You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2009/08/12 20:20:16 UTC

svn commit: r803650 - /qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java

Author: ritchiem
Date: Wed Aug 12 18:20:16 2009
New Revision: 803650

URL: http://svn.apache.org/viewvc?rev=803650&view=rev
Log:
QPID-2002 : Ensure that we set the logging actor correctly when mina signals the connection closed

Modified:
    qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java

Modified: qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java?rev=803650&r1=803649&r2=803650&view=diff
==============================================================================
--- qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java (original)
+++ qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java Wed Aug 12 18:20:16 2009
@@ -48,6 +48,7 @@
 import org.apache.qpid.server.configuration.ServerConfiguration;
 import org.apache.qpid.server.registry.ApplicationRegistry;
 import org.apache.qpid.server.registry.IApplicationRegistry;
+import org.apache.qpid.server.logging.actors.CurrentActor;
 import org.apache.qpid.ssl.SSLContextFactory;
 
 /**
@@ -175,12 +176,17 @@
         {
             try
             {
+                CurrentActor.set(amqProtocolSession.getLogActor());
                 amqProtocolSession.closeSession();
             }
             catch (AMQException e)
             {
                 _logger.error("Caught AMQException whilst closingSession:" + e);
             }
+            finally
+            {
+                CurrentActor.remove();
+            }
         }
     }
 



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org