diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2015-02-12 18:50:09 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2015-02-12 18:50:09 +0000 |
| commit | 8d84886a1324a42db1992a4d567487821894d691 (patch) | |
| tree | c1ce99e1c405c5c2c95b07215da367c734dbadd5 | |
| parent | 176675ef4914dbc548e92700232ec4429614430a (diff) | |
| download | qpid-python-8d84886a1324a42db1992a4d567487821894d691.tar.gz | |
QPID-6388 : Treat terminus with durability of "configuration" as durable
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1659359 13f79535-47bb-0310-9956-ffa450edef68
| -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); } |