activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From patrickjamesbarry <patrickjamesba...@gmail.com>
Subject timeStampingBrokerPlugin problems
Date Tue, 18 Mar 2008 16:20:21 GMT

I am seeing the following differences between v5.0 and v5.1.  Many of our
producers have different times on there sys clocks and we really need this
feature working.  Here is the debug output from broker.  Time to live is set
to 3000 ms on producer. Is it expected behaviour to set the expiration to
infinite (0), if brokerInTime + timeToLive has not yet expired? 

Client clock set slower than brokers, on v5.0 broker
INFO  Send                           - Sending: ActiveMQObjectMessage
{commandId = 11, responseRequired = true, messageId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52018-1205852722873-0:0:1:1:6,
originalDestination = null, originalTransactionId = null, producerId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52018-1205852722873-0:0:1:1,
destination = queue://ReferenceAddressCaptureService, transactionId = null,
expiration = 1205852844450, timestamp = 1205853423062, arrival = 0,
brokerInTime = 0, brokerOutTime = 0, correlationId = null, replyTo =
queue://26fd0f8a-1c09-4d37-ae68-78b62841d5c2, persistent = true, type =
null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@be49e0, marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 0, properties = null,
readOnlyProperties = false, readOnlyBody = false, droppable = false}
DEBUG RegionBroker                   - Message expired ActiveMQObjectMessage
{commandId = 11, responseRequired = true, messageId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52018-1205852722873-0:0:1:1:6,
originalDestination = null, originalTransactionId = null, producerId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52018-1205852722873-0:0:1:1,
destination = queue://ReferenceAddressCaptureService, transactionId = null,
expiration = 1205852844450, timestamp = 1205853423062, arrival = 0,
brokerInTime = 1205853423065, brokerOutTime = 0, correlationId = null,
replyTo = queue://26fd0f8a-1c09-4d37-ae68-78b62841d5c2, persistent = true,
type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@be49e0, marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 0, properties = null,
readOnlyProperties = false, readOnlyBody = false, droppable = false}
WARN  RegionBroker                   - Failed to send ActiveMQObjectMessage
{commandId = 11, responseRequired = true, messageId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52018-1205852722873-0:0:1:1:6,
originalDestination = null, originalTransactionId = null, producerId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52018-1205852722873-0:0:1:1,
destination = queue://ReferenceAddressCaptureService, transactionId = null,
expiration = 1205852844450, timestamp = 1205853423062, arrival = 0,
brokerInTime = 1205853423065, brokerOutTime = 0, correlationId = null,
replyTo = queue://26fd0f8a-1c09-4d37-ae68-78b62841d5c2, persistent = true,
type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@be49e0, marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 0, properties = null,
readOnlyProperties = false, readOnlyBody = false, droppable = false} to dead
letter queue

Client clock set faster than broker v5.0 <no RegionBroker output>
INFO  Send                           - Sending: ActiveMQObjectMessage
{commandId = 8, responseRequired = true, messageId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52027-1205853958752-0:0:1:1:2,
originalDestination = null, originalTransactionId = null, producerId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52027-1205853958752-0:0:1:1,
destination = queue://ReferenceAddressCaptureService, transactionId = null,
expiration = 1205853998700, timestamp = 1205853677304, arrival = 0,
brokerInTime = 0, brokerOutTime = 0, correlationId = null, replyTo =
queue://01f55599-b668-4ec1-b6b8-ae3e2c5f85a7, persistent = true, type =
null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@4a7df6, marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 0, properties = null,
readOnlyProperties = false, readOnlyBody = false, droppable = false}
INFO  Send                           - Sending: ActiveMQObjectMessage
{commandId = 63, responseRequired = true, messageId =
ID:patrick-32949-1205848745456-0:0:1:18:1, originalDestination = null,
originalTransactionId = null, producerId =
ID:patrick-32949-1205848745456-0:0:1:18, destination =
queue://01f55599-b668-4ec1-b6b8-ae3e2c5f85a7, transactionId = null,
expiration = 0, timestamp = 1205853677311, 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 =
org.apache.activemq.util.ByteSequence@20f443, marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 0, properties = null,
readOnlyProperties = false, readOnlyBody = false, droppable = false}


Client clock set slower than brokers, on v5.1 broker
INFO  Send                           - Sending: ActiveMQObjectMessage
{commandId = 6, responseRequired = true, messageId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52055-1205854214595-0:0:1:1:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52055-1205854214595-0:0:1:1,
destination = queue://ReferenceAddressCaptureService, transactionId = null,
expiration = 1205854245671, timestamp = 1205854462552, arrival = 0,
brokerInTime = 0, brokerOutTime = 0, correlationId = null, replyTo =
queue://6c717ddc-bf80-4791-b0ce-ee847eed99e0, persistent = true, type =
null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@14d7745, marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 0, properties = null,
readOnlyProperties = false, readOnlyBody = false, droppable = false}
DEBUG RegionBroker                   - Message expired ActiveMQObjectMessage
{commandId = 6, responseRequired = true, messageId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52055-1205854214595-0:0:1:1:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52055-1205854214595-0:0:1:1,
destination = queue://ReferenceAddressCaptureService, transactionId = null,
expiration = 1205854245671, timestamp = 1205854462552, arrival = 0,
brokerInTime = 1205854462555, brokerOutTime = 0, correlationId = null,
replyTo = queue://6c717ddc-bf80-4791-b0ce-ee847eed99e0, persistent = true,
type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@14d7745, marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 0, properties = null,
readOnlyProperties = false, readOnlyBody = false, droppable = false}
INFO  Send                           - Sending: ActiveMQObjectMessage
{commandId = 6, responseRequired = true, messageId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52055-1205854214595-0:0:1:1:1,
originalDestination = queue://ReferenceAddressCaptureService,
originalTransactionId = null, producerId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52055-1205854214595-0:0:1:1,
destination = queue://ActiveMQ.DLQ, transactionId = null, expiration = 0,
timestamp = 1205854462557, arrival = 0, brokerInTime = 1205854462555,
brokerOutTime = 0, correlationId = null, replyTo =
queue://6c717ddc-bf80-4791-b0ce-ee847eed99e0, persistent = true, type =
null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@14d7745, marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{originalExpiration=1205854245671}, readOnlyProperties = false, readOnlyBody
= false, droppable = false}

Client clock set faster than broker v5.1 
INFO  Send                           - Sending: ActiveMQObjectMessage
{commandId = 8, responseRequired = true, messageId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52040-1205854386984-0:0:1:1:2,
originalDestination = null, originalTransactionId = null, producerId =
ID:dhcp-10-0-18-112.cml.in.interactions.net-52040-1205854386984-0:0:1:1,
destination = queue://ReferenceAddressCaptureService, transactionId = null,
expiration = 1205854468030, timestamp = 1205854146617, arrival = 0,
brokerInTime = 0, brokerOutTime = 0, correlationId = null, replyTo =
queue://b11d830e-fae5-490a-8779-b191f2ab805d, persistent = true, type =
null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@14acfcd, marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 0, properties = null,
readOnlyProperties = false, readOnlyBody = false, droppable = false}
INFO  Send                           - Sending: ActiveMQObjectMessage
{commandId = 15, responseRequired = true, messageId =
ID:patrick-33034-1205854053073-0:0:1:2:1, originalDestination = null,
originalTransactionId = null, producerId =
ID:patrick-33034-1205854053073-0:0:1:2, destination =
queue://b11d830e-fae5-490a-8779-b191f2ab805d, transactionId = null,
expiration = 0, timestamp = 1205854146624, 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 =
org.apache.activemq.util.ByteSequence@ab54eb, marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 0, properties = null,
readOnlyProperties = false, readOnlyBody = false, droppable = false}



-- 
View this message in context: http://www.nabble.com/timeStampingBrokerPlugin-problems-tp16124822s2354p16124822.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.


Mime
View raw message