qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From oru...@apache.org
Subject [04/10] qpid-broker-j git commit: QPID-7531: [Java Broker] add JIRA references to TODOs
Date Thu, 05 Oct 2017 19:20:06 GMT
QPID-7531: [Java Broker] add JIRA references to TODOs


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

Branch: refs/heads/master
Commit: a963d54d1df8e0a8de0b0b6e7189e56ebe5fd32a
Parents: 6b44f41
Author: Lorenz Quack <lquack@apache.org>
Authored: Wed Oct 4 14:05:39 2017 +0100
Committer: Alex Rudyy <orudyy@apache.org>
Committed: Thu Oct 5 12:18:29 2017 +0100

----------------------------------------------------------------------
 .../org/apache/qpid/server/protocol/v1_0/AbstractLinkEndpoint.java | 2 +-
 .../org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.java   | 2 ++
 .../java/org/apache/qpid/server/protocol/v1_0/Session_1_0.java     | 2 +-
 3 files changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/a963d54d/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AbstractLinkEndpoint.java
----------------------------------------------------------------------
diff --git a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AbstractLinkEndpoint.java
b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AbstractLinkEndpoint.java
index 6664600..287979a 100644
--- a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AbstractLinkEndpoint.java
+++ b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AbstractLinkEndpoint.java
@@ -433,7 +433,7 @@ public abstract class AbstractLinkEndpoint<S extends BaseSource, T
extends BaseT
 
     protected void detach(Error error, boolean close)
     {
-        //TODO
+        //TODO: QPID-7954: improve detach
         switch (_state)
         {
             case ATTACHED:

http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/a963d54d/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.java
----------------------------------------------------------------------
diff --git a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.java
b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.java
index 66a1fd3..eb6d512 100644
--- a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.java
+++ b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.java
@@ -324,6 +324,7 @@ class ConsumerTarget_1_0 extends AbstractConsumerTarget<ConsumerTarget_1_0>
     }
 
     /*
+        QPID-7541
         Currently if a queue is deleted the consumer sits there withiout being closed, but
         obviously not receiving any new messages
 
@@ -339,6 +340,7 @@ class ConsumerTarget_1_0 extends AbstractConsumerTarget<ConsumerTarget_1_0>
         linkReg.unregisterSendingLink(getEndpoint().getName());
     }
       */
+
     @Override
     public boolean allocateCredit(final ServerMessage msg)
     {

http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/a963d54d/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 4a91719..f3fb2cb 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
@@ -1264,7 +1264,7 @@ public class Session_1_0 extends AbstractAMQPSession<Session_1_0,
ConsumerTarget
         }
         else
         {
-            // TODO
+            //TODO: QPID-7954
         }
     }
 


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


Mime
View raw message