From: Adrian B. <ej...@us...> - 2003-09-15 09:16:53
|
User: ejort Date: 03/09/15 02:16:52 Modified: src/main/org/jboss/ejb/plugins/jms Tag: Branch_3_2 JMSContainerInvoker.java Log: Don't destroy the DLQ handler until the invoker has finished Revision Changes Path No revision No revision 1.50.2.11 +15 -14 jboss/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvoker.java Index: JMSContainerInvoker.java =================================================================== RCS file: /cvsroot/jboss/jboss/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvoker.java,v retrieving revision 1.50.2.10 retrieving revision 1.50.2.11 diff -u -r1.50.2.10 -r1.50.2.11 --- JMSContainerInvoker.java 11 Aug 2003 16:41:50 -0000 1.50.2.10 +++ JMSContainerInvoker.java 15 Sep 2003 09:16:51 -0000 1.50.2.11 @@ -65,7 +65,7 @@ /** * EJBProxyFactory for JMS MessageDrivenBeans * - * @version <tt>$Revision: 1.50.2.10 $</tt> + * @version <tt>$Revision: 1.50.2.11 $</tt> * @author <a href="mailto:pet...@ti...">Peter Antman</a> . * @author <a href="mailto:ric...@te...">Rickard Ãberg</a> * @author <a href="mailto:seb...@m4...">Sebastien Alborini</a> @@ -752,19 +752,6 @@ protected void destroyService() throws Exception { - // Take down DLQ - try - { - if (dlqHandler != null) - { - dlqHandler.destroy(); - dlqHandler = null; - } - } - catch (Exception e) - { - log.error("Failed to close the dlq handler", e); - } // close the connection consumer try @@ -804,6 +791,20 @@ { log.error("Failed to close connection", e); } + } + + // Take down DLQ + try + { + if (dlqHandler != null) + { + dlqHandler.destroy(); + dlqHandler = null; + } + } + catch (Exception e) + { + log.error("Failed to close the dlq handler", e); } } |