From e75a679dec01408ec9295b3eb505045fc2a773c9 Mon Sep 17 00:00:00 2001
From: Clebert Suconic <clebertsuconic@apache.org>
Date: Fri, 20 Nov 2020 10:42:05 -0500
Subject: [PATCH] ARTEMIS-2985 Ordered Executor not needed on Actor

The Actor is already an ordered executor. No need to create one here.
---
 .../artemis/core/protocol/mqtt/MQTTProtocolHandler.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTProtocolHandler.java b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTProtocolHandler.java
index 545d34f97e..d34ade5180 100644
--- a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTProtocolHandler.java
+++ b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTProtocolHandler.java
@@ -71,7 +71,7 @@ public class MQTTProtocolHandler extends ChannelInboundHandlerAdapter {
    public MQTTProtocolHandler(ActiveMQServer server, MQTTProtocolManager protocolManager) {
       this.server = server;
       this.protocolManager = protocolManager;
-      this.mqttMessageActor = new Actor<>(server.getExecutorFactory().getExecutor(), this::act);
+      this.mqttMessageActor = new Actor<>(server.getThreadPool(), this::act);
    }
 
    void setConnection(MQTTConnection connection, ConnectionEntry entry) throws Exception {