activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hbruch <>
Subject Hanging shutdown using failover networkConnector
Date Wed, 27 Sep 2006 18:19:43 GMT

I just updated to AMQ 4.0.2 (RC4). Changes since 4.0.1 seem to result in a
hanging broker, if a network connection could not be established.

The stacktrace is as follows:
HangingShutdown at localhost:4847 (Suspended)
	System Thread [Finalizer] (Suspended)
	System Thread [Reference Handler] (Suspended)
	Thread [main] (Suspended)
		MutexTransport.oneway(Command) line: 45
		ResponseCorrelator.oneway(Command) line: 59
		DiscoveryNetworkConnector$2(DemandForwardingBridgeSupport).stop() line:
		DiscoveryNetworkConnector.doStop(ServiceStopper) line: 191
		DiscoveryNetworkConnector(ServiceSupport).stop() line: 58
		ServiceStopper.stop(Service) line: 42
		XBeanBrokerService(BrokerService).stop() line: 398
		HangingShutdown.main(String[]) line: 10
	System Thread [Signal Dispatcher] (Suspended)
	Thread [ActiveMQ Transport Server: tcp://isbst-note11:61618] (Suspended)
		PlainSocketImpl.socketAccept(SocketImpl) line: not available [native
		SocksSocketImpl(PlainSocketImpl).accept(SocketImpl) line: 384
		ServerSocket.implAccept(Socket) line: 450
		ServerSocket.accept() line: 421 line: 125 line: 595
	Thread [ActiveMQ Transport Status Monitor: default] (Suspended)
		Thread.sleep(long) line: not available [native method] line: 99 line: 595
	Thread [ActiveMQ Task] (Suspended)
		PlainSocketImpl.socketConnect(InetAddress, int, int) line: not available
[native method]
		SocksSocketImpl(PlainSocketImpl).doConnect(InetAddress, int, int) line:
		SocksSocketImpl(PlainSocketImpl).connectToAddress(InetAddress, int, int)
line: 195
		SocksSocketImpl(PlainSocketImpl).connect(SocketAddress, int) line: 182
		SocksSocketImpl.connect(SocketAddress, int) line: 366
		Socket.connect(SocketAddress, int) line: 516
		TcpTransport.connect() line: 319
		TcpTransport.doStart() line: 288
		TcpTransport(ServiceSupport).start() line: 49
		InactivityMonitor(TransportFilter).start() line: 56
		WireFormatNegotiator(TransportFilter).start() line: 56
		WireFormatNegotiator.start() line: 60
		FailoverTransport$2.iterate() line: 170
		PooledTaskRunner.runTask() line: 111
		PooledTaskRunner.access$1(PooledTaskRunner) line: 95
		PooledTaskRunner$ line: 44
		ThreadPoolExecutor$Worker.runTask(Runnable) line: 650
		ThreadPoolExecutor$ line: 675 line: 595
	Thread [ActiveMQ Transport Status Monitor: vm://Broker] (Suspended)
		Thread.sleep(long) line: not available [native method] line: 99 line: 595
	Thread [Thread-1] (Suspended)
		Object.wait(long) line: not available [native method]
		FailoverTransport.oneway(Command) line: 359
		MutexTransport.oneway(Command) line: 45
		ResponseCorrelator.oneway(Command) line: 59
line: 253
		DemandForwardingBridgeSupport$ line: 204

See code below to reproduce.



public class HangingShutdown {
  public static int main(String[] args) throws Exception {
    BrokerService broker = BrokerFactory.createBroker(new
    return 0;

<beans xmlns="">
  <broker brokerName="Broker" useJmx="false" persistent="false">
       <transportConnector name="default" uri="tcp://localhost:61618"/>
      <networkConnector name="other" uri="static:tcp://localhost:61619"

View this message in context:
Sent from the ActiveMQ - User mailing list archive at

View raw message