Repository: qpid-broker-j Updated Branches: refs/heads/7.0.x b5d67e003 -> aea2d43c5
QPID-7948: [Broker-J] [AMQP 0-9-1] [Publisher Confirms] Ensure that unroutable non-mandatory messages are acknowledged (cherry picked from commit fb98e76e86656799a9e16e6f09a6402b01bd2f2a) 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/aea2d43c Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/aea2d43c Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/aea2d43c Branch: refs/heads/7.0.x Commit: aea2d43c5ed6ab921b1b3eefe43ece96125c9d5b Parents: b5d67e0 Author: Keith Wall <[email protected]> Authored: Mon Jan 15 16:42:16 2018 +0000 Committer: Alex Rudyy <[email protected]> Committed: Wed Mar 21 12:40:51 2018 +0000 ---------------------------------------------------------------------- .../java/org/apache/qpid/server/protocol/v0_8/AMQChannel.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/aea2d43c/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQChannel.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQChannel.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQChannel.java index ffe2c8d..6418ea9 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQChannel.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQChannel.java @@ -461,6 +461,12 @@ public class AMQChannel extends AbstractAMQPSession<AMQChannel, ConsumerTarget_0 } else { + if (_confirmOnPublish) + { + _connection.writeFrame(new AMQFrame(_channelId, + new BasicAckBody(_confirmedMessageCounter, + false))); + } message(ExchangeMessages.DISCARDMSG(exchangeName, routingKey)); } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
