activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [3/4] activemq-6 git commit: ACTIVEMQ6-38 Overzealous logging for missing queue
Date Mon, 17 Nov 2014 19:59:08 GMT
ACTIVEMQ6-38 Overzealous logging for missing queue


Project: http://git-wip-us.apache.org/repos/asf/activemq-6/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-6/commit/2d9125a7
Tree: http://git-wip-us.apache.org/repos/asf/activemq-6/tree/2d9125a7
Diff: http://git-wip-us.apache.org/repos/asf/activemq-6/diff/2d9125a7

Branch: refs/heads/master
Commit: 2d9125a7c61999ed2aaa7c14d0fd3fe2b9a5d19d
Parents: 8fcf81f
Author: jbertram <jbertram@redhat.com>
Authored: Mon Nov 17 13:47:49 2014 -0600
Committer: jbertram <jbertram@redhat.com>
Committed: Mon Nov 17 13:47:49 2014 -0600

----------------------------------------------------------------------
 .../core/protocol/core/ServerSessionPacketHandler.java      | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-6/blob/2d9125a7/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/ServerSessionPacketHandler.java
----------------------------------------------------------------------
diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/ServerSessionPacketHandler.java
b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/ServerSessionPacketHandler.java
index 1b2382f..57ac895 100644
--- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/ServerSessionPacketHandler.java
+++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/ServerSessionPacketHandler.java
@@ -556,7 +556,14 @@ public class ServerSessionPacketHandler implements ChannelHandler
             }
             else
             {
-               HornetQServerLogger.LOGGER.caughtException(e);
+               if (e.getType() == HornetQExceptionType.QUEUE_EXISTS)
+               {
+                  HornetQServerLogger.LOGGER.debug("Caught exception", e);
+               }
+               else
+               {
+                  HornetQServerLogger.LOGGER.caughtException(e);
+               }
             }
          }
          catch (Throwable t)


Mime
View raw message