You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2017/03/16 22:16:15 UTC
activemq-artemis git commit: ARTEMIS-1044 Avoiding StackOverflow on
AMQP under load
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 <cl...@apache.org>
Authored: Thu Mar 16 18:03:54 2017 -0400
Committer: Clebert Suconic <cl...@apache.org>
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