Repository: activemq-artemis Updated Branches: refs/heads/master 4936291ae -> a4beb18a6
ARTEMIS-1044 Avoiding StackOverflow on AMQP under load Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/a4beb18a Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/a4beb18a Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/a4beb18a Branch: refs/heads/master Commit: a4beb18a6ec02c8ec06eb6e224def16cab43726f Parents: 4936291 Author: Clebert Suconic <[email protected]> Authored: Thu Mar 16 18:03:54 2017 -0400 Committer: Clebert Suconic <[email protected]> Committed: Thu Mar 16 18:11:57 2017 -0400 ---------------------------------------------------------------------- .../activemq/artemis/protocol/amqp/broker/AMQPSessionCallback.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/a4beb18a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPSessionCallback.java ---------------------------------------------------------------------- diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPSessionCallback.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPSessionCallback.java index fb355ff..7f7e22b 100644 --- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPSessionCallback.java +++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPSessionCallback.java @@ -404,7 +404,7 @@ public class AMQPSessionCallback implements SessionCallback { delivery.disposition(Accepted.getInstance()); delivery.settle(); } - connection.flush(true); + connection.flush(); } @Override
