The problem is resolved in 5.6-SNAPSHOT with the auditNetworkProducers flag
so I'll take another look at my backport.
Thanks,
Bruce
--
View this message in context:
http://activemq.2283324.n4.nabble.com/AMQ-5-5-1-Duplicate-Messages-After-Network-Outage-and-Broker-Restart-tp4520697p4526378.html
S
This is the listener startup code, started by a servlet listener. The 'Queue
Setup done' is printed to the console, no errors:
public TestMyQueueListener startTestQueueConsumer() {
try {
if (testMyQueueListener == null) {
testMyQueueListener = new TestMyQue
the best way to validate your back port is to verify that the problem
is resolved with a 5.6-SNAPSHOT[1],
there are some tests that exercise that feature, in particular:
org.apache.activemq.usecases.TwoBrokerQueueClientsReconnectTest#testDuplicateSend
maybe give that a run on your branch.
If you
Its a bit difficult to follow your observations. However forget about the
ActiveMQ.Advisory.* topics, these are just advisory channels
(http://activemq.apache.org/advisory-message.html).
Your code snippet below seems to send a message to a queue called MyQueue. If
the consumerCount for that des
Param 'DestinationName' on the message I send(find it in JMX) has
ActiveMQ.Advisory.TempTopic and TempQueue, not MyQueue. It is listed under
Subscription.Non-Durable.Topic...
I am using this code to produce the message(Can you see why it isn't
published on MyTopic?):
String message = "test mes
Hi,
> Foremost I am unsure about whats the preferred way of
> running/deploying ActiveMQ. Is it good enough to let it run as a UNIX
> service?
Yes, thats good enough and probably used most often.
You can embed ActiveMQ in other applications as well but please be aware that
you tie the lifetime
Also, there are two consumers listed under 'Topic' folder as
'ActiveMQ.Advisory.Consumer.Queue.MyQueue' and
'ActiveMQ.Advisory.Consumer.Topic.MyTopic' and when I send messages, new
entries in the monitor occur as 'ActiveMQ.Advisory.Producer .. Queue.MyQueue
and Topic.MyTopic'. The topic and queue
There is a MyTopic and a MyQueue and both have 'ConsumerCount' set to 1 at
startup. However I noticed that 'ProducerCount' is set to 0 for both. Also,
when I send messages the 'ConsumerCount' goes to zero and the
'ProducerCount' goes to the number of messages sent. Same as
'EnqueueCount'.
--
View
Hi,
Check using jconsole that a consumer is registered on the destination that you
want to consume from.
If its not registered, then there is most likely a problem with your consumer
code.
Hope this serves as a starting point.
Torsten Mielke
tors...@fusesource.com
tmie...@blogspot.com
On
Hello,
Check the javadoc of PooledConnectionFactory [1].
The class description mentions that this ConnectionFactory also pools sessions
and MessageProducers.
Your approach looks correct to me. Every call to createConnection() and
createSession() will reuse these objects from the pool (after a
> static:(failover:(tcp://hub1:61001,tcp://hub2:62001)?updateURIsSupported=false&maxReconnectAttempts=1,failover:(tcp://hub2:61001,tcp://hub1:62001)?updateURIsSupported=false&maxReconnectAttempts=1)
Hhm, if hub1 and hub2 are the same machines in both of the failover urls, then
you only need one o
11 matches
Mail list logo
