You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2014/10/22 11:35:19 UTC
svn commit: r1633579 -
/qpid/trunk/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQProtocolEngine.java
Author: rgodfrey
Date: Wed Oct 22 09:35:18 2014
New Revision: 1633579
URL: http://svn.apache.org/r1633579
Log:
QPID-6125 : only log store exceptions that occur against a vhost which is no longer AVAILABLE
Modified:
qpid/trunk/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQProtocolEngine.java
Modified: qpid/trunk/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQProtocolEngine.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQProtocolEngine.java?rev=1633579&r1=1633578&r2=1633579&view=diff
==============================================================================
--- qpid/trunk/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQProtocolEngine.java (original)
+++ qpid/trunk/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQProtocolEngine.java Wed Oct 22 09:35:18 2014
@@ -80,6 +80,7 @@ import org.apache.qpid.server.security.S
import org.apache.qpid.server.security.auth.AuthenticatedPrincipal;
import org.apache.qpid.server.security.auth.SubjectAuthenticationResult;
import org.apache.qpid.server.stats.StatisticsCounter;
+import org.apache.qpid.server.store.StoreException;
import org.apache.qpid.server.util.Action;
import org.apache.qpid.server.util.ConnectionScopedRuntimeException;
import org.apache.qpid.server.util.ServerScopedRuntimeException;
@@ -344,6 +345,17 @@ public class AMQProtocolEngine implement
_logger.error("I/O Exception", e);
closeProtocolSession();
}
+ catch (StoreException e)
+ {
+ if(_virtualHost.getState() == State.ACTIVE)
+ {
+ throw e;
+ }
+ else
+ {
+ _logger.error("Store Exception ignored as virtual host no longer active", e);
+ }
+ }
finally
{
_receivedLock.unlock();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org