activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject git commit: https://issues.apache.org/jira/browse/AMQ-4643 - have keepAlive task trap the new suppressreplyexception such that it can stay alive and renew a lease on resumption
Date Tue, 17 Sep 2013 20:01:59 GMT
Updated Branches:
  refs/heads/trunk dd91e8592 -> 29b90b581


https://issues.apache.org/jira/browse/AMQ-4643 - have keepAlive task trap the new suppressreplyexception
such that it can stay alive and renew a lease on resumption


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

Branch: refs/heads/trunk
Commit: 29b90b58129e7a78cc00dabde923002da133efdf
Parents: dd91e85
Author: gtully <gary.tully@gmail.com>
Authored: Tue Sep 17 21:01:40 2013 +0100
Committer: gtully <gary.tully@gmail.com>
Committed: Tue Sep 17 21:01:40 2013 +0100

----------------------------------------------------------------------
 .../java/org/apache/activemq/broker/LockableServiceSupport.java    | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/29b90b58/activemq-broker/src/main/java/org/apache/activemq/broker/LockableServiceSupport.java
----------------------------------------------------------------------
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/LockableServiceSupport.java
b/activemq-broker/src/main/java/org/apache/activemq/broker/LockableServiceSupport.java
index 13ae02d..b1bffd0 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/LockableServiceSupport.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/LockableServiceSupport.java
@@ -121,6 +121,8 @@ public abstract class LockableServiceSupport extends ServiceSupport implements
L
                     stop = true;
                 }
             }
+        } catch (SuppressReplyException e) {
+            LOG.warn("locker keepAlive resulted in", e);
         } catch (IOException e) {
             LOG.warn("locker keepAlive resulted in", e);
         }


Mime
View raw message