Is there a way to know when the standby exclusive consumer become active

I'm using active/active exclusive consumer model to consume message from the ActiveMQ. Since I'm writing the consumed message files and split the file based on time(e.g. 30min). When the active consumer dies and the standby consume become active I need to start up the timer. So is there a way to

Getting 'java.net.SocketException' in ActiveMQ logs frequently

We are frequently getting 'java.net.SocketException' in ActiveMQ logs. Aftr that the number of consumer becomes 0 and message becomes pending. java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: tcp:///10.51.19.88:2855 Our

Re:Getting 'java.net.SocketException' in ActiveMQ logs frequently

Seems this is a real FAQ but never gets answered. http://stackoverflow.com/questions/62929/java-net-socketexception-connection-reset At 2013-04-23 15:26:21,Prashant prash...@in.ibm.com wrote: We are frequently getting 'java.net.SocketException' in ActiveMQ logs. Aftr that the number of

Re:Is there a way to know when the standby exclusive consumer become active

yes, you can subscribe the advisory topic to get notified when consumers start or stop. For exclusive consumer it will release the exclusive lock when it's stopped, that means there must be a switch happening. At 2013-04-23 14:28:23,Sean Guo s...@voxeolabs.com wrote: I'm using active/active

Re: Consumer not consume message

On 04/23/2013 01:18 AM, Balachandar R.A. wrote: Hello, I have an issue. I push 100 messages to the queue with one consumer initially. The consumer takes the message and starts working. After few seconds, I start another consumer. The second consumer does not take any messages from the queue

Re: Is there a way to know when the standby exclusive consumer become active

Thanks for the quick reply. Can I get such kind of notify inside the same message listener which receives the normal JMS message from the queue? On Tue, Apr 23, 2013 at 4:21 PM, SuoNayi [via ActiveMQ] ml-node+s2283324n4666142...@n4.nabble.com wrote: yes, you can subscribe the advisory topic

JMSXUserID is overrided in network of broker

When a message move to another broker, JMSXUserID contain the userName defined in networkConnector. There is a way to keep the initial producer userName in this case ? -- View this message in context:

Re: Trying to set up non-persistant messaging...

with broker persistence=false / there is no temp store for the file pending message cursor to use so all messages are retained in memory. you need to send non persistent messages, producer.setDeliveryMode(NON_PERSISTENT) and enable broker persistence. Then the file cursor will over flow to disk

Re: Getting 'java.net.SocketException' in ActiveMQ logs frequently

Interesting, and I can understand why exceptions (and FAQ) like this...go unanswered for years. I think I have seen this exception in the past, since my app was dependent on a Verizon 4G wireless internet connection (something that CEO wanted and was proud to have, until myself and another

Re: How to set network connector between to secure activemq broker?

This seems to be unanswered on activemq-user forum too. http://mail-archives.apache.org/mod_mbox/activemq-users/200910.mbox/%3c69b2d60e0910240900r3d36b142w236ec1bf6f6d8...@mail.gmail.com%3E -- View this message in context:

Not able redelivery all 500 messages from DLQ

I am using active-mq 5.5.1 In DLQ i am having 500 messages,i just redelivery messages into using active-mq api i used below code to redelivery 500 messages mbeanProxy.moveMessageTo Messages re-delivering into queue,But due to some reason messages coming back into DLQ again. This issue

Re: use AMQ to transfer, about Security problem

I am stuck in the same situation. http://activemq.2283324.n4.nabble.com/How-to-set-network-connector-between-to-secure-activemq-broker-td4664874.html The two broker in my case use jaas auth plugin and the users can never be same in two brokers. And I have to use duplex network connection. Did

Is there a workaround for AMQ-4328 Cross talk over duplex network connection can lead to blocking

Hi, We have a duplex network connection between two brokers and when we run load on these nodes, messages are not shared between two brokers. after I searched around I found AMQ-4328 https://issues.apache.org/jira/browse/AMQ-4328 Cross talk over duplex network connection can lead to blocking

Re: Trying to set up non-persistant messaging...

My consumer prefetch is 1 for all consumers. I have 10 consumers right now for testing, but will ramp up to 400. -- View this message in context: http://activemq.2283324.n4.nabble.com/Trying-to-set-up-non-persistant-messaging-tp4666127p4666155.html Sent from the ActiveMQ - User mailing list

Re: using jndi caused error

I found following description in my pom.xml and this overrides java.naming.provider.url in jndi.properties. systemProperty keyjava.naming.provider.url/key valuejni://localhost:1099/value /systemProperty I removed above definition from pom.xml, then it worked fine. -- View this