[ https://issues.apache.org/activemq/browse/AMQ-813?page=all ] Hiram Chirino resolved AMQ-813: -------------------------------
Fix Version: 4.0.2 Resolution: Fixed Assign To: Hiram Chirino Fixed: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java?r1=415306&r2=420714&pathrev=420714 The VMTransport's oneway method was dropping the send request when the peer was disconnected like in the case where the broker is shutdown at the same time that the client is shutdown. > can get a shutdown hang when using embedded broker with VM transport along > with the activemq-web module > ------------------------------------------------------------------------------------------------------- > > Key: AMQ-813 > URL: https://issues.apache.org/activemq/browse/AMQ-813 > Project: ActiveMQ > Type: Bug > Reporter: james strachan > Assignee: Hiram Chirino > Fix For: 4.1, 4.0.2 > > > See attached thread dump. I think we just need to use a timeout on the close > operations (such as to close consumers, sessions, producers) > Full thread dump Java HotSpot(TM) Client VM (1.5.0_04-b05 mixed mode, > sharing): > > "Shutdown" prio=1 tid=0x08385960 nid=0x5e99 in Object.wait() > [0xaed7d000..0xaed7e130] > at java.lang.Object.wait(Native Method) > - waiting on <0x88af01c8> (a > edu.emory.mathcs.backport.java.util.concurrent.locks.CondVar) > at java.lang.Object.wait(Object.java:474) > at > edu.emory.mathcs.backport.java.util.concurrent.locks.CondVar.await(CondVar.java:75) > - locked <0x88af01c8> (a > edu.emory.mathcs.backport.java.util.concurrent.locks.CondVar) > at > edu.emory.mathcs.backport.java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:318) > at > org.apache.activemq.transport.FutureResponse.getResult(FutureResponse.java:41) > at > org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:72) > at > org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1130) > at > org.apache.activemq.ActiveMQSession.syncSendPacket(ActiveMQSession.java:1660) > at > org.apache.activemq.ActiveMQMessageConsumer.close(ActiveMQMessageConsumer.java:516) > at > org.apache.activemq.web.WebClient.closeConsumers(WebClient.java:135) > - locked <0x893e6558> (a org.apache.activemq.web.WebClient) > at org.apache.activemq.web.WebClient.close(WebClient.java:145) > - locked <0x893e6558> (a org.apache.activemq.web.WebClient) > at org.apache.activemq.web.WebClient.valueUnbound(WebClient.java:318) > at > org.mortbay.jetty.servlet.AbstractSessionManager$Session.unbindValue(AbstractSessionManager.java:899) > at > org.mortbay.jetty.servlet.AbstractSessionManager$Session.invalidate(AbstractSessionManager.java:755) > - locked <0x893caa88> (a > org.mortbay.jetty.servlet.HashSessionManager$Session) > at > org.mortbay.jetty.servlet.AbstractSessionManager.doStop(AbstractSessionManager.java:551) > at > org.mortbay.component.AbstractLifeCycle.stop(AbstractLifeCycle.java:63) > at > org.mortbay.jetty.servlet.SessionHandler.doStop(SessionHandler.java:124) > at > org.mortbay.component.AbstractLifeCycle.stop(AbstractLifeCycle.java:63) > at > org.mortbay.jetty.handler.HandlerWrapper.doStop(HandlerWrapper.java:131) > at > org.mortbay.jetty.handler.ContextHandler.doStop(ContextHandler.java:467) > at > org.mortbay.jetty.webapp.WebAppContext.doStop(WebAppContext.java:477) > at > org.mortbay.component.AbstractLifeCycle.stop(AbstractLifeCycle.java:63) > at > org.mortbay.jetty.handler.HandlerCollection.doStop(HandlerCollection.java:173) > at > org.mortbay.component.AbstractLifeCycle.stop(AbstractLifeCycle.java:63) > at > org.mortbay.jetty.handler.HandlerCollection.doStop(HandlerCollection.java:173) > at > org.mortbay.component.AbstractLifeCycle.stop(AbstractLifeCycle.java:63) > at > org.mortbay.jetty.handler.HandlerWrapper.doStop(HandlerWrapper.java:131) > at org.mortbay.jetty.Server.doStop(Server.java:242) > at > org.mortbay.component.AbstractLifeCycle.stop(AbstractLifeCycle.java:63) > at org.mortbay.jetty.Server$ShutdownHookThread.run(Server.java:450) -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira