activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hbruch <holger.br...@isb-ag.de>
Subject DemandForwardingBridge not restarted after restart of remote broker
Date Thu, 11 May 2006 13:53:09 GMT

Hi,

when I shut down a remote broker (broker2 in the configuration below) the
local broker's (broker1) DemandForwardingBridge
 is stopped. When i restart the remote broker again, the
DemandForwardingBridge is not restarted,
 though I configured the network connector with failover=true.

Am I missing something? Find the configuration and log below.
I'm using the soon-to-be-voted-on 4.0 release (date: 20060508), JVM 1.5,
WinXP

Thanks for your help,
Holger

<broker brokerName="broker1" useJmx="true">
...
   <transportConnectors>
      <transportConnector name="default" uri="tcp://localhost:61618" />
   </transportConnectors>
   <networkConnectors>
      <networkConnector name="broker2"
uri="static://(tcp://localhost:61617)" failover="true" />
    </networkConnectors>
</broker>

<broker brokerName="broker2" useJmx="true">
...
   <transportConnectors>
      <transportConnector name="default" uri="tcp://localhost:61617" />
   </transportConnectors>
</broker>

... Starting broker2 while broker1 is already running...
2006-05-11 15:46:18,031 [Thread-2       ] DEBUG FailoverTransport             
- Waiting for transport to reconnect.
2006-05-11 15:46:19,033 [Thread-2       ] DEBUG FailoverTransport             
- Waiting for transport to reconnect.
2006-05-11 15:46:20,034 [Thread-2       ] DEBUG FailoverTransport             
- Waiting for transport to reconnect.
2006-05-11 15:46:21,036 [Thread-2       ] DEBUG FailoverTransport             
- Waiting for transport to reconnect.
2006-05-11 15:46:21,266 [orker: 27182317] DEBUG FailoverTransport             
- Attempting connect to: tcp://localhost:61617
2006-05-11 15:46:21,296 [orker: 27182317] DEBUG 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-05-11 15:46:21,336 [st-note11:61617] DEBUG 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-05-11 15:46:21,346 [/127.0.0.1:2126] DEBUG TcpTransport                  
- TCP consumer thread starting
2006-05-11 15:46:21,426 [127.0.0.1:61617] DEBUG TcpTransport                  
- TCP consumer thread starting
2006-05-11 15:46:21,436 [127.0.0.1:61617] DEBUG 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-05-11 15:46:21,436 [/127.0.0.1:2126] DEBUG 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-05-11 15:46:21,446 [/127.0.0.1:2126] DEBUG WireFormatNegotiator          
- tcp:///127.0.0.1:2126 before negotiation: OpenWireFormat{version=1,
cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false}
2006-05-11 15:46:21,446 [/127.0.0.1:2126] DEBUG WireFormatNegotiator          
- tcp:///127.0.0.1:2126 after negotiation: OpenWireFormat{version=1,
cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true,
sizePrefixDisabled=false}
2006-05-11 15:46:21,446 [orker: 27182317] DEBUG FailoverTransport             
- Connection established
2006-05-11 15:46:21,456 [orker: 27182317] INFO  DemandForwardingBridge        
- Outbound transport to null resumed
2006-05-11 15:46:21,456 [127.0.0.1:61617] DEBUG WireFormatNegotiator          
- tcp://localhost/127.0.0.1:61617 before negotiation:
OpenWireFormat{version=1, cacheEnabled=false, stackTraceEnabled=false,
tightEncodingEnabled=false, sizePrefixDisabled=false}
2006-05-11 15:46:21,456 [127.0.0.1:61617] DEBUG WireFormatNegotiator          
- tcp://localhost/127.0.0.1:61617 after negotiation:
OpenWireFormat{version=1, cacheEnabled=true, stackTraceEnabled=true,
tightEncodingEnabled=true, sizePrefixDisabled=false}
2006-05-11 15:46:21,486 [/127.0.0.1:2126] DEBUG AbstractRegion                
- Adding destination: topic://ActiveMQ.Advisory.Connection
2006-05-11 15:46:21,496 [/127.0.0.1:2126] DEBUG AbstractRegion                
- Adding destination: topic://ActiveMQ.Advisory.Topic
2006-05-11 15:46:21,506 [Thread-4       ] DEBUG AbstractRegion                
- Adding destination: topic://ActiveMQ.Advisory.Connection
2006-05-11 15:46:21,536 [Thread-4       ] DEBUG AbstractRegion                
- Adding destination: topic://ActiveMQ.Advisory.Topic
2006-05-11 15:46:21,536 [Thread-4       ] INFO  DemandForwardingBridge        
- Network connection between vm://broker1#0 and
tcp://localhost:61617(broker2) has been established.
... Now stopping broker2 via Ctrl-C...
2006-05-11 15:46:35,206 [main           ] INFO  BrokerService                 
- ActiveMQ Message Broker (broker2, ID:note11-2121-1147355172113-1:0) is
shutting down
2006-05-11 15:46:35,216 [main           ] DEBUG BrokerService                 
- Caught exception, must be shutting down: java.lang.IllegalStateException:
Shutdown in progress
2006-05-11 15:46:35,657 [127.0.0.1:61617] WARN  DemandForwardingBridge        
- Outbound transport to broker2 interrupted ...
2006-05-11 15:46:35,657 [127.0.0.1:61617] INFO  DemandForwardingBridge        
- broker1 Shutting down
2006-05-11 15:46:35,657 [127.0.0.1:61617] DEBUG DemandForwardingBridge        
-  stopping broker1 bridge to broker2 is disposed already ? false
2006-05-11 15:46:35,667 [127.0.0.1:61617] INFO  VMTransportFactory            
- Shutting down VM connectors for broker: broker1
2006-05-11 15:46:35,667 [127.0.0.1:61617] INFO  VMTransportFactory            
- Shutting down VM connectors for broker: broker1
2006-05-11 15:46:35,667 [127.0.0.1:61617] INFO  TransportConnector            
- Connector vm://broker1 Stopped
2006-05-11 15:46:35,667 [127.0.0.1:61617] DEBUG FailoverTransport             
- Stopped.
2006-05-11 15:46:35,667 [127.0.0.1:61617] DEBUG DemandForwardingBridge        
- broker1 bridge to broker2 stopped
2006-05-11 15:46:35,667 [127.0.0.1:61617] DEBUG FailoverTransport             
- Transport failed, starting up reconnect task
java.net.SocketException: Connection reset
	at java.net.SocketInputStream.read(SocketInputStream.java:168)
	at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:48)
	at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:55)
	at java.io.DataInputStream.readInt(DataInputStream.java:443)
	at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:270)
	at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
	at java.lang.Thread.run(Thread.java:534)

... Restarting broker2 ...
2006-05-11 15:46:46,472 [main           ] WARN  MulticastDiscoveryAgent       
- brokerName not set
2006-05-11 15:46:46,472 [main           ] INFO  TransportConnector            
- Connector default Started
2006-05-11 15:46:46,472 [main           ] INFO  BrokerService                 
- ActiveMQ JMS Message Broker (broker2, ID:note11-2128-1147355205721-1:0)
started
2006-05-11 15:46:46,472 [main           ] DEBUG DefaultListableBeanFactory    
- Invoking BeanPostProcessors after initialization of bean
'org.apache.activemq.xbean.XBeanBrokerService'
2006-05-11 15:46:46,472 [main           ] DEBUG DefaultListableBeanFactory    
- Returning cached instance of singleton bean 'postgres-ds'
2006-05-11 15:46:46,492 [main           ] DEBUG
ClassPathXmlApplicationContext - Publishing event in context
[org.apache.xbean.spring.context.ClassPathXmlApplicationContext;hashCode=14651230]:
org.springframework.context.event.ContextRefreshedEvent[source=org.apache.xbean.spring.context.ClassPathXmlApplicationContext:
display name
[org.apache.xbean.spring.context.ClassPathXmlApplicationContext;hashCode=14651230];
startup date [Thu May 11 15:46:45 CEST 2006]; root of context hierarchy]
2006-05-11 15:46:46,492 [main           ] DEBUG DefaultListableBeanFactory    
- No bean named 'broker' found in
org.springframework.beans.factory.support.DefaultListableBeanFactory
defining beans [org.apache.activemq.xbean.XBeanBrokerService,postgres-ds];
root of BeanFactory hierarchy
2006-05-11 15:46:46,492 [main           ] DEBUG DefaultListableBeanFactory    
- Returning cached instance of singleton bean
'org.apache.activemq.xbean.XBeanBrokerService'


--
View this message in context: http://www.nabble.com/DemandForwardingBridge-not-restarted-after-restart-of-remote-broker-t1600808.html#a4340799
Sent from the ActiveMQ - User forum at Nabble.com.


Mime
View raw message