PROTON-753: add constants for the delivery outcome symbol descriptors, for use in setting the supported outcomes on a Source
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/7b91e1ff Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/7b91e1ff Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/7b91e1ff Branch: refs/heads/examples Commit: 7b91e1ffe986c8b3f4ee9f4b6c3fe24cafedbe05 Parents: 02f1c57 Author: Robert Gemmell <[email protected]> Authored: Wed Nov 19 12:53:41 2014 +0000 Committer: Robert Gemmell <[email protected]> Committed: Wed Nov 19 16:31:43 2014 +0000 ---------------------------------------------------------------------- .../main/java/org/apache/qpid/proton/amqp/messaging/Accepted.java | 3 +++ .../main/java/org/apache/qpid/proton/amqp/messaging/Modified.java | 3 +++ .../main/java/org/apache/qpid/proton/amqp/messaging/Rejected.java | 2 ++ .../main/java/org/apache/qpid/proton/amqp/messaging/Released.java | 3 +++ .../java/org/apache/qpid/proton/amqp/transaction/Declared.java | 3 +++ 5 files changed, 14 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/7b91e1ff/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Accepted.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Accepted.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Accepted.java index a2bac32..d21caaa 100644 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Accepted.java +++ b/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Accepted.java @@ -23,12 +23,15 @@ package org.apache.qpid.proton.amqp.messaging; +import org.apache.qpid.proton.amqp.Symbol; import org.apache.qpid.proton.amqp.transport.DeliveryState; public final class Accepted implements DeliveryState, Outcome { + public static final Symbol DESCRIPTOR_SYMBOL = Symbol.valueOf("amqp:accepted:list"); + private static final Accepted INSTANCE = new Accepted(); http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/7b91e1ff/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Modified.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Modified.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Modified.java index d727e25..9b9a3a3 100644 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Modified.java +++ b/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Modified.java @@ -22,11 +22,14 @@ package org.apache.qpid.proton.amqp.messaging; import java.util.Map; + +import org.apache.qpid.proton.amqp.Symbol; import org.apache.qpid.proton.amqp.transport.DeliveryState; public final class Modified implements DeliveryState, Outcome { + public static final Symbol DESCRIPTOR_SYMBOL = Symbol.valueOf("amqp:modified:list"); private Boolean _deliveryFailed; private Boolean _undeliverableHere; http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/7b91e1ff/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Rejected.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Rejected.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Rejected.java index 022c277..3ea3a5b 100644 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Rejected.java +++ b/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Rejected.java @@ -23,6 +23,7 @@ package org.apache.qpid.proton.amqp.messaging; +import org.apache.qpid.proton.amqp.Symbol; import org.apache.qpid.proton.amqp.transport.DeliveryState; import org.apache.qpid.proton.amqp.transport.ErrorCondition; @@ -30,6 +31,7 @@ import org.apache.qpid.proton.amqp.transport.ErrorCondition; public final class Rejected implements DeliveryState, Outcome { + public static final Symbol DESCRIPTOR_SYMBOL = Symbol.valueOf("amqp:rejected:list"); private ErrorCondition _error; http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/7b91e1ff/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Released.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Released.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Released.java index a9878c1..c67917f 100644 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Released.java +++ b/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Released.java @@ -23,12 +23,15 @@ package org.apache.qpid.proton.amqp.messaging; +import org.apache.qpid.proton.amqp.Symbol; import org.apache.qpid.proton.amqp.transport.DeliveryState; public final class Released implements DeliveryState, Outcome { + public static final Symbol DESCRIPTOR_SYMBOL = Symbol.valueOf("amqp:released:list"); + private static final Released INSTANCE = new Released(); @Override http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/7b91e1ff/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Declared.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Declared.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Declared.java index 18b508c..e049cd5 100644 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Declared.java +++ b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Declared.java @@ -24,6 +24,7 @@ package org.apache.qpid.proton.amqp.transaction; import org.apache.qpid.proton.amqp.Binary; +import org.apache.qpid.proton.amqp.Symbol; import org.apache.qpid.proton.amqp.messaging.Outcome; import org.apache.qpid.proton.amqp.transport.DeliveryState; @@ -31,6 +32,8 @@ import org.apache.qpid.proton.amqp.transport.DeliveryState; public final class Declared implements DeliveryState, Outcome { + public static final Symbol DESCRIPTOR_SYMBOL = Symbol.valueOf("amqp:declared:list"); + private Binary _txnId; public Binary getTxnId() --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
