Multiple Consumers/Single queue

I'm having trouble getting load balancing to work across multiple consumers on a single queue. I've read all the docs I could find on the website regarding prefetch values, async dispatch and round robin dispatch models, but I still can't get it to work. And yeah, I found this page, and tried

Wireformat exception

Hi, We are using ActiveMQ 4.1 running on local broker, with a fail-over network connected to a remote broker. We have a producer program putting mesage to the local broker, and the message will automatically get transmitted to the remote broker, where the consumer will consume the message. We appl

Bad signature for release 4.1.0?

Hi - I downloaded 4.1.0 (current) version: apache-activemq-4.1.0-incubator.zip and the signing keys from the repository under trunk/KEYS and the si

Re: Message queue getting blocked

I've added an entry to the FAQ on this one... http://cwiki.apache.org/ACTIVEMQ/my-producer-blocks.html On 3/2/07, Po Cheung <[EMAIL PROTECTED]> wrote: I am seeing a queue being blocked in both ActiveMQMessageProducer.send() and ActiveMQMessageConsumer.close() and no more messages can be prod

Message queue getting blocked in both ActiveMQMessageProducer and ActiveMQMessageConsumer

I am seeing a queue being blocked in both ActiveMQMessageProducer.send() and ActiveMQMessageConsumer.close() and no more messages can be produced or consumed. The test case involved a client sending a single message to a queue every 10 minutes. Another client consumed the message and produced a

Re: [Spam: 5.0] Message queue getting blocked

Here is the missing thread dump for ActiveMQMessageProducer.send in the original post: "jmsConnector.jmsConnector.dispatchers.dispatcher.8" prio=1 tid=0xbf91bcc0 nid=0xab156bb0 [EMAIL PROTECTED] in Object.wait() [ab155000..ab156170] at java.lang.Object.wait(Native Method) - waiting on <

Message queue getting blocked

I am seeing a queue being blocked in both ActiveMQMessageProducer.send() and ActiveMQMessageConsumer.close() and no more messages can be produced or consumed. The test case involved a client sending a single message to a queue every 10 minutes. Another client consumed the message and produced a

Re: Remove all messages from a queue

On 3/2/07, Kelly Campbell <[EMAIL PROTECTED]> wrote: One problem with Rob's method of initialization is you have to re-initialize the broker for each unit test which I'd rather not do for performance reasons. The problem with the recommended approach James mentioned in the docs (turning persiste

Re: Remove all messages from a queue

One problem with Rob's method of initialization is you have to re-initialize the broker for each unit test which I'd rather not do for performance reasons. The problem with the recommended approach James mentioned in the docs (turning persistence off), is what about when you specifically want to

Re: Remove all messages from a queue

Rob Davies wrote: > for unit tests - we often set the deleteAllMessagesOnStartup flag on the > broker > > For your case where you are using the vm://transport, create the broker > separetly in your setUp() - and set the deleteAllMessageOnStartup > property on the broker before calling start() or s

Re: [Spam: 5.0] Durable Topic subscriber

Well the bussiness case is to have http://www.nabble.com/file/6894/forumn.jpg image is uploaded. If one embedded broker talking to multiple embedded brokers i am not sure how it will work. The reason we have several subscribers running on several machines is that the number of clients are huge

Re: [Spam: 5.0] Problem whith librairies

On 3/2/07, didyeah971 <[EMAIL PROTECTED]> wrote: I just saw my mistake but actually, the directory proposed on the site was really activemq-web Yeah - I fixed that before hitting send on my previous reply :) , but i should have guessed it by myself. No worries Thx a lot You're welcome

Re: [Spam: 5.0] Durable Topic subscriber

Ah, so you're using networks right? Try using Master/Slave instead. We currently don't provide ordering guarrentees across store-and-forward networks. On 3/2/07, Mathulan <[EMAIL PROTECTED]> wrote: The testcase is There are 2 machines Machine A, B. Each of them running single brokers each (B

Re: [Spam: 5.0] Problem whith librairies

I just saw my mistake but actually, the directory proposed on the site was really activemq-web, but i should have guessed it by myself. Thx a lot Did James.Strachan wrote: > > It looks like you missed the first line of the 2 lines you're meant to > type. Try cd into the activemq-web-demo directo

Re: [Spam: 5.0] Durable Topic subscriber

The testcase is There are 2 machines Machine A, B. Each of them running single brokers each (BrokerA, BrokerB). The dispatch policy is setup on both brokers as follows A Topic publisher is attached to BrokerA (PubA) is publishing 1000 messages to 'MyTopic'. And the Durable topic subscr

Re: [Spam: 5.0] Durable Topic subscriber

Could you post a test case that reproduces the issue? On 3/2/07, Mathulan <[EMAIL PROTECTED]> wrote: I tried in both 4.1 & 4.2-Snapshot James.Strachan wrote: > > Which version were you using? > > On 3/2/07, Mathulan <[EMAIL PROTECTED]> wrote: >> >> Hi All, >> >> I am trying to get the ordere

Re: [Spam: 5.0] Durable Topic subscriber

I tried in both 4.1 & 4.2-Snapshot James.Strachan wrote: > > Which version were you using? > > On 3/2/07, Mathulan <[EMAIL PROTECTED]> wrote: >> >> Hi All, >> >> I am trying to get the ordered message delivery for durable Topic >> subscriber. I have setup despatch policy as below >> >>

Re: [Spam: 5.0] Problem whith librairies

It looks like you missed the first line of the 2 lines you're meant to type. Try cd into the activemq-web-demo directory first before running the mvn command http://cwiki.apache.org/ACTIVEMQ/web-samples.html On 3/2/07, didyeah971 <[EMAIL PROTECTED]> wrote: I am still trying the Ajax module. I

Re: [Spam: 5.0] Problem whith librairies

I am still trying the Ajax module. I downloaded and compiled all the code, because when i tried to build only the web modules i had some errors. Now i am trying to launch it with maven, with the command mvn jetty:run, and i have this error: [INFO] The plugin 'org.apache.maven.plugins:maven-jetty

Re: Durable Topic subscriber

Which version were you using? On 3/2/07, Mathulan <[EMAIL PROTECTED]> wrote: Hi All, I am trying to get the ordered message delivery for durable Topic subscriber. I have setup despatch policy as below Also the publisher does Message grouping

Re: [Spam: 5.0] Pausing Transmission

That all sounds great - particularly the bit about contributing changes back to the project :) The best place to start is probably to write your own TransportFilter to do the stuff you need (allowing pause/resume/monitor throughput etc etc). If you need closer integration with the TCP layer you m

Re: [Spam: 5.0] ActiveMQ 4.1 Queue is full

Could you please let me know the jira number for this issue fix? I would like to include the link in our documentation so that our customers have full knowledge of this particular fix and could make a knowledgeable decision on the upgrade.. Thanks in advance.. rajdavies wrote: > > The memor

Durable Topic subscriber

Hi All, I am trying to get the ordered message delivery for durable Topic subscriber. I have setup despatch policy as below Also the publisher does Message grouping as well. But when the durable subscriber goes offline and comes back the message

Re: [Spam: 5.0] Pausing Transmission

James Again, thanks for taking the time to help. We got some feedback from the customer, they want to be able to do the Quality of Service measurements and control from outside of Active MQ. We still want to control the transport, turning it on and off, but we want to empower the Broker object to

Re: Is ActiveMQMessageProducer.send thread safe?

yes! On 1 Mar 2007, at 09:47, Paul French wrote: Is ActiveMQMessageProducer.send thread safe? -- View this message in context: http://www.nabble.com/Is- ActiveMQMessageProducer.send-thread-safe--tf3325927s2354.html#a9246594 Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Remove all messages from a queue

for unit tests - we often set the deleteAllMessagesOnStartup flag on the broker For your case where you are using the vm://transport, create the broker separetly in your setUp() - and set the deleteAllMessageOnStartup property on the broker before calling start () or setting a transport co