masterov wrote:
>
> two producers publish to the same topic. Each publishes 10000 messages.
> Two consumers listen on that topic. Both consumers receive equal number
> of messages which in total is less than 20000 (i.e. 19135 <- this number
> is different every time) .
>
there is also the following exception at the broker:
2007-01-26 15:26:18,790 INFO [STDOUT] 15:26:16,589 ERROR [Service] Async
error occurred: java.lang.IllegalArg
umentException: The subscription does not exist:
ID:USHSPROGWK317-4071-1169841381167-5:3:-1:1
java.lang.IllegalArgumentException: The subscription does not exist:
ID:USHSPROGWK317-4071-1169841381167-5:3:-
1:1
at
org.apache.activemq.broker.region.AbstractRegion.acknowledge(AbstractRegion.java:298)
at
org.apache.activemq.broker.region.RegionBroker.acknowledge(RegionBroker.java:400)
at
org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionBroker.java:177)
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:74)
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:74)
at
org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBrokerFilter.java:88)
at
org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:491)
at org.apache.activemq.command.MessageAck.visit(MessageAck.java:179)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:287)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
at
org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:7
4)
at
org.apache.activemq.transport.stomp.StompSubscription.onMessageDispatch(StompSubscription.java:71)
at
org.apache.activemq.transport.stomp.ProtocolConverter.onActiveMQCommad(ProtocolConverter.java:479)
at
org.apache.activemq.transport.stomp.StompTransportFilter.oneway(StompTransportFilter.java:56)
at
org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:141)
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:43)
at
org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1054)
at
org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:775)
at
org.apache.activemq.broker.TransportConnection.iterate(TransportConnection.java:791)
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:111)
at
org.apache.activemq.thread.PooledTaskRunner.access$100(PooledTaskRunner.java:26)
at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:44)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
at java.lang.Thread.run(Thread.java:595)
--
View this message in context:
http://www.nabble.com/activemq-cpp-missing-messages-tf3124967.html#a8658260
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
