You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jg...@apache.org on 2018/07/16 02:11:18 UTC
activemq git commit: [AMQ-7011] Override dispatch to always set
dispatchAsync true
Repository: activemq
Updated Branches:
refs/heads/master 2b64b7b04 -> 46160c7b7
[AMQ-7011] Override dispatch to always set dispatchAsync true
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/46160c7b
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/46160c7b
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/46160c7b
Branch: refs/heads/master
Commit: 46160c7b7f66d9d5dda05d2e2dc45e993d3cc48e
Parents: 2b64b7b
Author: jgoodyear <ja...@gmail.com>
Authored: Sun Jul 15 15:20:45 2018 -0230
Committer: Jeff Genender <jg...@savoirtech.com>
Committed: Sun Jul 15 20:10:45 2018 -0600
----------------------------------------------------------------------
.../java/org/apache/activemq/transport/stomp/ProtocolConverter.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/46160c7b/activemq-stomp/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java
----------------------------------------------------------------------
diff --git a/activemq-stomp/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java b/activemq-stomp/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java
index b25860b..22e63a1 100644
--- a/activemq-stomp/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java
+++ b/activemq-stomp/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java
@@ -611,6 +611,7 @@ public class ProtocolConverter {
}
consumerInfo.setDestination(actualDest);
+ consumerInfo.setDispatchAsync(true);
StompSubscription stompSubscription;
if (!consumerInfo.isBrowser()) {