Hi
I'm having info and error log messages when my consumer get messages. Im
not sure it it happens cause my cluster of brokers are duplicating due to
"Store and forward".
my-broker-4
2014-03-13 10:44:09,832 | INFO | my-broker-4 Ignoring sub from
my-broker-2, browsers explicitly suppressed |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Transport: tcp:///10.142.176.106:61617@60352
2014-03-13 10:44:09,832 | INFO | my-broker-4 Ignoring sub from
my-broker-2, browsers explicitly suppressed |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Transport: tcp:///10.142.176.106:47996@61617
2014-03-13 10:44:09,833 | INFO | my-broker-4 Ignoring sub from
my-broker-2, browsers explicitly suppressed |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Transport: tcp:///10.142.176.106:61617@60352
2014-03-13 10:44:09,833 | INFO | my-broker-4 Ignoring sub from
my-broker-2, browsers explicitly suppressed |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Transport: tcp:///10.142.176.106:47996@61617
my-broker-2
2014-03-13 10:40:10,530 | WARN | Async error occurred: |
org.apache.activemq.broker.TransportConnection.Service | ActiveMQ
Transport: tcp:///10.142.176.107:60215@61617
javax.jms.JMSException: Unmatched acknowledge: MessageAck {commandId = 462,
responseRequired = false, ackType = 2, consumerId =
ID:528952-app4.consumer.com-59912-1394727278990-45:1:-1:2, firstMessageId =
ID:528950-app3.consumer.com-43927-1394642795191-601:1:520:520:1,
lastMessageId =
ID:528950-app3.consumer.com-43927-1394642795191-601:1:520:520:1,
destination = queue://jms.app.rsa.renovation, transactionId =
XID:[4871251,globalId=8c00ffffffbc63cffffffbc3532383935322d617070342e636f6e636570746f6d6f76696c2e636f6d2c766173732d6e6f64652d322c503233373030,branchId=3532383935322d617070342e636f6e636570746f6d6f76696c2e636f6d2c766173732d6e6f64652d322c5032333730302c0],
messageCount = 1, poisonCause = null}; Could not find Message-ID
ID:528950-app3.consumer.com-43927-1394642795191-601:1:520:520:1 in
dispatched-list (start of ack)
at
org.apache.activemq.broker.region.PrefetchSubscription.assertAckMatchesDispatched(PrefetchSubscription.java:480)
at
org.apache.activemq.broker.region.PrefetchSubscription.acknowledge(PrefetchSubscription.java:212)
at
org.apache.activemq.broker.region.AbstractRegion.acknowledge(AbstractRegion.java:412)
at
org.apache.activemq.broker.region.RegionBroker.acknowledge(RegionBroker.java:458)
at org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:82)
at org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:82)
at
org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionBroker.java:277)
at
org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBrokerFilter.java:92)
at
org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:476)
at org.apache.activemq.command.MessageAck.visit(MessageAck.java:236)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:149)
at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
at
org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:270)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
at java.lang.Thread.run(Thread.java:722)
Thanks
