This is an automated email from the ASF dual-hosted git repository. clebertsuconic pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
commit 0db13ee8ab60a07aa0f90cdfcf4158d0c5b00d38 Author: Francesco Nigro <[email protected]> AuthorDate: Sat Jul 11 09:09:11 2020 +0200 ARTEMIS-2844 Use writeAndFlush with voidPromise to reduce GC pressure --- .../activemq/artemis/core/protocol/mqtt/MQTTProtocolHandler.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) 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 7266cd5..136ad7e 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 @@ -259,8 +259,7 @@ public class MQTTProtocolHandler extends ChannelInboundHandlerAdapter { return; } MQTTUtil.logMessage(session.getSessionState(), message, false); - ctx.write(message); - ctx.flush(); + ctx.writeAndFlush(message, ctx.voidPromise()); } private int getMessageId(MqttMessage message) {
