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-2327 - fix regression in org.apache.activemq.network.NetworkBrokerDetachTest - need to conduit statically included durables when dynamicOnly=false (local networkSubs)
Date Tue, 01 Oct 2013 15:05:14 GMT
Updated Branches:
  refs/heads/trunk ee8b51b27 -> 83f519cd6


https://issues.apache.org/jira/browse/AMQ-2327 - fix regression in org.apache.activemq.network.NetworkBrokerDetachTest
- need to conduit statically included durables when dynamicOnly=false (local networkSubs)


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

Branch: refs/heads/trunk
Commit: 83f519cd657aea378c3d7a4452f71318a2dbdcdf
Parents: ee8b51b
Author: gtully <gary.tully@gmail.com>
Authored: Tue Oct 1 16:04:13 2013 +0100
Committer: gtully <gary.tully@gmail.com>
Committed: Tue Oct 1 16:05:01 2013 +0100

----------------------------------------------------------------------
 .../main/java/org/apache/activemq/network/DurableConduitBridge.java | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/83f519cd/activemq-broker/src/main/java/org/apache/activemq/network/DurableConduitBridge.java
----------------------------------------------------------------------
diff --git a/activemq-broker/src/main/java/org/apache/activemq/network/DurableConduitBridge.java
b/activemq-broker/src/main/java/org/apache/activemq/network/DurableConduitBridge.java
index d2d9a79..621972c 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/network/DurableConduitBridge.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/network/DurableConduitBridge.java
@@ -59,6 +59,7 @@ public class DurableConduitBridge extends ConduitBridge {
             for (ActiveMQDestination dest : dests) {
                 if (isPermissableDestination(dest) && !doesConsumerExist(dest)) {
                     DemandSubscription sub = createDemandSubscription(dest);
+                    sub.setStaticallyIncluded(true);
                     if (dest.isTopic()) {
                         sub.getLocalInfo().setSubscriptionName(getSubscriberName(dest));
                     }


Mime
View raw message