You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2013/09/17 22:01:59 UTC
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
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 <ga...@gmail.com>
Authored: Tue Sep 17 21:01:40 2013 +0100
Committer: gtully <ga...@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);
}