activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject git commit: https://issues.apache.org/jira/browse/AMQ-5160 - start/stop wrapped policy
Date Mon, 02 Jun 2014 11:22:30 GMT
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 <dejan@nighttale.net>
Authored: Mon Jun 2 13:22:25 2014 +0200
Committer: Dejan Bosanac <dejan@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 {


Mime
View raw message