Hi all. I am working with camel 2.5.0 and activemq 5.4.2.
I my setup, 2 machines are connecting through a peer jms peer connection. I then setup camel routes on each machine to pull messages off a topic and process the message to a local text file. I've set up a test so that both machines send 2000 messages, one message a second per machine. Everything goes well, but after a while (eg 10 mins), Machine B seems to cut the connection with Machine A, and stops receiving the messages from A, but continues to receive its own messages. Machine A, however, continues to receive the messages from both A and B. I've tested this a few times now, and this problem seems to occur almost every time, not always after the same number of messages though. I have no idea why this is happening, and would be very happy if somebody could point out a potential reason for this. Below is an extract from my (debug) log from the time the connection is stopped. No exception takes place, so no mention of this goes into my error log. Milliseconds since program start: 907860 Classname of caller: org.apache.activemq.broker.TransportConnection Date in ISO8601 format: 2011-04-08 15:30:39,993 Location of log event: org.apache.activemq.broker.TransportConnection.doStop(TransportConnection.java:964) Message: Stopping connection: /MACHINE_A_IP:49217 Milliseconds since program start: 907860 Classname of caller: org.apache.camel.processor.SendProcessor$2 Date in ISO8601 format: 2011-04-08 15:30:39,993 Location of log event: org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:102) Message: >>>> Endpoint[jms://queue:MACHINE_B_NAMEPreProcessqueue] Exchange[JmsMessage: ActiveMQTextMessage {commandId = 4120, responseRequired = true, messageId = ID:MACHINE_B_NAME-58783-1302272132976-3:4:1:1:822, originalDestination = null, originalTransactionId = null, producerId = ID:MACHINE_B_NAME-58783-1302272132976-3:4:1:1, destination = topic://OUR_TOPIC, transactionId = null, expiration = 0, timestamp = 1302273039962, arrival = 0, brokerInTime = 1302273039962, brokerOutTime = 1302273039993, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@76817b, marshalledProperties = org.apache.activemq.util.ByteSequence@2ed039, dataStructure = null, redeliveryCounter = 0, size = 2304, properties = {CamelFileNameOnly=order822.xml, CamelFileLastModified=Fri Apr 08 15:30:23 BST 2011, CamelFileRelativePath=LOCAL_DIRECTORYFiles\order822.xml, CamelFileAbsolutePath=LOCAL_DIRECTORYFiles\order822.xml, ORIGINATOR_ID=ID:MACHINE_A_NAME-49211-1302272128045-3:9:1:1:309, CamelFileName=order822.xml, CamelFileLength=765, CamelFilePath=LOCAL_DIRECTORYFiles\order822.xml, CamelFileParent=LOCAL_DIRECTORYFiles, ORIGINATOR=MACHINE_A_NAME, CamelJmsDeliveryMode=2, CamelFileAbsolute=true}, readOnlyProperties = true, readOnlyBody = true, droppable = false, text = <?xml version="1.0" encoding="utf-8"?> }] Milliseconds since program start: 907860 Classname of caller: org.apache.activemq.transport.tcp.TcpTransport Date in ISO8601 format: 2011-04-08 15:30:39,993 Location of log event: org.apache.activemq.transport.tcp.TcpTransport.doStop(TcpTransport.java:508) Message: Stopping transport tcp:///MACHINE_A_IP:49217 Milliseconds since program start: 907876 Classname of caller: org.springframework.jms.core.JmsTemplate Date in ISO8601 format: 2011-04-08 15:30:40,009 Location of log event: org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:464) Message: Executing callback on JMS Session: PooledSession { ActiveMQSession {id=ID:MACHINE_B_NAME-58783-1302272132976-3:3:1,started=true} } Milliseconds since program start: 907876 Classname of caller: org.apache.activemq.broker.TransportConnection Date in ISO8601 format: 2011-04-08 15:30:40,009 Location of log event: org.apache.activemq.broker.TransportConnection.doStop(TransportConnection.java:980) Message: Stopped transport: /MACHINE_A_IP:49217 Milliseconds since program start: 907876 Classname of caller: org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate Date in ISO8601 format: 2011-04-08 15:30:40,009 Location of log event: org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.doSend(JmsConfiguration.java:280) Message: Sending JMS message to: queue://MACHINE_B_NAMEPreProcessqueue with message: ActiveMQTextMessage {commandId = 0, responseRequired = false, messageId = null, originalDestination = null, originalTransactionId = null, producerId = null, destination = null, transactionId = null, expiration = 0, timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = {CamelFileNameOnly=order822.xml, CamelFileRelativePath=LOCAL_DIRECTORYFiles\order822.xml, CamelFileLastModified=Fri Apr 08 15:30:23 BST 2011, ORIGINATOR_ID=ID:MACHINE_A_NAME-49211-1302272128045-3:9:1:1:309, CamelFileAbsolutePath=LOCAL_DIRECTORYFiles\order822.xml, CamelFileLength=765, CamelFileName=order822.xml, CamelFilePath=LOCAL_DIRECTORYFiles\order822.xml, CamelFileParent=LOCAL_DIRECTORYFiles, ORIGINATOR=MACHINE_A_NAME, CamelJmsDeliveryMode=2, CamelFileAbsolute=true}, readOnlyProperties = false, readOnlyBody = false, droppable = false, text = <?xml version="1.0" encoding="utf-8"?> } Milliseconds since program start: 907876 Classname of caller: org.apache.activemq.broker.TransportConnection Date in ISO8601 format: 2011-04-08 15:30:40,009 Location of log event: org.apache.activemq.broker.TransportConnection.doStop(TransportConnection.java:1013) Message: Cleaning up connection resources: /MACHINE_A_IP:49217 Milliseconds since program start: 907876 Classname of caller: org.apache.activemq.broker.region.Queue Date in ISO8601 format: 2011-04-08 15:30:40,009 Location of log event: org.apache.activemq.broker.region.Queue.doPageIn(Queue.java:1653) Message: MACHINE_B_NAMEPreProcessqueue toPageIn: 1, Inflight: 0, pagedInMessages.size 0, enqueueCount: 3294, dequeueCount: 3293 Milliseconds since program start: 907876 Classname of caller: org.apache.activemq.broker.TransportConnection Date in ISO8601 format: 2011-04-08 15:30:40,009 Location of log event: org.apache.activemq.broker.TransportConnection.processRemoveConnection(TransportConnection.java:713) Message: remove connection id: ID:MACHINE_A_NAME-49211-1302272128045-5:1 Milliseconds since program start: 907891 Classname of caller: org.apache.activemq.broker.region.cursors.AbstractStoreCursor Date in ISO8601 format: 2011-04-08 15:30:40,024 Location of log event: org.apache.activemq.broker.region.cursors.AbstractStoreCursor.remove(AbstractStoreCursor.java:213) Message: MACHINE_B_NAMEPreProcessqueue enabling cache on last remove Milliseconds since program start: 907891 Classname of caller: org.apache.activemq.broker.region.AbstractRegion Date in ISO8601 format: 2011-04-08 15:30:40,024 Location of log event: org.apache.activemq.broker.region.AbstractRegion.removeConsumer(AbstractRegion.java:322) Message: MACHINE_B_NAMEMachine removing consumer: ID:MACHINE_A_NAME-49211-1302272128045-5:1:1:1 for destination: ActiveMQ.Advisory.Consumer.>,topic://ActiveMQ.Advisory.TempQueue,topic://ActiveMQ.Advisory.TempTopic Milliseconds since program start: 907891 Classname of caller: org.apache.camel.component.jms.EndpointMessageListener Date in ISO8601 format: 2011-04-08 15:30:40,024 Location of log event: org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:70) Message: Endpoint[jms://queue:MACHINE_B_NAMEPreProcessqueue] consumer receiving JMS message: ActiveMQTextMessage {commandId = 6593, responseRequired = true, messageId = ID:MACHINE_B_NAME-58783-1302272132976-3:3:1:1:3294, originalDestination = null, originalTransactionId = null, producerId = ID:MACHINE_B_NAME-58783-1302272132976-3:3:1:1, destination = queue://MACHINE_B_NAMEPreProcessqueue, transactionId = null, expiration = 0, timestamp = 1302273040009, arrival = 0, brokerInTime = 1302273040009, brokerOutTime = 1302273040024, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@337df9, marshalledProperties = org.apache.activemq.util.ByteSequence@938135, dataStructure = null, redeliveryCounter = 0, size = 2554, properties = {CamelFileNameOnly=order822.xml, CamelFileLastModified=Fri Apr 08 15:30:23 BST 2011, CamelFileRelativePath=LOCAL_DIRECTORYFiles\order822.xml, CamelFileAbsolutePath=LOCAL_DIRECTORYFiles\order822.xml, ORIGINATOR_ID=ID:MACHINE_A_NAME-49211-1302272128045-3:9:1:1:309, CamelFileName=order822.xml, CamelFileLength=765, CamelFilePath=LOCAL_DIRECTORYFiles\order822.xml, CamelFileParent=LOCAL_DIRECTORYFiles, ORIGINATOR=MACHINE_A_NAME, CamelJmsDeliveryMode=2, CamelFileAbsolute=true}, readOnlyProperties = true, readOnlyBody = true, droppable = false, text = <?xml version="1.0" encoding="utf-8"?> } Milliseconds since program start: 907891 Classname of caller: org.apache.activemq.broker.TransportConnection Date in ISO8601 format: 2011-04-08 15:30:40,024 Location of log event: org.apache.activemq.broker.TransportConnection.doStop(TransportConnection.java:1023) Message: Connection Stopped: /MACHINE_A_IP:49217 Regards, Oli -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-connection-stopping-after-a-number-of-messages-tp3436725p3436725.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.