activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Oli <olafur.eiriks...@postea.com>
Subject ActiveMQ connection stopping after a number of messages
Date Fri, 08 Apr 2011 15:51:33 GMT

 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.

Mime
View raw message