activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hiram Chirino (JIRA)" <j...@apache.org>
Subject [jira] Resolved: (AMQ-813) can get a shutdown hang when using embedded broker with VM transport along with the activemq-web module
Date Tue, 11 Jul 2006 14:48:51 GMT
     [ 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


Mime
View raw message