You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2017/10/05 19:20:06 UTC
[04/10] qpid-broker-j git commit: QPID-7531: [Java Broker] add JIRA
references to TODOs
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 <lq...@apache.org>
Authored: Wed Oct 4 14:05:39 2017 +0100
Committer: Alex Rudyy <or...@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