Hi,
I'm prototyping an ActiveMQ network of brokers using 4.0.2 RC 6. The setup
consists of 2 producers and 2 consumers. At startup things look fine. After
restarting one of the consumers one or more times it stops receiving
messages. All the work is done by the remaining cosumer.
The connection dialog of the restarted broker looks o.k., but it doesn't
receive messages anymore.
(I don't use JmsTemplate) :
<code>
2006-10-31 17:12:53,156 DEBUG [ActiveMQ Task]
org.apache.activemq.transport.failover.FailoverTransport: Attempting connect
to: tcp://localhost:20002
2006-10-31 17:12:53,171 DEBUG [ActiveMQ Task]
org.apache.activemq.transport.WireFormatNegotiator: Sending: WireFormatInfo
{ version=1, properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2006-10-31 17:12:53,171 DEBUG [ActiveMQ Task]
org.apache.activemq.transport.failover.FailoverTransport: Connection
established
2006-10-31 17:12:53,171 DEBUG [ActiveMQ Transport Server:
tcp://dtams0365:20002] org.apache.activemq.transport.WireFormatNegotiator:
Sending: WireFormatInfo { version=1, properties={TightEncodingEnabled=true,
TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2006-10-31 17:12:53,171 DEBUG [ActiveMQ Transport:
tcp://localhost/127.0.0.1:20002]
org.apache.activemq.transport.WireFormatNegotiator: Received WireFormat:
WireFormatInfo { version=1, properties={StackTraceEnabled=true,
TightEncodingEnabled=true, TcpNoDelayEnabled=true, SizePrefixDisabled=false,
MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2006-10-31 17:12:53,171 DEBUG [ActiveMQ Transport: tcp:///127.0.0.1:1411]
org.apache.activemq.transport.WireFormatNegotiator: Received WireFormat:
WireFormatInfo { version=1, properties={StackTraceEnabled=true,
TightEncodingEnabled=true, TcpNoDelayEnabled=true, SizePrefixDisabled=false,
MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2006-10-31 17:12:53,171 DEBUG [ActiveMQ Transport:
tcp://localhost/127.0.0.1:20002]
org.apache.activemq.transport.WireFormatNegotiator:
tcp://localhost/127.0.0.1:20002 before negotiation:
OpenWireFormat{version=1, cacheEnabled=false, stackTraceEnabled=false,
tightEncodingEnabled=false, sizePrefixDisabled=false}
2006-10-31 17:12:53,171 DEBUG [ActiveMQ Transport: tcp:///127.0.0.1:1411]
org.apache.activemq.transport.WireFormatNegotiator: tcp:///127.0.0.1:1411
before negotiation: OpenWireFormat{version=1, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false}
2006-10-31 17:12:53,171 DEBUG [ActiveMQ Transport:
tcp://localhost/127.0.0.1:20002]
org.apache.activemq.transport.WireFormatNegotiator:
tcp://localhost/127.0.0.1:20002 after negotiation: OpenWireFormat{version=1,
cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true,
sizePrefixDisabled=false}
2006-10-31 17:12:53,171 DEBUG [ActiveMQ Transport: tcp:///127.0.0.1:1411]
org.apache.activemq.transport.WireFormatNegotiator: tcp:///127.0.0.1:1411
after negotiation: OpenWireFormat{version=1, cacheEnabled=true,
stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
2006-10-31 17:12:53,218 DEBUG [ActiveMQ Transport Server:
tcp://dtams0365:20002] org.apache.activemq.transport.WireFormatNegotiator:
Sending: WireFormatInfo { version=1, properties={TightEncodingEnabled=true,
TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2006-10-31 17:12:53,218 DEBUG [ActiveMQ Transport: tcp:///127.0.0.1:1406]
org.apache.activemq.transport.WireFormatNegotiator: Received WireFormat:
WireFormatInfo { version=1, properties={StackTraceEnabled=true,
TightEncodingEnabled=true, TcpNoDelayEnabled=true, SizePrefixDisabled=false,
MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2006-10-31 17:12:53,218 DEBUG [ActiveMQ Transport: tcp:///127.0.0.1:1406]
org.apache.activemq.transport.WireFormatNegotiator: tcp:///127.0.0.1:1406
before negotiation: OpenWireFormat{version=1, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false}
2006-10-31 17:12:53,218 DEBUG [ActiveMQ Transport: tcp:///127.0.0.1:1406]
org.apache.activemq.transport.WireFormatNegotiator: tcp:///127.0.0.1:1406
after negotiation: OpenWireFormat{version=1, cacheEnabled=true,
stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
2006-10-31 17:12:53,234 DEBUG [ActiveMQ Transport Server:
tcp://dtams0365:20002] org.apache.activemq.transport.WireFormatNegotiator:
Sending: WireFormatInfo { version=1, properties={TightEncodingEnabled=true,
TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2006-10-31 17:12:53,234 DEBUG [ActiveMQ Transport: tcp:///127.0.0.1:1407]
org.apache.activemq.transport.WireFormatNegotiator: Received WireFormat:
WireFormatInfo { version=1, properties={StackTraceEnabled=true,
TightEncodingEnabled=true, TcpNoDelayEnabled=true, SizePrefixDisabled=false,
MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2006-10-31 17:12:53,234 DEBUG [ActiveMQ Transport: tcp:///127.0.0.1:1407]
org.apache.activemq.transport.WireFormatNegotiator: tcp:///127.0.0.1:1407
before negotiation: OpenWireFormat{version=1, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false}
2006-10-31 17:12:53,234 DEBUG [ActiveMQ Transport: tcp:///127.0.0.1:1407]
org.apache.activemq.transport.WireFormatNegotiator: tcp:///127.0.0.1:1407
after negotiation: OpenWireFormat{version=1, cacheEnabled=true,
stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
2006-10-31 17:12:53,234 DEBUG [Thread-3]
org.apache.activemq.broker.region.AbstractRegion: Adding destination:
topic://ActiveMQ.Advisory.Topic
2006-10-31 17:12:53,234 INFO [Thread-4]
org.apache.activemq.network.DemandForwardingBridge: Network connection
between vm://consumer-002#2 and tcp://localhost:10002(producer-002) has been
established.
2006-10-31 17:12:53,234 INFO [Thread-3]
org.apache.activemq.network.DemandForwardingBridge: Network connection
between vm://consumer-002#0 and tcp://localhost:10001(producer-001) has been
established.
2006-10-31 17:12:53,234 DEBUG [main]
org.apache.activemq.transport.failover.FailoverTransport: Started.
2006-10-31 17:12:53,265 DEBUG [ActiveMQ Transport: tcp:///127.0.0.1:1407]
org.apache.activemq.broker.region.AbstractRegion: Adding destination:
queue://jmsExample
2006-10-31 17:12:53,281 DEBUG [ActiveMQ Transport:
tcp://localhost/127.0.0.1:10002]
org.apache.activemq.broker.region.AbstractRegion: Adding destination:
queue://jmsExample
2006-10-31 17:12:53,281 DEBUG [ActiveMQ Transport:
tcp://localhost/127.0.0.1:10001]
org.apache.activemq.broker.region.AbstractRegion: Adding destination:
queue://jmsExample
2006-10-31 17:12:53,281 DEBUG [ActiveMQ Transport: tcp:///127.0.0.1:1407]
org.apache.activemq.broker.region.AbstractRegion: Adding destination:
topic://ActiveMQ.Advisory.Queue
2006-10-31 17:12:53,296 DEBUG [ActiveMQ Transport:
tcp://localhost/127.0.0.1:10002]
org.apache.activemq.broker.region.AbstractRegion: Adding destination:
topic://ActiveMQ.Advisory.Consumer.Queue.jmsExample
2006-10-31 17:12:53,296 DEBUG [ActiveMQ Transport:
tcp://localhost/127.0.0.1:10002]
org.apache.activemq.network.DemandForwardingBridge: Forwarding sub on
vm://consumer-002#2 from producer-002 : ConsumerInfo {commandId = 3,
responseRequired = false, consumerId =
ID:dtams0365-1365-1162311147296-3:1:1:1, destination = queue://jmsExample,
prefetchSize = 1000, maximumPendingMessageLimit = 0, browser = false,
dispatchAsync = true, selector = null, subcriptionName = null, noLocal =
false, exclusive = false, retroactive = false, priority = 0, brokerPath =
[ID:dtams0365-1371-1162311149155-0:0, ID:dtams0365-1365-1162311147296-0:0],
optimizedAcknowledge = false, noRangeAcks = false, additionalPredicate =
null}
2006-10-31 17:12:53,296 DEBUG [ActiveMQ Transport:
tcp://localhost/127.0.0.1:10001]
org.apache.activemq.network.DemandForwardingBridge: Forwarding sub on
vm://consumer-002#0 from producer-001 : ConsumerInfo {commandId = 3,
responseRequired = false, consumerId =
ID:dtams0365-1356-1162311143827-3:1:1:1, destination = queue://jmsExample,
prefetchSize = 1000, maximumPendingMessageLimit = 0, browser = false,
dispatchAsync = true, selector = null, subcriptionName = null, noLocal =
false, exclusive = false, retroactive = false, priority = 0, brokerPath =
[ID:dtams0365-1371-1162311149155-0:0, ID:dtams0365-1356-1162311143827-0:0],
optimizedAcknowledge = false, noRangeAcks = false, additionalPredicate =
null}
</code>
The configuration of the brokers is:
<code>
<broker brokerName="consumer-001" persistent="false" useJmx="false">
<transportConnectors>
<transportConnector uri="tcp://localhost:20001"/>
</transportConnectors>
<networkConnectors>
<networkConnector networkTTL="3" name="to-producer-001"
dynamicOnly="true" conduitSubscriptions="true"
uri="static:(tcp://localhost:10001)" failover="true"/>
<networkConnector networkTTL="3" name="to-producer-002"
dynamicOnly="true" conduitSubscriptions="true"
uri="static:(tcp://localhost:10002)" failover="true"/>
</networkConnectors>
<persistenceAdapter>
<memoryPersistenceAdapter/>
</persistenceAdapter>
</broker>
<broker brokerName="consumer-002" persistent="false" useJmx="false">
<transportConnectors>
<transportConnector uri="tcp://localhost:20002"/>
</transportConnectors>
<broker brokerName="producer-001" persistent="false" useJmx="false">
<transportConnectors>
<transportConnector uri="tcp://localhost:10001"/>
</transportConnectors>
<networkConnectors>
<networkConnector networkTTL="3" name="to-consumer-001"
dynamicOnly="true" conduitSubscriptions="true"
uri="static:(tcp://localhost:20001)" failover="true"/>
<networkConnector networkTTL="3" name="to-consumer-002"
dynamicOnly="true" conduitSubscriptions="true"
uri="static:(tcp://localhost:20002)" failover="true"/>
</networkConnectors>
<persistenceAdapter>
<memoryPersistenceAdapter/>
</persistenceAdapter>
</broker>
<broker brokerName="producer-001" persistent="false" useJmx="false">
<transportConnectors>
<transportConnector uri="tcp://localhost:10001"/>
</transportConnectors>
<networkConnectors>
<networkConnector networkTTL="3" name="to-consumer-001"
dynamicOnly="true" conduitSubscriptions="true"
uri="static:(tcp://localhost:20001)" failover="true"/>
<networkConnector networkTTL="3" name="to-consumer-002"
dynamicOnly="true" conduitSubscriptions="true"
uri="static:(tcp://localhost:20002)" failover="true"/>
</networkConnectors>
<persistenceAdapter>
<memoryPersistenceAdapter/>
</persistenceAdapter>
</broker>
<broker brokerName="producer-002" persistent="false" useJmx="false">
<transportConnectors>
<transportConnector uri="tcp://localhost:10002"/>
</transportConnectors>
<networkConnectors>
<networkConnector name="to-consumer-001" networkTTL="3"
dynamicOnly="true" conduitSubscriptions="true"
uri="static:(tcp://localhost:20001)" failover="true"/>
<networkConnector name="to-consumer-002" networkTTL="3"
dynamicOnly="true" conduitSubscriptions="true"
uri="static:(tcp://localhost:20002)" failover="true"/>
</networkConnectors>
<persistenceAdapter>
<memoryPersistenceAdapter/>
</persistenceAdapter>
</broker>
<networkConnectors>
<networkConnector networkTTL="3" name="to-producer-001"
dynamicOnly="true" conduitSubscriptions="true"
uri="static:(tcp://localhost:10001)" failover="true"/>
<networkConnector networkTTL="3" name="to-producer-002"
dynamicOnly="true" conduitSubscriptions="true"
uri="static:(tcp://localhost:10002)" failover="true"/>
</networkConnectors>
<persistenceAdapter>
<memoryPersistenceAdapter/>
</persistenceAdapter>
</broker>
</code>
Has anyone experienced this before, and maybe solved it?
Regards,
Sanne
--
View this message in context:
http://www.nabble.com/Network-of-brokers-tf2546736.html#a7097115
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
