*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
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
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
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
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
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
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
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
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
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.
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
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
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
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
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
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
16 matches
Mail list logo