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