activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From masterov <alexei.maste...@us.icap.com>
Subject Re: activemq-cpp missing messages
Date Fri, 26 Jan 2007 20:30:19 GMT



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.


Mime
View raw message