You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Oli <ol...@postea.com> on 2011/04/08 17:51:33 UTC
ActiveMQ connection stopping after a number of messages
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.