activemq-artemis git commit: ARTEMIS-1044 Avoiding StackOverflow on AMQP under load

Previous Topic Next Topic
 
classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

activemq-artemis git commit: ARTEMIS-1044 Avoiding StackOverflow on AMQP under load

clebertsuconic-2
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 <[hidden email]>
Authored: Thu Mar 16 18:03:54 2017 -0400
Committer: Clebert Suconic <[hidden email]>
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

Loading...