Re: Slow performance of NMS api compared to Java

Would it be property of connection or transport? I thought connection means JMS connection and it has nothing to do with TCP. Vadim. On Wed, Aug 27, 2008 at 10:33 PM, Jim Gomes <[EMAIL PROTECTED]> wrote: > Since I couldn't look at your code because of the license grant issue, > I looked in to wha

NMS: OpenWire version

Apparently WireFormatNegotiator checks only magic bytes during the format negotiation and does not check the version. So NMS client V2 talks to ActiveMQ V3. Is it a bug? 394 [-1211205856] INFO Apache.NMS.Tracer (null) - SENDING: WireFormatInfo[ Magic=System.Byte[] Version=2 MarshalledProperties={C

Re: Slow performance of NMS api compared to Java

Since I couldn't look at your code because of the license grant issue, I looked in to what you had mentioned about the NoDelay option. I took a stab at adding support for turning this (and several other socket transport options) on and off from the connection URI. Once you fix the license grant,

Re: NMS Discovery with client

Yes, ActiveMQ broker has it implemented. You can search on the website to find out how to set it up. My company implemented our own proprietary auto-discovery a couple of years ago using UDP broadcasts and some middle-ware mBeans. Until it is added to the NMS client, you might be able to do somet

Re: NMS Discovery with client

I am using the activemq default broker with my C# app, which has that implemented right? So is there no way to take advantage of discovery from a C# client? Thank you. semog wrote: > > The Discovery Transport is part of the server code, and not currently > implemented in NMS. It would be a

Re: Deadlock in ActiveMQ version 4.1

I have the exact same issue with the same thread stack dump. This appears to occur after approximately 5000 messages go through our application. The application consists of a broker and two groups of listeners threads (different VM's). The listener groups will block for up to 5 minutes, and the

RE: Question about Logging in ActiveMQ 5.1

Not by default, I don't believe. Our organization added logging to a few places to achieve just that, but frankly it seems like overkill and since I took over the project I have never actually had to use those logs. You can use camel inside the broker to log messages when they arrive, I don't

Re: NMS: how to get list of messages?

Hi Vadim, There is no way of iterating through the messages that are currently in a queue. The closest you can get is to turn on queue mirrors (http://activemq.apache.org/mirrored-queues.html). There is an enhancement scheduled for NMS 1.1 to add QueueBrowser() as detailed in Jira issue AMQNET-9

Question about Logging in ActiveMQ 5.1

I'd like to setup log4j to log when a message was received by the broker, and when a consumer retrieved it. Is there a way to do this? It seems the default logging options are simply INFO, WARN, ERROR, FATAL, and DEBUG. We're currently using INFO, but would like a little more granular detail.

Re: NMS Discovery with client

The Discovery Transport is part of the server code, and not currently implemented in NMS. It would be a pretty cool feature to have in NMS. You can enter a Jira request for this enhancement and it will be scheduled for a future release. On 8/27/08, yesnid <[EMAIL PROTECTED]> wrote: > > Hello A

setting up the admin web console in an embedded instance

Hi, I have running an embedded instance of activemq. The xml file used to load the broker is attached. I am loading the broker using the BrokerFactory class. ACTIVEMQ is running and I can connect from the outside using the tcp transport. But if I go to : localhost:8171/admin, I get a 404 e

Re: Slow performance of NMS api compared to Java

Hi Stefan, Thanks for creating Jira AMQNET-109 and attaching the patch. However, the Grant ASF License option was not checked. Would you re-attach the patch and check that option? I can then look at integrating it into the codebase. Thanks! -Jim On 8/26/08, Stefan Gmeiner <[EMAIL PROTECTED]

Re: Build Problem ActiveMQ-CPP 2.2

Definitely sounds like its not able to find the lib file which means its probably not setup correctly. By default we expect in our projects file that the APR stuff is installed under C:\Program Files\APR if you have them somewhere else then you need to carefully add that location into all the incl

Build Problem ActiveMQ-CPP 2.2

Has anyone run into a problem when they try to build through the activemq-cpp-2.2\vs2005-build\vs2005-activemq-cpp.sln Similar to this: Error 19 fatal error LNK1104: cannot open file 'libapr-1.lib' vs2005-activemq-unittests I am trying to build activemq-cpp and I keep g

URL to access a /queue

I have ActiveMQ 5.1 running and I'm trying to figure out how to access /queue/test from a client. I'm wondering ... is there some way to build a URL so that I can access a queue and received data when it's published? I'm using orbited/stomp from a browser w/ a tcp socket to get to it. Any ideas? -

NMS Discovery with client

Hello All, I created a simple C# win-forms application that receives messages from the ActiveMQ broker. I am now trying to alter this so that I can use discovery, can anyone explain how I would go about this in code from C# with NMS? Thank you, Appreciate the help. -- View this message in cont

Re: LDAPAuthoizationMap permissions

To fix this I made some changes in the LDAPLoginModule. The problem appears to lie in the getRoles method. I based my changes on the code that finds the topic and queue objects in the LDAPAuthorizationMAP and the code that finds the user in LDAPLoginModule. Here is the diff: @@ -49,6 +49,8 @@ im

Re: Slow performance of NMS api compared to Java

I had similar results as yours when performance testing NMS. You may want evaluate IKVM for C# integration. Using IKVM, I had 4 times the message throughput than NMS. Also, the converted jar -> dll gives you access to the full JMS API for your C# producers and consumers. Stefan Gmeiner wrote: >

Re: Problem to start AMQ 5.1.0

On Wed, Aug 27, 2008 at 4:51 AM, NabiL <[EMAIL PROTECTED]> wrote: > > Hi all, > > I use ActiveMQ 5.1.0, OS Linux ES 4. > > I get errors when start activemq, why ? > > ACTIVEMQ_HOME: /usr/apache-activemq-5.1.0 > ACTIVEMQ_BASE: /usr/apache-activemq-5.1.0 > Loading message broker from: xbean:activemq.

Re: NMS and message groups

Hopefully, it is working now. It definitely wasn't before, though. I'm OK with leaving the NMSXGroupID as-is for now. It can be set on the IMessage interface now, so the functionality is there. On Wed, Aug 27, 2008 at 7:52 AM, James Strachan <[EMAIL PROTECTED]>wrote: > 2008/8/27 Jim Gomes <[EM

Re: NMS and message groups

Hi James, There was an implementation gap on this area. I refactored this area of the code. Feel free to look over it to make sure I did things right. I wanted to make the IMessage.Properties transparent to use and interchangeable with the SetObjectProperty/GetObjectProperty functions. A user

Re: NMS and message groups

2008/8/27 Jim Gomes <[EMAIL PROTECTED]>: > Hi James, > > There was an implementation gap on this area. I refactored this area of the > code. Feel free to look over it to make sure I did things right. I wanted > to make the IMessage.Properties transparent to use and interchangeable with > the Set

Re: NMSXGroupSeq and ActiveMQMessage

Hi Marko, Would you get the latest code and try your tests again? I think the NMSXGroupSeq and NMSXGroupID settings were not being set properly before. Now that they are being set correctly on the client, we can test that they are being interpreted correctly by the broker. Also, is there any way

Re: Compile of ActiveMQ.NMS.ActiveMQ fails under Windows XP

Great! Glad I was able to help. Feel free to offer and contribute any additional unit tests. I am very interested in greatly expanding the tests that are in place. Best, Jim On Tue, Aug 26, 2008 at 2:26 PM, aschrum <[EMAIL PROTECTED]> wrote: > > Hi Jim, > > I'll be brief in the future. Here's

Re: STOMP remove Durable Subscriber

The patch attached to the issue should solve the problem now. Cheers Dejan Bosanac-3 wrote: > > The issue is definitely still here. I've created issue with test case: > https://issues.apache.org/activemq/browse/AMQ-1890 > > I'll try to nail it down soon. > > Cheers > > -- > Dejan Bosanac >

Re: Connection not acknowledged / Connection reset

Michael suggested the following which solved my problem. Sounds like something funny is going on with stream_select() on line 558. Can you retry with lines 510-512 in Stomp.php commented out? Note that I was able to connect to my amq server from my laptop running php5.2. The problem only ap

Re: How and Where to set asyncSend attribute ?

Hi Gary , Thanx for the info . My basic doubts get clarified . I have executed the performance test with the help of activeMQ performance plug in . How to interpet the results . The summary of the Report is as fallows : 41949 4 134.88424437299037 133.81350482315113 33.72106109324759 33.4533

Re: Out of memory exception in ActiveMQ

Try increase your heap; as a broker and mule server and JMS client is gonna use up RAM. To reduce the memory overhead of the JMS client you can reduce the prefetch... http://activemq.apache.org/what-is-the-prefetch-limit-for.html the out of the box broker config should be fine but if you're reall

How to Interpet the Performance report from the activeMQ performance plugin

Hi , I have executed the performance test with the help of activeMQ performance plug in . How to interpet the results . The summary of the Report is as fallows : 41949 4 134.88424437299037 133.81350482315113 33.72106109324759 33.453376205787784 clientName=JmsProducer1,value=0 clientName=JmsPr

Re: Out of memory exception in ActiveMQ

Hi, We are using following - 1. ActiveMQ 5.1 2. I have not set JVM heap to any value. 3. We are running a mule server. 4. Both the consumer and broker are using the same JVM. Thanks, Manu James.Strachan wrote: > > Which version are you using? What did you set your JVM heap to? Which > JVM got

Re: Problem to start AMQ 5.1.0

if the system in which you are running the MQ server is not in lan , i think we get this exception . Comment the discoveryUri="multicast://default" part in the config file start the server. Regards, Jill NabiL wrote: > > Hi all, > > I use ActiveMQ 5.1.0, OS Linux ES 4. > > I get errors

Problem to start AMQ 5.1.0

Hi all, I use ActiveMQ 5.1.0, OS Linux ES 4. I get errors when start activemq, why ? ACTIVEMQ_HOME: /usr/apache-activemq-5.1.0 ACTIVEMQ_BASE: /usr/apache-activemq-5.1.0 Loading message broker from: xbean:activemq.xml INFO BrokerService - Using Persistence Adapter: AMQPersiste

Re: ActiveMQ and SMX4

James Strachan ha scritto: 2008/8/26 Guillaume Nodet <[EMAIL PROTECTED]>: ServiceMix distribution includes ActiveMQ and Camel, while the ActiveMQ distribution includes Camel. The ServiceMix Kernel is an enhanced OSGi based runtime that does not include the JBI layer, ActiveMQ or Camel, but th

Re: Out of memory exception in ActiveMQ

Which version are you using? What did you set your JVM heap to? Which JVM got the OOM exception, the broker or the consumer? This document helps you get better help quicker http://activemq.apache.org/support.html 2008/8/27 Manupriya <[EMAIL PROTECTED]>: > > Hi, > > We have the following requireme

Re: How and Where to set asyncSend attribute ?

Hi Jill, it is a client side option. An option that effects a message producer. So you set it on the connection factory used by your client. Either append "?jms.useAsyncSend=true" to the brokerUrl or in code, invoke the ActiveMQConnectionFactory.setUseAsyncSend(boolean) method. 2008/8/27 Srini.Ji

Re: NMSXGroupSeq and ActiveMQMessage

Sorry, I have expressed myself incorrectly. I meant that I sent 10 messages with NMSXGroupSeq set to 0. And they were all recived by same consumer. I tried sending 10,000 and same thing happens again. James.Strachan wrote: > > 2008/8/27 Marko111 <[EMAIL PROTECTED]>: >> >> No, thats not what is

Re: how to set priority of brokers in failover URI

You can turn off the default random behavior and have an ordered list with the following: failover:(tcp://x.x.x.x:xx,tcp://y.y.y.y:yy)?randomize=false see: http://activemq.apache.org/failover-transport-reference.html for more options. 2008/8/26 stevec <[EMAIL PROTECTED]>: > > On the client, ho

Out of memory exception in ActiveMQ

Hi, We have the following requirement - 1. We read a flat file that has around 2 million rows. 2. For each row we do some processing and create a JMS message and put it in an ActiveMQ topic. 3. We have a consumer that consumes each of there messages and then does some processing. 4. We need the

Re: NMSXGroupSeq and ActiveMQMessage

2008/8/27 Marko111 <[EMAIL PROTECTED]>: > > No, thats not what is happens. I sent 10 messages with 0 group id and they > were all recived by same consumer. Thats quite common due to prefetch size BTW http://activemq.apache.org/what-is-the-prefetch-limit-for.html did you try say 10,000 messages?

Does Apache Camel support HTTPS in the JETTY and/or HTTP components?

Dear Newsgroup! Does Apache Camel contain HTTPS support in the JETTY and/or HTTP components? Best Regards Michael Justin -- View this message in context: http://www.nabble.com/Does-Apache-Camel-support-HTTPS-in-the-JETTY-and-or-HTTP-components--tp19176433p19176433.html Sent from the ActiveMQ -

Re: NMSXGroupSeq and ActiveMQMessage

No, thats not what is happens. I sent 10 messages with 0 group id and they were all recived by same consumer. James.Strachan wrote: > > 2008/8/26 Marko111 <[EMAIL PROTECTED]>: >> >> Hi, >> >> I am using NMSXGroupSeq property of AcitveMQMessage object to terminate >> group sequence. When set 0