2016-09-21 59 views
1

我正在运行带有嵌入式ActiveMQ服务器(5.10.0)的Spring Boot(1.3.5)控制台应用程序,该应用程序对于接收消息来说工作得很好。但是,我无法在没有例外的情况下关闭应用程序。关闭Apache ActiveMQ

此异常为每个队列扔一次,按Ctrl-C后:

2016-09-21 15:46:36.561 ERROR 18275 --- [update]] o.apache.activemq.broker.BrokerService : Failed to start Apache ActiveMQ ([my-mq-server, null], {}) 

java.lang.IllegalStateException: Shutdown in progress 
    at java.lang.ApplicationShutdownHooks.add(ApplicationShutdownHooks.java:66) 
    at java.lang.Runtime.addShutdownHook(Runtime.java:211) 
    at org.apache.activemq.broker.BrokerService.addShutdownHook(BrokerService.java:2446) 
    at org.apache.activemq.broker.BrokerService.doStartBroker(BrokerService.java:693) 
    at org.apache.activemq.broker.BrokerService.startBroker(BrokerService.java:684) 
    at org.apache.activemq.broker.BrokerService.start(BrokerService.java:605) 
    at org.apache.activemq.transport.vm.VMTransportFactory.doCompositeConnect(VMTransportFactory.java:127) 
    at org.apache.activemq.transport.vm.VMTransportFactory.doConnect(VMTransportFactory.java:56) 
    at org.apache.activemq.transport.TransportFactory.connect(TransportFactory.java:65) 
    at org.apache.activemq.ActiveMQConnectionFactory.createTransport(ActiveMQConnectionFactory.java:314) 
    at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:329) 
    at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:302) 
    at org.apache.activemq.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:242) 
    at org.apache.activemq.jms.pool.PooledConnectionFactory.createConnection(PooledConnectionFactory.java:283) 
    at org.apache.activemq.jms.pool.PooledConnectionFactory$1.makeObject(PooledConnectionFactory.java:96) 
    at org.apache.activemq.jms.pool.PooledConnectionFactory$1.makeObject(PooledConnectionFactory.java:93) 
    at org.apache.commons.pool2.impl.GenericKeyedObjectPool.create(GenericKeyedObjectPool.java:1041) 
    at org.apache.commons.pool2.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:357) 
    at org.apache.commons.pool2.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:279) 
    at org.apache.activemq.jms.pool.PooledConnectionFactory.createConnection(PooledConnectionFactory.java:243) 
    at org.apache.activemq.jms.pool.PooledConnectionFactory.createConnection(PooledConnectionFactory.java:212) 
    at org.springframework.jms.support.JmsAccessor.createConnection(JmsAccessor.java:180) 
    at org.springframework.jms.listener.AbstractJmsListeningContainer.createSharedConnection(AbstractJmsListeningContainer.java:413) 
    at org.springframework.jms.listener.AbstractJmsListeningContainer.refreshSharedConnection(AbstractJmsListeningContainer.java:398) 
    at org.springframework.jms.listener.DefaultMessageListenerContainer.refreshConnectionUntilSuccessful(DefaultMessageListenerContainer.java:925) 
    at org.springframework.jms.listener.DefaultMessageListenerContainer.recoverAfterListenerSetupFailure(DefaultMessageListenerContainer.java:899) 
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1075) 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) 
    at java.lang.Thread.run(Thread.java:745) 
2016-09-21 15:46:36.564 INFO 18275 --- [update]] o.apache.activemq.broker.BrokerService : Apache ActiveMQ 5.12.3 (my-mq-server, null) is shutting down 

它似乎使用DefaultMessageListenerContainer试图启动一个ActiveMQ的服务器,即没有道理给我。我已经将BrokerService的阶段设置为Integer.MAX_INT - 1,并且将DefaultJmsListeningContainerFactory的阶段设置为Integer.MAX_INT,以在ActiveMQ服务器停止之前使其消失。

我有这个在我的主要():

public static void main(String[] args) { 
    final ConfigurableApplicationContext context = SpringApplication.run(SiteServer.class, args); 
    context.registerShutdownHook(); 
} 

我试过的建议在这里设置守护进程为true:Properly Shutting Down ActiveMQ and Spring DefaultMessageListenerContainer

任何想法?谢谢! =)

+0

'run()'可能会阻塞,直到输入CTRL-C(可能是因为SiteServer正在做什么?)。您需要使用http://docs.spring.io/spring-boot/docs/current/api/org/springframework/boot/SpringApplication.html中的第二个示例对其进行分割 – Gus

回答

0

找到它。当驼峰上下文在 BrokerService之后关闭时发生此问题。添加适当的生命周期管理,以便在解决问题之前关闭骆驼。现在一切都以干净的方式关闭,没有错误。