Hello everybody!
I am encountering a very strange problem using Active MQ 4.0.2 RC5 (actually
this problem occurs in all version i have tried so far, 4.0 - 4.0.2 RC5).
The topology of the network of brokers is attached, please see for details.
http://www.nabble.com/file/3957/setup.png setup.png
As you can see, the network of brokers consists of four fully meshed Active
MQ 4.0.2 RC5 Servers, with 10 Subscribers connected to each of them and
between 1 and 160 publishers connected to each of them. In a standard
message replication scenarios, i.e. with no subscription installed - so
everbody should receive every published message - a strange problem occurs.
After a certain time, around 120 seconds, the network of brokers suddenly
stops working, no messages are published, no messages are received,
Throughput = 0.
The following exception occurs:
03.11.2006 00:44:17 org.apache.activemq.ActiveMQMessageConsumer dispatch
WARNUNG: could not process message: MessageDispatch {commandId = 6495820,
responseRequired = false, consumerId =
ID:<sub1>-52739-1162510267615-1:3:1:1, destination = topic://MyTopic,
message = ActiveMQBytesMessage {commandId = 38565, responseRequired = false,
messageId = ID:<pub1>-33140-1162510178642-1:80:1:1:38561,
originalDestination = null, originalTransactionId = null, producerId =
ID:<pub1>-33140-1162510178642-1:80:1:1, destination = topic://MyTopic,
transactionId = null, expiration = 0, timestamp = 1162511150603, arrival =
0, correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content =
[EMAIL PROTECTED], marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
null, readOnlyProperties = true, readOnlyBody = true} ActiveMQBytesMessage{
bytesOut = null, dataOut = null, dataIn = null }, redeliveryCounter = 0}
java.lang.NullPointerException
at java.util.LinkedList.addBefore(Unknown Source)
at java.util.LinkedList.addFirst(Unknown Source)
at
org.apache.activemq.ActiveMQMessageConsumer.beforeMessageIsConsumed(ActiveMQMessageConsumer.java:608)
at
org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:793)
at
org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:96)
at
org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:149)
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:110)
at
org.apache.activemq.thread.PooledTaskRunner.access$100(PooledTaskRunner.java:25)
at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
at java.lang.Thread.run(Unknown Source)
and the Active MQ Server claim:
INFO DemandForwardingBridge - Network connection between
vm://<srv1>#0 and tcp://<srv2>:61616 shutdown due to a local error:
java.lang.IllegalArgumentException: The subscription does not exist:
ID:<src1>-38825-1162495707674-3:1:1:2
The same problem sporadically occurs with 5 subscribers connected to each
server. Also other topologies (2,3 servers fully meshed) result in the same
problem.
Does anyone have an idea what to do, or where the problem lies?
Thank you very much in advance.
Have a nice day,
Stephan Seufert
--
View this message in context:
http://www.nabble.com/Active-MQ-4.0.2-RC5%2C-Network-of-Brokers-Problem%3A-Subsciption-does-not-exist-tf2566399.html#a7152953
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
