activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sanne <sa...@newfoundland.nl>
Subject Re: Network of brokers
Date Wed, 01 Nov 2006 16:34:30 GMT

Hi Bernard,

O.k, thanks for replicating the problem. 

Somewhat related is the prefetchSize on the network connector. This prevents
all messages streaming to the consumer not being restarted. Setting the
prefetchSize does not solve this problem however.

Regards,

Sanne


Bernhard2 wrote:
> 
> Hello,
> 
> I experienced the same problem in my tests.
> 
> Who can help Sanne and me here? I’m subscribed to this mailing list for
> some time now. As soon when it comes to help for topics around “network of
> brokers”, I noticed that normally nobody is able (or wants?) to help. Is a
> “network of brokers” an uncommon used feature? Regarding to the number of
> mails for this topic I do not think so.
> 
> Thanks and have a nice day,
> 
> Bernhard
> 
> 
> 
> sanne wrote:
>> 
>> 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#a7117463
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message