master/slave, consumer can not failover

2012-06-28 Thread bizcenter
*Deploy the brokers with master/slave, when master stops, consumer can not reconnect to slave.* code example: /String brokerUrl = "failover:(tcp://hostA, tcp://hostB)"; try { connection = factory.createConnection(); // if a durable topic subscription, and client id must

Re: master/slave, consumer can not failover

2012-06-28 Thread bizcenter
Thanks for you answer! *In my environment, hostA on port 61616, hostB on 61617.* When master down, slave becomes master. Producer can failover, but consumer not with the same configuration. String brokerUrl = "failover:(tcp://localhost:61616,tcp://localhost:61617)"; What troubles me is why the

Re: master/slave, consumer can not failover

2012-06-29 Thread bizcenter
broker uri: failover:(tcp://localhost:61616, tcp://localhost:61617) but the problem still occurs... my configuration is right, the exception indicates that the client fail from 61616, try to reconnect 61617 -- View this message in context: http://activemq.2283324.n4.nabble.com/master-slave-cons

Activemq Performance

2012-08-15 Thread bizcenter
Hello buddy: as following configuration, my activemq send 1 messages in 30seconds, anyone who can help me to improve the speed(sending) . Thanks. Sender: 1. use PooledConnectionFactory 2. asyncSend Receiver: default prefecht http://www.springframework.org/schema/beans"; xmln

Re: master/slave, consumer can not failover

2012-08-20 Thread bizcenter
Consumer can do failover in web project. Consumer should be a servlet! You can have a try! On Tue, Aug 21, 2012 at 2:38 AM, joesan [via ActiveMQ] < ml-node+s2283324n4655327...@n4.nabble.com> wrote: > Did you find a solution to this? I have more or less the same issue. My > Producer can fail-over

How to mintor activemq

2012-10-22 Thread bizcenter
When using ActiveMQ, some problems troubles me: 1. When broker crashed or stopped, messages from sender will be lost(I set timeout, because the sender have others to do). 2. consumer receives all messages from broker, but how i dnow the consumer received all messages(zero lost). 3. If message is l

Re: How to mintor activemq

2012-10-23 Thread bizcenter
Sorry, I didn't make myself clearly. For reability, i should not set timeout. But in my business, 2 seconds means too long. So 'useAsyncSend' and 'sending timeout' is necessary. Timeout is not message timeout but sending timeout(in 2 seconds), message is persisted forever. In this condition, mes

activemq transaction

2013-05-27 Thread bizcenter
Forgive my poor english. In JMS transaction, messages sent will be persisted( stored in db) before session.commit() is fired? Assume that the session.commit() failed, then the broker is stopped : 1. where are messages sent? 2. The broker starts in the future, if i can do session.c

Re: ActiveMQ Topic Persistence - ActiveMQ restart

2013-05-27 Thread bizcenter
you should use durable sbuscription! You follow these steps 1. Create a durable topic subscription 2. Publish some messages to the topic(Qos: set persistent to true) more to see: http://activemq.apache.org/why-do-i-not-receive-messages-on-my-durable-topic-subscription.html -- View this

Re: Re:activemq transaction

2013-05-27 Thread bizcenter
Thanks, I got it. There is a MemoryTransactionStore will hold all messages. -- View this message in context: http://activemq.2283324.n4.nabble.com/activemq-transaction-tp4667500p4667521.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Producer Window Size

2013-06-25 Thread bizcenter
In org.apache.activemq.broker.region.Queue#send(ProducerBrokerExchange, Message), it just determine that the producerWindowSize is greater than 0, so set producerWindowSize to 1024 or 10240 can do the same effect??? am i right? public void send(final ProducerBrokerExchange producerExchange, final

Producer Window Size

2013-06-25 Thread bizcenter
In org.apache.activemq.broker.region.Queue#send(ProducerBrokerExchange, Message), it just determine that the producerWindowSize is greater than 0, so set producerWindowSize to 1024 or 10240 can do the same effect??? am i right? public void send(final ProducerBrokerExchange producerExchange, final

Producer Window Size

2013-06-25 Thread bizcenter
In org.apache.activemq.broker.region.Queue#send(ProducerBrokerExchange, Message), it just determine that the producerWindowSize is greater than 0, so set producerWindowSize to 1024 or 10240 can do the same effect??? am i right? public void send(final ProducerBrokerExchange producerExchange, final

Re: JMX Connector problems

2013-08-19 Thread bizcenter
connectorPath in ManagementContext is jmxrmi, if you create more instances of ManageContext, the error above will occur. change connectorPath (or port). On Fri, Aug 16, 2013 at 1:02 AM, Ashwini Kuntamukkala [via ActiveMQ] < ml-node+s2283324n4670430...@n4.nabble.com> wrote: > Here is the stacktra

Re: [ActiveMQ]How to setup fault-tolerant consumer node?

2013-12-18 Thread bizcenter
hi: What you want: 1. consumer node just consume message once 2. consumer node is in cluster am i right? you should have a look at VirtualTopic http://activemq.apache.org/virtual-destinations.html On Fri, Dec 13, 2013 at 5:23 PM, rajdavies [via ActiveMQ] < ml-node+s2283324n46

Re: Re: What is the effect of dedicatedTaskRunner Attribute?

2014-01-13 Thread bizcenter
Activemq supports DedicatedTaskRunner and PooledTaskRunner: DedicatedTaskRunner: One thread to execute all tasks. PooledTaskRunner: Thread pool to execute all tasks, default size is Integer.MAX_VALUE. bizcenter...@gmail.com From: khandelwalanuj [via ActiveMQ] Date: 2014-01-13 22:30 To