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 <[email protected]> Authored: Mon Jun 2 13:22:25 2014 +0200 Committer: Dejan Bosanac <[email protected]> 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 {
