Re: Same MessageId assigned Messages created at the same time...

This does sound bizarre, as the message ID = producerID + sequenceNumber. Are you positive that both your producers have the same producer IDs? On 6/20/07, rvenkat23 <[EMAIL PROTECTED]> wrote: Here is the two message ids: ID:beprd02-46310-1181944109798-1:0:19:1:702 ID:beprd02-46310-11819441097

Re: UDP buffer problem

UDP is unreliable; whatever the buffer size is, messages can still get discarded if a client doesn't process them fast enough etc. So we need a working reliable layer on top of UDP which is capable of handling re-requests of missing packets etc. The current code is work in progress; which nearly

Re: How to have a highly available and scalable setup using network of brokers?

On 6/20/07, Nicky Sandhu <[EMAIL PROTECTED]> wrote: James.Strachan wrote: > > On 6/20/07, Nicky Sandhu <[EMAIL PROTECTED]> wrote: >> >> I am in the process of trying to setup a network of brokers for HA > > If you want HA then you want a Master/Slave arrangement as you > probably want to replicat

Re: How to have a highly available and scalable setup using network of brokers?

Joel Schaubert wrote: > > > Our strategy is to use the "network of brokers" hosted behind a load > balancer. > http://activemq.apache.org/networks-of-brokers.html > > What are the extra benefits of going to the more complicated setup of > pairs of master/slave's behind the load balancer instea

Re: UDP buffer problem

I still not find the correct way to resolve this problem. I have changed the replayBufferCommandCount to 1000 and compiled the source code . Then I replaced the ReliableTransport.class in the lib. But when I run the client, it was the same. "Request for buffer xx is no longer present" in eclipse

How to config to make the activemq work with load balance?

I integrated the ActiveMQ into the application of JBoss,and I used the ActiveMQ in clustering environment. I have tried many times for the value of ,but the result is I didn't made the consumer MDB receive the message with load balancing. I want to make the consumer MDB receive message with ro

Actually getting Stomp support to a usable state...

- "James Strachan" <[EMAIL PROTECTED]> wrote: ... > Just use the JAAS plugin in ActiveMQ and you're good to go; the Stomp > code uses whatever security plugin you're using As has been discussed, this is broken, and has been since 4.1.1 or earlier. Is there any sort of roadmap to the Act

Basic Spring+AMQ+XBean+embededbroker problem

Ok, well I'm officially stumped, but I can't get a basic Spring+AMQ 4.1.1+XBeans with embedded broker test harness to work using the configuration outlined here: http://activemq.apache.org/how-do-i-embed-a-broker-inside-a- connection.html I get a ClassNotFoundException (see [1]). Now, _ob

Re: Same MessageId assigned Messages created at the same time...

Here is the two message ids: ID:beprd02-46310-1181944109798-1:0:19:1:702 ID:beprd02-46310-1181944109798-1:0:19:1:702 Note: Whenever we change the status of an item, we place the message in the queue and these message ids and item id are logged into a table. Above are the item ids generated for t

Re: Same MessageId assigned Messages created at the same time...

rvenkat23 wrote: > > recently i found out that two messages created by 2 different producer(s) > at the same time are having the same messageid. > can you post the message ID's that you are seeing? Also how are you examining the messages to determine what their ID's are? Joel Schaubert --

Same MessageId assigned Messages created at the same time...

Hi, We are using ActiveMQ 4.1.1, recently i found out that two messages created by 2 different producer(s) at the same time are having the same messageid. In this case one of the message is consumed by the listener (async) and the other is not. Please let me know anyone faced the same behavi

Re: How to have a highly available and scalable setup using network of brokers?

Nicky Sandhu wrote: > > I am in the process of trying to setup a network of brokers for HA behind > a load balancer. The aim is to allow clients to see a virtual broker > (which is really load balanced and with fail over) with a single IP/port. > We've been testing a simpler failover strategy

Re: How to have a highly available and scalable setup using network of brokers?

James.Strachan wrote: > > On 6/20/07, Nicky Sandhu <[EMAIL PROTECTED]> wrote: >> >> I am in the process of trying to setup a network of brokers for HA > > If you want HA then you want a Master/Slave arrangement as you > probably want to replicate messages to multiple physical brokers (or > shar

Re: How to have a highly available and scalable setup using network of brokers?

On 6/20/07, Nicky Sandhu <[EMAIL PROTECTED]> wrote: I am in the process of trying to setup a network of brokers for HA If you want HA then you want a Master/Slave arrangement as you probably want to replicate messages to multiple physical brokers (or share state across multiple brokers via JDB

Re: Memory Leak Using Temporary Queues

Running a profiler should help decifer where the memory leak is. I'm wondering if its the advisory issue ... http://issues.apache.org/activemq/browse/AMQ-1255 On 6/20/07, mpont <[EMAIL PROTECTED]> wrote: Hello All, I am grappling with what appears to be memory leaks while creating and destr

How to have a highly available and scalable setup using network of brokers?

I am in the process of trying to setup a network of brokers for HA behind a load balancer. The aim is to allow clients to see a virtual broker (which is really load balanced and with fail over) with a single IP/port. The LBR is round robin spraying connections to all the masters and the slaves are

Re: Server side memory leak on connection with NMS

OK, so I went back to version 4.0.2, and the memory leak went away with exactly the same test app. So can anyone confirm whether this is a bug in 4.1.1, or whether NMS is not compatible with 4.1.1? Also, all the docs seem to relate to 4.1.1 now. How should a topic be set up in the xml file in ver

Memory Leak Using Temporary Queues

Hello All, I am grappling with what appears to be memory leaks while creating and destroying Temporary Queues. Should an application that is consuming X bytes of memory be able to create new Temporary Queues that consume Z additional bytes (total application memory consumption is now X+Z bytes)

Re: How to config the load balancer?

On 6/20/07, abs327 <[EMAIL PROTECTED]> wrote: I integrated the ActiveMQ into the application of Jboss, and I will use the cluster function. What cluster function & why do you want to use it? Now, I meet a question. I try to make the ActiveMQ work with load balancing, but I don't know how to

Re: How to receive messages concurrently from a queue?

Great! Thanks. Naresh -- View this message in context: http://www.nabble.com/How-to-receive-messages-concurrently-from-a-queue--tf3949698s2354.html#a11215154 Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Setting compression through XML configuration

On 6/16/07, iqbalzaveri <[EMAIL PROTECTED]> wrote: Hello, I am trying to set compression for messages using XML config. Here's a snapshot of the activemq.xml http://activemq.org/config/1.0";> . .. ... factory = new ActiveMQConnectionFactory(url); You are not looking

Re: reading message size using queue browser

On 6/20/07, keneida <[EMAIL PROTECTED]> wrote: using queue browser i can see all the parameters of the messages. However doesnt matter what I send the "size" parameter is always 0. What "size" parameter? -- James --- http://macstrac.blogspot.com/

Re: Setting compression through XML configuration

You are setting the compression in the client configuration not tha AMQ server iqbalzaveri wrote: > > Hello, > I am trying to set compression for messages using XML config. Here's a > snapshot of the activemq.xml > > > > >class="org.springframework.beans.factory.config.PropertyPlace

Re: Server side memory leak on connection with NMS

OK, so I hooked up JProbe to an instance running on my Windows XP workstation, and I see the same behaviour. It looks very much like the InactivityMonitor class is holding on to instances of TcpTransport - when I release the reference from InactivityMonitor to TcpTransport in JProbe, it can be gar

Re: message compression

On 6/20/07, keneida <[EMAIL PROTECTED]> wrote: what kind of compression is used when jms.useCommpresion is deifned to true. gzip -- James --- http://macstrac.blogspot.com/

Re: How to receive messages concurrently from a queue?

Hi Naresh, I added a bit of documentation on the default values here http://cwiki.apache.org/confluence/display/ACTIVEMQ/What+is+the+prefetch+limit+for Regards, Jonas Naresh Bhatia wrote: Jonas, that did the trick. Thank you. BTW, are the default values documented somewhere? I could only fin

message compression

what kind of compression is used when jms.useCommpresion is deifned to true. -- View this message in context: http://www.nabble.com/message-compression-tf3952518s2354.html#a11213828 Sent from the ActiveMQ - User mailing list archive at Nabble.com.

How to config the load balancer?

I integrated the ActiveMQ into the application of Jboss, and I will use the cluster function. Now, I meet a question. I try to make the ActiveMQ work with load balancing, but I don't know how to config the xml file to make it effect. I need your help, thanks. -- View this message in context: htt

Re: How to receive messages concurrently from a queue?

Jonas, that did the trick. Thank you. BTW, are the default values documented somewhere? I could only find them burried deep in the JMX console. Naresh -- View this message in context: http://www.nabble.com/How-to-receive-messages-concurrently-from-a-queue--tf3949698s2354.html#a11213111 Sent fr

reading message size using queue browser

using queue browser i can see all the parameters of the messages. However doesnt matter what I send the "size" parameter is always 0. -- View this message in context: http://www.nabble.com/reading-message-size-using-queue-browser-tf3951562s2354.html#a11210820 Sent from the ActiveMQ - User maili

Re: How to receive messages concurrently from a queue?

Hi Can you try setting your prefetch limit to a lower value (ie. 10) ? http://activemq.apache.org/what-is-the-prefetch-limit-for.html Regards, Jonas Naresh Bhatia wrote: I have a very simple Java program that creates 10 MessageListeners to receive JMS messages concurrently from a queue. The M