artnaseef wrote
> Hmm, check the producer connections to the broker after the VPN restart
> using netstat.
>
> When the consumers appear to hang, do you see evidence on the broker that
> the producer messages are actually being received in the broker? For
> example, the QueueSize for the queue --
We are currently testing a work around for this issue.
Since our broker has Persistent set to false and our producers are just
using default settings which is causing them to send their messages with
Persistent = true. We are changing the producer to set Persistent = false
which seems to fix the is
It looks like the issue with the consumer hanging has something to do with
duplicate messages after a producer comes back from a failover.
I see the Producer reconnect after the network is restored.
The broker receives a ActiveMQMapMessage.
The ProducerBrokerExchange setting the last stored sequen
So I was unable to produce a JUnit test that causes this issue to occur.
My first attempt was to use the SocketProxy in the test package of activemq.
I had the broker,the consumer, and the producer all running in the same JVM.
The consumer was using the VM transport and the producer was connecting
I will work on something to try to force the network connection failure
without using openvpn to be my networking failure trigger.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Consumer-hanging-after-a-producer-fails-for-being-inactive-tp4689775p4689828.html
Sent from t
I have been able to reproduce the issue with 5.10.
I am currently trying to walk through the activemq 5.9 code to figure out
whats going on.
I am seeing
DEBUG Queue - Incoming toPageIn: 200, Inflight: 0, pagedInMessages.size 0 in
my log files
In the org.apache.activemq.broker.region.Queue at line
We are testing ActiveMQ 5.9 with Oracle JDK 1.7.
We created a embedded broker with persistent set to false with a single
queue.
We gave it two transportConnectors
openwire with a
uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"
vm with a uri="vm://localhost"
W
