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:[email protected]
