Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-1287/ARTEMIS-1292 Fixing intermittent failure on reconnects

This commit is contained in:
Clebert Suconic 2017-07-17 09:11:39 -04:00
parent de4ea0f84f
commit 41a03de02f
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/ServerSessionPacketHandler.java
View File

@ -180,8 +180,11 @@ public class ServerSessionPacketHandler implements ChannelHandler {
this.callExecutor = server.getExecutorFactory().getExecutor();
// TODO: I wish I could figure out how to create this through OrderedExecutor
this.packetActor = new Actor<>(server.getThreadPool(), this::onMessagePacket);
// In an optimized way packetActor should use the threadPool as the parent executor
// directly from server.getThreadPool();
// However due to how transferConnection is handled we need to
// use the same executor
this.packetActor = new Actor<>(callExecutor, this::onMessagePacket);
if (conn instanceof NettyConnection) {
direct = ((NettyConnection) conn).isDirectDeliver();