You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2014/11/26 21:05:59 UTC
[12/35] qpid-proton git commit: PROTON-753: add constants for the
delivery outcome symbol descriptors,
for use in setting the supported outcomes on a Source
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 <ro...@apache.org>
Authored: Wed Nov 19 12:53:41 2014 +0000
Committer: Robert Gemmell <ro...@apache.org>
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: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org