You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by de...@apache.org on 2014/06/02 13:22:30 UTC
git commit: https://issues.apache.org/jira/browse/AMQ-5160 -
start/stop wrapped policy
Repository: activemq
Updated Branches:
refs/heads/trunk 7bfbce9a5 -> 3ba129561
https://issues.apache.org/jira/browse/AMQ-5160 - start/stop wrapped policy
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/3ba12956
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/3ba12956
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/3ba12956
Branch: refs/heads/trunk
Commit: 3ba129561c28b3ac36a7d8a8b677cf13797bec9b
Parents: 7bfbce9
Author: Dejan Bosanac <de...@nighttale.net>
Authored: Mon Jun 2 13:22:25 2014 +0200
Committer: Dejan Bosanac <de...@nighttale.net>
Committed: Mon Jun 2 13:22:25 2014 +0200
----------------------------------------------------------------------
.../policy/RetainedMessageSubscriptionRecoveryPolicy.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/3ba12956/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/RetainedMessageSubscriptionRecoveryPolicy.java
----------------------------------------------------------------------
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/RetainedMessageSubscriptionRecoveryPolicy.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/RetainedMessageSubscriptionRecoveryPolicy.java
index ea07c8b..019d37a 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/RetainedMessageSubscriptionRecoveryPolicy.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/RetainedMessageSubscriptionRecoveryPolicy.java
@@ -87,9 +87,15 @@ public class RetainedMessageSubscriptionRecoveryPolicy implements SubscriptionRe
}
public void start() throws Exception {
+ if (wrapped != null) {
+ wrapped.start();
+ }
}
public void stop() throws Exception {
+ if (wrapped != null) {
+ wrapped.stop();
+ }
}
public Message[] browse(ActiveMQDestination destination) throws Exception {