qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From oru...@apache.org
Subject [01/10] qpid-broker-j git commit: QPID-7531: [Java Broker, AMQP 1.0] Improve reported error conditions
Date Thu, 05 Oct 2017 19:20:03 GMT
Repository: qpid-broker-j
Updated Branches:
  refs/heads/master a9c872561 -> fb93bae63


QPID-7531: [Java Broker, AMQP 1.0] Improve reported error conditions


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/c1dabe68
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/c1dabe68
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/c1dabe68

Branch: refs/heads/master
Commit: c1dabe6810300e57824148a5a28e4eca1702907c
Parents: 6a7633d
Author: Lorenz Quack <lquack@apache.org>
Authored: Wed Oct 4 16:03:48 2017 +0100
Committer: Alex Rudyy <orudyy@apache.org>
Committed: Thu Oct 5 12:18:29 2017 +0100

----------------------------------------------------------------------
 .../org/apache/qpid/server/protocol/v1_0/Session_1_0.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/c1dabe68/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Session_1_0.java
----------------------------------------------------------------------
diff --git a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Session_1_0.java
b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Session_1_0.java
index f3fb2cb..ce8e401 100644
--- a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Session_1_0.java
+++ b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Session_1_0.java
@@ -572,8 +572,8 @@ public class Session_1_0 extends AbstractAMQPSession<Session_1_0, ConsumerTarget
         if (linkEndpoint == null)
         {
             Error error = new Error();
-            error.setCondition(AmqpError.ILLEGAL_STATE);
-            error.setDescription("TRANSFER called on Session for link handle " + inputHandle
+ " which is not attached");
+            error.setCondition(SessionError.UNATTACHED_HANDLE);
+            error.setDescription("TRANSFER called on Session for link handle " + inputHandle
+ " which is not attached.");
             _connection.close(error);
 
         }
@@ -581,8 +581,8 @@ public class Session_1_0 extends AbstractAMQPSession<Session_1_0, ConsumerTarget
         {
 
             Error error = new Error();
-            error.setCondition(ConnectionError.FRAMING_ERROR);
-            error.setDescription("TRANSFER called on Session for link handle " + inputHandle
+ " which is a sending ink not a receiving link");
+            error.setCondition(AmqpError.PRECONDITION_FAILED);
+            error.setDescription("Received TRANSFER for link handle " + inputHandle + " which
is a sending link not a receiving link.");
             _connection.close(error);
 
         }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message