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

ARTEMIS-2985 Ordered Executor not needed on Actor 

The Actor is already an ordered executor. No need to create one here.
This commit is contained in:
Clebert Suconic 2020-11-20 10:42:05 -05:00
parent 4f208ef4b1
commit e75a679dec
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTProtocolHandler.java
View File

@ -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 {