qpid-broker-j git commit: QPID-7664: [Java Broker] [AMQP1.0] Supply default-outcome on SendingLinks

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

qpid-broker-j git commit: QPID-7664: [Java Broker] [AMQP1.0] Supply default-outcome on SendingLinks

lquack
Repository: qpid-broker-j
Updated Branches:
  refs/heads/master 77925a1a1 -> c2c2bc470


QPID-7664: [Java Broker] [AMQP1.0] Supply default-outcome on SendingLinks


Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/c2c2bc47
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/c2c2bc47
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/c2c2bc47

Branch: refs/heads/master
Commit: c2c2bc470ae7d59a5eeba6d560e97aaf68a216b7
Parents: 77925a1
Author: Lorenz Quack <[hidden email]>
Authored: Thu Jun 15 14:16:34 2017 +0100
Committer: Lorenz Quack <[hidden email]>
Committed: Thu Jun 15 14:46:26 2017 +0100

----------------------------------------------------------------------
 .../org/apache/qpid/server/protocol/v1_0/SendingLinkEndpoint.java | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/c2c2bc47/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLinkEndpoint.java
----------------------------------------------------------------------
diff --git a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLinkEndpoint.java b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLinkEndpoint.java
index 1f346afd..55431e4 100644
--- a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLinkEndpoint.java
+++ b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLinkEndpoint.java
@@ -638,6 +638,9 @@ public class SendingLinkEndpoint extends AbstractLinkEndpoint<Source, Target>
             source = new Source();
             Source attachSource = (Source) attach.getSource();
 
+            final Modified defaultOutcome = new Modified();
+            defaultOutcome.setDeliveryFailed(true);
+            source.setDefaultOutcome(defaultOutcome);
             source.setAddress(attachSource.getAddress());
             source.setDynamic(attachSource.getDynamic());
             if (Boolean.TRUE.equals(attachSource.getDynamic()) && attachSource.getDynamicNodeProperties() != null)


---------------------------------------------------------------------
To unsubscribe, e-mail: [hidden email]
For additional commands, e-mail: [hidden email]