You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Venkatg <ve...@yahoo.com> on 2006/09/05 15:33:28 UTC
Message are geting dropped in some scenarios
Hi,
I have two broker MAIN and SUB Brokesr and running on different machines.
SUB broker is added as a network connector to MAIN broker. Publisher is
connected to MAIN broker. Consumers opened for MAIN broker working fine and
getting all the message with different selectors(changed dynamically). But
Consumers connected to SUB broker are not getting all the messages under
certain conditions, selector for the cunsumer are changes dyanmically based
on the applications opened on the client(where consumer is running). When
ever selector is changed sometimes I get the messages and all other time I
don't get it. I couldn't figure out the specific Under which I am getting
the message. Random in nature. I found the following line in the MAIN broker
log file. For the case "Ignoring sub ConsumerInfo"(see the below log) I am
not getting the message
2006-09-05 16:38:24,452 | DEBUG | ActiveMQ Transport:
tcp:///10.10.10.36:36005 | DemandForwardingBridge:383 | Forwarding sub on
vm://CFEBroker#0 from 10.10.10.366573064568522906996 : ConsumerInfo
{commandId = 4, responseRequired = true, consumerId =
ID:L3-BFNE3-1753-1157454501452-0:0:1:1, destination = topic://AVC,
prefetchSize = 32766, maximumPendingMessageLimit = 0, browser = false,
dispatchAsync = false, selector = (MD4=TRUE OR MD3=TRUE) AND (MoTypeNum =
501 ), subcriptionName = null, noLocal = false, exclusive = false,
retroactive = false, priority = 0, brokerPath =
[ID:SWNM-BLADE-36-34851-1157453869692-0:0], optimizedAcknowledge = false,
noRangeAcks = false, additionalPredicate = null}
2006-09-05 16:39:00,656 | DEBUG | ActiveMQ Transport:
tcp:///10.10.10.36:36005 | DemandForwardingBridge:386 | Ignoring sub
ConsumerInfo {commandId = 5, responseRequired = true, consumerId =
ID:L3-BFNE3-1753-1157454501452-0:0:1:2, destination = topic://AVC,
prefetchSize = 32766, maximumPendingMessageLimit = 0, browser = false,
dispatchAsync = false, selector = (MD4=TRUE OR MD3=TRUE) AND (MoTypeNum =
501 OR ( ( NodeNumber=105) AND MoTypeNum BETWEEN 1001 AND 2000 ) OR ( (
NodeNumber=105) AND (MoTypeNum = 2002 OR MoTypeNum = 2010 ) )),
subcriptionName = null, noLocal = false, exclusive = false, retroactive =
false, priority = 0, brokerPath =
[ID:SWNM-BLADE-36-34851-1157453869692-0:0], optimizedAcknowledge = false,
noRangeAcks = false, additionalPredicate = null} already subscribed to
matching destination
2006-09-05 16:41:24,706 | DEBUG | ActiveMQ Transport:
tcp:///10.10.10.36:36005 | DemandForwardingBridge:383 | Forwarding sub on
vm://CFEBroker#0 from 10.10.10.366573064568522906996 : ConsumerInfo
{commandId = 4, responseRequired = true, consumerId =
ID:L3-BFNE3-1825-1157454683315-0:0:1:1, destination = topic://AVC,
prefetchSize = 32766, maximumPendingMessageLimit = 0, browser = false,
dispatchAsync = false, selector = (MD4=TRUE OR MD3=TRUE) AND (MoTypeNum =
501 ), subcriptionName = null, noLocal = false, exclusive = false,
retroactive = false, priority = 0, brokerPath =
[ID:SWNM-BLADE-36-34851-1157453869692-0:0], optimizedAcknowledge = false,
noRangeAcks = false, additionalPredicate = null}
2006-09-05 16:42:23,551 | DEBUG | ActiveMQ Transport:
tcp:///10.10.10.36:36005 | DemandForwardingBridge:386 | Ignoring sub
ConsumerInfo {commandId = 5, responseRequired = true, consumerId =
ID:L3-BFNE3-1825-1157454683315-0:0:1:2, destination = topic://AVC,
prefetchSize = 32766, maximumPendingMessageLimit = 0, browser = false,
dispatchAsync = false, selector = (MD4=TRUE OR MD3=TRUE) AND (MoTypeNum =
501 OR ( ( NodeNumber=105) AND MoTypeNum BETWEEN 1001 AND 2000 ) OR ( (
NodeNumber=105) AND (MoTypeNum = 2002 OR MoTypeNum = 2010 ) )),
subcriptionName = null, noLocal = false, exclusive = false, retroactive =
false, priority = 0, brokerPath =
[ID:SWNM-BLADE-36-34851-1157453869692-0:0], optimizedAcknowledge = false,
noRangeAcks = false, additionalPredicate = null} already subscribed to
matching destination
2006-09-05 16:43:00,645 | DEBUG | ActiveMQ Transport:
tcp:///10.10.10.36:36005 | DemandForwardingBridge:383 | Forwarding sub on
vm://CFEBroker#0 from 10.10.10.366573064568522906996 : ConsumerInfo
{commandId = 7, responseRequired = true, consumerId =
ID:L3-BFNE3-1825-1157454683315-0:0:1:3, destination = topic://AVC,
prefetchSize = 32766, maximumPendingMessageLimit = 0, browser = false,
dispatchAsync = false, selector = (MD4=TRUE OR MD3=TRUE) AND (MoTypeNum =
501 OR ((NodeNumber=105) AND MoTypeNum BETWEEN 1001 AND 1500) OR ( (
NodeNumber=105) AND MoTypeNum BETWEEN 1501 AND 2000 ) OR ( ( NodeNumber=105)
AND (MoTypeNum = 2002 OR MoTypeNum = 2010 ) )), subcriptionName = null,
noLocal = false, exclusive = false, retroactive = false, priority = 0,
brokerPath = [ID:SWNM-BLADE-36-34851-1157453869692-0:0],
optimizedAcknowledge = false, noRangeAcks = false, additionalPredicate =
null}
2006-09-05 16:45:48,930 | DEBUG | ActiveMQ Transport:
tcp:///10.10.10.36:36005 | DemandForwardingBridge:386 | Ignoring sub
ConsumerInfo {commandId = 12, responseRequired = true, consumerId =
ID:L3-BFNE3-1825-1157454683315-0:0:1:4, destination = topic://AVC,
prefetchSize = 32766, maximumPendingMessageLimit = 0, browser = false,
dispatchAsync = false, selector = (MD4=TRUE OR MD3=TRUE) AND (MoTypeNum =
501 OR ((NodeNumber=105) AND MoTypeNum BETWEEN 1001 AND 1500) OR
((NodeNumber=105) AND MoTypeNum BETWEEN 2001 AND 3000) OR ( (
NodeNumber=105) AND MoTypeNum BETWEEN 1501 AND 2000 )), subcriptionName =
null, noLocal = false, exclusive = false, retroactive = false, priority = 0,
brokerPath = [ID:SWNM-BLADE-36-34851-1157453869692-0:0],
optimizedAcknowledge = false, noRangeAcks = false, additionalPredicate =
null} already subscribed to matching destination
Thanks
Venkat
--
View this message in context: http://www.nabble.com/Message-are-geting-dropped-in-some-scenarios-tf2220816.html#a6152012
Sent from the ActiveMQ - User forum at Nabble.com.