diff options
-rw-r--r-- | qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Session_1_0.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Session_1_0.java b/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Session_1_0.java index 1820de9d3a..b9ee0ad498 100644 --- a/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Session_1_0.java +++ b/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Session_1_0.java @@ -214,7 +214,7 @@ public class Session_1_0 implements SessionEventListener, AMQSessionModel<Sessio registerConsumer(sendingLink.getConsumer()); link = sendingLink; - if(TerminusDurability.UNSETTLED_STATE.equals(source.getDurable())) + if(TerminusDurability.UNSETTLED_STATE.equals(source.getDurable()) || TerminusDurability.CONFIGURATION.equals(source.getDurable())) { linkRegistry.registerSendingLink(endpoint.getName(), sendingLink); } @@ -376,7 +376,8 @@ public class Session_1_0 implements SessionEventListener, AMQSessionModel<Sessio receivingLinkEndpoint.setLinkEventListener(new SubjectSpecificReceivingLinkListener(receivingLink)); link = receivingLink; - if(TerminusDurability.UNSETTLED_STATE.equals(target.getDurable())) + if(TerminusDurability.UNSETTLED_STATE.equals(target.getDurable()) + || TerminusDurability.CONFIGURATION.equals(target.getDurable())) { linkRegistry.registerReceivingLink(endpoint.getName(), receivingLink); } |