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:36:29 UTC
activemq git commit: [AMQ-7011] Override dispatch to always set
dispatchAsync true [Forced Update!]
Repository: activemq
Updated Branches:
refs/heads/activemq-5.15.x 43fd31c10 -> a1e5b970d (forced update)
[AMQ-7011] Override dispatch to always set dispatchAsync true
This closes #287
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/a1e5b970
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/a1e5b970
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/a1e5b970
Branch: refs/heads/activemq-5.15.x
Commit: a1e5b970d81d21daed277a08098f7fddf017c606
Parents: 3397a97
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:35:18 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/a1e5b970/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()) {