You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by dulanov <du...@gmail.com> on 2009/11/17 16:32:50 UTC

Messages are losted during camel context initialization

Hello, I have a race conditional problem (FUSE ESB 3.4.0.4), time to time
immediately after hot deploy apache camel losts several first messages in
activemq channels:

INFO - AutoDeploymentService - Directory: hotdeploy: Archive changed:
processing ...-SNAPSHOT.zip ...
WARN - DirectProducer - No getConsumers() available on
Producer[direct:process] for Exchange[JmsMessage: ActiveMQBytesMessage
{commandId = 5, responseRequired = true, messageId =
ID:dulanov-laptop-59995-1255514158159-2:22:1:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:dulanov-laptop-59995-1255514158159-2:22:1:1, destination =
topic://VirtualTopic.interplat.agreement.new, transactionId = null,
expiration = 0, timestamp = 1255514307628, arrival = 0, brokerInTime =
1255514307637, brokerOutTime = 1255514323144, 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@1080803,
marshalledProperties = org.apache.activemq.util.ByteSequence@463b08,
dataStructure = null, redeliveryCounter = 0, size = 4080, properties =
{org_apache_camel_splitSize=7, org_apache_camel_splitCounter=0},
readOnlyProperties = true, readOnlyBody = true, droppable = false}
ActiveMQBytesMessage{ bytesOut = null, dataOut = null, dataIn = null }]
WARN - DirectProducer - No getConsumers() available on
Producer[direct:process] for Exchange[JmsMessage: ActiveMQBytesMessage
{commandId = 5, responseRequired = true, messageId =
ID:dulanov-laptop-59995-1255514158159-2:23:1:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:dulanov-laptop-59995-1255514158159-2:23:1:1, destination =
topic://VirtualTopic.interplat.agreement.loss.new, transactionId = null,
expiration = 0, timestamp = 1255514307629, arrival = 0, brokerInTime =
1255514307629, brokerOutTime = 1255514323195, 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@119052d,
marshalledProperties = org.apache.activemq.util.ByteSequence@1a2fd1b,
dataStructure = null, redeliveryCounter = 0, size = 2309, properties =
{org_apache_camel_splitSize=7, org_apache_camel_splitCounter=0},
readOnlyProperties = true, readOnlyBody = true, droppable = false}
ActiveMQBytesMessage{ bytesOut = null, dataOut = null, dataIn = null }]
WARN - DirectProducer - No getConsumers() available on
Producer[direct:process] for Exchange[JmsMessage: ActiveMQBytesMessage
{commandId = 5, responseRequired = true, messageId =
ID:dulanov-laptop-59995-1255514158159-2:21:1:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:dulanov-laptop-59995-1255514158159-2:21:1:1, destination =
topic://VirtualTopic.interplat.agreement.object.new, transactionId = null,
expiration = 0, timestamp = 1255514307628, arrival = 0, brokerInTime =
1255514307628, brokerOutTime = 1255514323169, 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@dc7d5f,
marshalledProperties = org.apache.activemq.util.ByteSequence@1ab0d58,
dataStructure = null, redeliveryCounter = 0, size = 2015, properties =
{org_apache_camel_splitSize=7, org_apache_camel_splitCounter=0},
readOnlyProperties = true, readOnlyBody = true, droppable = false}
ActiveMQBytesMessage{ bytesOut = null, dataOut = null, dataIn = null }]
WARN - DirectProducer - No getConsumers() available on
Producer[direct:process] for Exchange[JmsMessage: ActiveMQBytesMessage
{commandId = 5, responseRequired = true, messageId =
ID:dulanov-laptop-59995-1255514158159-2:20:1:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:dulanov-laptop-59995-1255514158159-2:20:1:1, destination =
topic://VirtualTopic.interplat.agreement.payment.new, transactionId = null,
expiration = 0, timestamp = 1255514307627, arrival = 0, brokerInTime =
1255514307627, brokerOutTime = 1255514323219, 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@19702b5,
marshalledProperties = org.apache.activemq.util.ByteSequence@132fa84,
dataStructure = null, redeliveryCounter = 0, size = 1367, properties =
{org_apache_camel_splitSize=7, org_apache_camel_splitCounter=0},
readOnlyProperties = true, readOnlyBody = true, droppable = false}
ActiveMQBytesMessage{ bytesOut = null, dataOut = null, dataIn = null }]
WARN - DirectProducer - No getConsumers() available on
Producer[direct:process] for Exchange[JmsMessage: ActiveMQBytesMessage
{commandId = 5, responseRequired = true, messageId =
ID:dulanov-laptop-59995-1255514158159-2:19:1:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:dulanov-laptop-59995-1255514158159-2:19:1:1, destination =
topic://VirtualTopic.interplat.agreement.account.new, transactionId = null,
expiration = 0, timestamp = 1255514307626, arrival = 0, brokerInTime =
1255514307627, brokerOutTime = 1255514323251, 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@9e3fa6,
marshalledProperties = org.apache.activemq.util.ByteSequence@164d296,
dataStructure = null, redeliveryCounter = 0, size = 2009, properties =
{org_apache_camel_splitSize=7, org_apache_camel_splitCounter=0},
readOnlyProperties = true, readOnlyBody = true, droppable = false}
ActiveMQBytesMessage{ bytesOut = null, dataOut = null, dataIn = null }]
INFO - ServiceAssemblyLifeCycle - Starting service assembly: ...-sa
INFO - ServiceUnitLifeCycle - Initializing service unit: ...-su
INFO - ServiceUnitLifeCycle - Starting service unit: ...-su
INFO - AutoDeploymentService - Directory: hotdeploy: Finished installation
of archive: ...-sa-1.1-SNAPSHOT.zip

http://old.nabble.com/file/p26391885/camel-context.xml camel-context.xml 
http://old.nabble.com/file/p26391885/ComposeDataRouteBuilder.java
ComposeDataRouteBuilder.java 
-- 
View this message in context: http://old.nabble.com/Messages-are-losted-during-camel-context-initialization-tp26391885p26391885.html
Sent from the Camel - Users mailing list archive at Nabble.com.