From 67087a6a7e47315d7a93e3cb8c0b6689d2f04271 Mon Sep 17 00:00:00 2001 From: andsel Date: Tue, 22 Sep 2015 15:52:12 +0200 Subject: [PATCH] Minor changes --- .../org/eclipse/moquette/server/netty/NettyAcceptor.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/broker/src/main/java/org/eclipse/moquette/server/netty/NettyAcceptor.java b/broker/src/main/java/org/eclipse/moquette/server/netty/NettyAcceptor.java index 80e37d1d..d22487db 100644 --- a/broker/src/main/java/org/eclipse/moquette/server/netty/NettyAcceptor.java +++ b/broker/src/main/java/org/eclipse/moquette/server/netty/NettyAcceptor.java @@ -252,7 +252,7 @@ public class NettyAcceptor implements ServerAcceptor { pipeline.addLast("httpEncoder", new HttpResponseEncoder()); pipeline.addLast("httpDecoder", new HttpRequestDecoder()); pipeline.addLast("aggregator", new HttpObjectAggregator(65536)); - pipeline.addLast("webSocketHandler", new WebSocketServerProtocolHandler("/mqtt", "mqttv3.1, mqttv3.1.1")); + pipeline.addLast("webSocketHandler", new WebSocketServerProtocolHandler("/mqtt", "mqtt mqttv3.1, mqttv3.1.1")); pipeline.addLast("ws2bytebufDecoder", new WebSocketFrameToByteBufDecoder()); pipeline.addLast("bytebuf2wsEncoder", new ByteBufToWebSocketFrameEncoder()); pipeline.addFirst("idleStateHandler", new IdleStateHandler(0, 0, Constants.DEFAULT_CONNECT_TIMEOUT)); @@ -371,8 +371,7 @@ public class NettyAcceptor implements ServerAcceptor { public ChannelHandler create() { SSLEngine sslEngine = sslContext.createSSLEngine(); sslEngine.setUseClientMode(false); - SslHandler sslHandler = new SslHandler(sslEngine); - return sslHandler; + return new SslHandler(sslEngine); } }