Hi, returing back to this issue. If I use qos=1/2, artemis hangs after the same amount of messages, but will not log messages. I cannot see anything other than this being an netty issue.
Complete mem leak oputput: 12:18:06,640 ERROR [io.netty.util.ResourceLeakDetector] LEAK: ByteBuf.release() was not called before it's garbage-collected. See http://netty.io/wiki/reference-counted-objects.html for more information. Recent access records: 18 #18: Hint: 'MQTTProtocolHandler#0' will handle the message from this point. io.netty.handler.codec.mqtt.MqttPublishMessage.touch(MqttPublishMessage.java:99) io.netty.handler.codec.mqtt.MqttPublishMessage.touch(MqttPublishMessage.java:26) io.netty.channel.DefaultChannelPipeline.touch(DefaultChannelPipeline.java:107) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:267) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #17: io.netty.buffer.AdvancedLeakAwareByteBuf.release(AdvancedLeakAwareByteBuf.java:955) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:256) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #16: io.netty.buffer.AdvancedLeakAwareByteBuf.readRetainedSlice(AdvancedLeakAwareByteBuf.java:117) io.netty.handler.codec.ReplayingDecoderByteBuf.readRetainedSlice(ReplayingDecoderByteBuf.java:589) io.netty.handler.codec.mqtt.MqttDecoder.decodePublishPayload(MqttDecoder.java:416) io.netty.handler.codec.mqtt.MqttDecoder.decodePayload(MqttDecoder.java:323) io.netty.handler.codec.mqtt.MqttDecoder.decode(MqttDecoder.java:96) io.netty.handler.codec.ReplayingDecoder.callDecode(ReplayingDecoder.java:367) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #15: io.netty.buffer.AdvancedLeakAwareByteBuf.writeBytes(AdvancedLeakAwareByteBuf.java:591) io.netty.handler.codec.ByteToMessageDecoder$1.cumulate(ByteToMessageDecoder.java:92) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:246) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #14: io.netty.buffer.AdvancedLeakAwareByteBuf.discardSomeReadBytes(AdvancedLeakAwareByteBuf.java:129) io.netty.handler.codec.ByteToMessageDecoder.discardSomeReadBytes(ByteToMessageDecoder.java:319) io.netty.handler.codec.ByteToMessageDecoder.channelReadComplete(ByteToMessageDecoder.java:300) io.netty.channel.AbstractChannelHandlerContext.invokeChannelReadComplete(AbstractChannelHandlerContext.java:409) io.netty.channel.AbstractChannelHandlerContext.invokeChannelReadComplete(AbstractChannelHandlerContext.java:391) io.netty.channel.AbstractChannelHandlerContext.fireChannelReadComplete(AbstractChannelHandlerContext.java:384) io.netty.channel.DefaultChannelPipeline$HeadContext.channelReadComplete(DefaultChannelPipeline.java:1339) io.netty.channel.AbstractChannelHandlerContext.invokeChannelReadComplete(AbstractChannelHandlerContext.java:409) io.netty.channel.AbstractChannelHandlerContext.invokeChannelReadComplete(AbstractChannelHandlerContext.java:391) io.netty.channel.DefaultChannelPipeline.fireChannelReadComplete(DefaultChannelPipeline.java:932) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #13: io.netty.buffer.AdvancedLeakAwareByteBuf.discardSomeReadBytes(AdvancedLeakAwareByteBuf.java:129) io.netty.handler.codec.ByteToMessageDecoder.discardSomeReadBytes(ByteToMessageDecoder.java:319) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:262) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #12: io.netty.buffer.AdvancedLeakAwareByteBuf.writeBytes(AdvancedLeakAwareByteBuf.java:591) io.netty.handler.codec.ByteToMessageDecoder$1.cumulate(ByteToMessageDecoder.java:92) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:246) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #11: io.netty.buffer.AdvancedLeakAwareByteBuf.readUnsignedByte(AdvancedLeakAwareByteBuf.java:405) io.netty.handler.codec.ReplayingDecoderByteBuf.readUnsignedByte(ReplayingDecoderByteBuf.java:523) io.netty.handler.codec.mqtt.MqttDecoder.decodeMsbLsb(MqttDecoder.java:456) io.netty.handler.codec.mqtt.MqttDecoder.decodeMsbLsb(MqttDecoder.java:451) io.netty.handler.codec.mqtt.MqttDecoder.decodeMessageId(MqttDecoder.java:288) io.netty.handler.codec.mqtt.MqttDecoder.decodePublishVariableHeader(MqttDecoder.java:278) io.netty.handler.codec.mqtt.MqttDecoder.decodeVariableHeader(MqttDecoder.java:196) io.netty.handler.codec.mqtt.MqttDecoder.decode(MqttDecoder.java:85) io.netty.handler.codec.ReplayingDecoder.callDecode(ReplayingDecoder.java:367) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #10: io.netty.buffer.AdvancedLeakAwareByteBuf.readUnsignedByte(AdvancedLeakAwareByteBuf.java:405) io.netty.handler.codec.ReplayingDecoderByteBuf.readUnsignedByte(ReplayingDecoderByteBuf.java:523) io.netty.handler.codec.mqtt.MqttDecoder.decodeMsbLsb(MqttDecoder.java:455) io.netty.handler.codec.mqtt.MqttDecoder.decodeMsbLsb(MqttDecoder.java:451) io.netty.handler.codec.mqtt.MqttDecoder.decodeMessageId(MqttDecoder.java:288) io.netty.handler.codec.mqtt.MqttDecoder.decodePublishVariableHeader(MqttDecoder.java:278) io.netty.handler.codec.mqtt.MqttDecoder.decodeVariableHeader(MqttDecoder.java:196) io.netty.handler.codec.mqtt.MqttDecoder.decode(MqttDecoder.java:85) io.netty.handler.codec.ReplayingDecoder.callDecode(ReplayingDecoder.java:367) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #9: io.netty.buffer.AdvancedLeakAwareByteBuf.skipBytes(AdvancedLeakAwareByteBuf.java:531) io.netty.handler.codec.ReplayingDecoderByteBuf.skipBytes(ReplayingDecoderByteBuf.java:850) io.netty.handler.codec.mqtt.MqttDecoder.decodeString(MqttDecoder.java:445) io.netty.handler.codec.mqtt.MqttDecoder.decodeString(MqttDecoder.java:421) io.netty.handler.codec.mqtt.MqttDecoder.decodePublishVariableHeader(MqttDecoder.java:270) io.netty.handler.codec.mqtt.MqttDecoder.decodeVariableHeader(MqttDecoder.java:196) io.netty.handler.codec.mqtt.MqttDecoder.decode(MqttDecoder.java:85) io.netty.handler.codec.ReplayingDecoder.callDecode(ReplayingDecoder.java:367) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #8: io.netty.buffer.AdvancedLeakAwareByteBuf.toString(AdvancedLeakAwareByteBuf.java:747) io.netty.handler.codec.ReplayingDecoderByteBuf.toString(ReplayingDecoderByteBuf.java:912) io.netty.handler.codec.mqtt.MqttDecoder.decodeString(MqttDecoder.java:444) io.netty.handler.codec.mqtt.MqttDecoder.decodeString(MqttDecoder.java:421) io.netty.handler.codec.mqtt.MqttDecoder.decodePublishVariableHeader(MqttDecoder.java:270) io.netty.handler.codec.mqtt.MqttDecoder.decodeVariableHeader(MqttDecoder.java:196) io.netty.handler.codec.mqtt.MqttDecoder.decode(MqttDecoder.java:85) io.netty.handler.codec.ReplayingDecoder.callDecode(ReplayingDecoder.java:367) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #7: io.netty.buffer.AdvancedLeakAwareByteBuf.readUnsignedByte(AdvancedLeakAwareByteBuf.java:405) io.netty.handler.codec.ReplayingDecoderByteBuf.readUnsignedByte(ReplayingDecoderByteBuf.java:523) io.netty.handler.codec.mqtt.MqttDecoder.decodeMsbLsb(MqttDecoder.java:456) io.netty.handler.codec.mqtt.MqttDecoder.decodeMsbLsb(MqttDecoder.java:451) io.netty.handler.codec.mqtt.MqttDecoder.decodeString(MqttDecoder.java:436) io.netty.handler.codec.mqtt.MqttDecoder.decodeString(MqttDecoder.java:421) io.netty.handler.codec.mqtt.MqttDecoder.decodePublishVariableHeader(MqttDecoder.java:270) io.netty.handler.codec.mqtt.MqttDecoder.decodeVariableHeader(MqttDecoder.java:196) io.netty.handler.codec.mqtt.MqttDecoder.decode(MqttDecoder.java:85) io.netty.handler.codec.ReplayingDecoder.callDecode(ReplayingDecoder.java:367) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #6: io.netty.buffer.AdvancedLeakAwareByteBuf.readUnsignedByte(AdvancedLeakAwareByteBuf.java:405) io.netty.handler.codec.ReplayingDecoderByteBuf.readUnsignedByte(ReplayingDecoderByteBuf.java:523) io.netty.handler.codec.mqtt.MqttDecoder.decodeMsbLsb(MqttDecoder.java:455) io.netty.handler.codec.mqtt.MqttDecoder.decodeMsbLsb(MqttDecoder.java:451) io.netty.handler.codec.mqtt.MqttDecoder.decodeString(MqttDecoder.java:436) io.netty.handler.codec.mqtt.MqttDecoder.decodeString(MqttDecoder.java:421) io.netty.handler.codec.mqtt.MqttDecoder.decodePublishVariableHeader(MqttDecoder.java:270) io.netty.handler.codec.mqtt.MqttDecoder.decodeVariableHeader(MqttDecoder.java:196) io.netty.handler.codec.mqtt.MqttDecoder.decode(MqttDecoder.java:85) io.netty.handler.codec.ReplayingDecoder.callDecode(ReplayingDecoder.java:367) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #5: io.netty.buffer.AdvancedLeakAwareByteBuf.readUnsignedByte(AdvancedLeakAwareByteBuf.java:405) io.netty.handler.codec.ReplayingDecoderByteBuf.readUnsignedByte(ReplayingDecoderByteBuf.java:523) io.netty.handler.codec.mqtt.MqttDecoder.decodeFixedHeader(MqttDecoder.java:156) io.netty.handler.codec.mqtt.MqttDecoder.decode(MqttDecoder.java:76) io.netty.handler.codec.ReplayingDecoder.callDecode(ReplayingDecoder.java:367) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #4: io.netty.buffer.AdvancedLeakAwareByteBuf.readUnsignedByte(AdvancedLeakAwareByteBuf.java:405) io.netty.handler.codec.ReplayingDecoderByteBuf.readUnsignedByte(ReplayingDecoderByteBuf.java:523) io.netty.handler.codec.mqtt.MqttDecoder.decodeFixedHeader(MqttDecoder.java:144) io.netty.handler.codec.mqtt.MqttDecoder.decode(MqttDecoder.java:76) io.netty.handler.codec.ReplayingDecoder.callDecode(ReplayingDecoder.java:367) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #3: Hint: 'MqttDecoder#0' will handle the message from this point. io.netty.channel.DefaultChannelPipeline.touch(DefaultChannelPipeline.java:107) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #2: Hint: 'DefaultChannelPipeline$HeadContext#0' will handle the message from this point. io.netty.channel.DefaultChannelPipeline.touch(DefaultChannelPipeline.java:107) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) #1: io.netty.buffer.AdvancedLeakAwareByteBuf.writeBytes(AdvancedLeakAwareByteBuf.java:633) io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:366) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:118) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) Created at: io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:271) io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:179) io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:170) io.netty.buffer.AbstractByteBufAllocator.ioBuffer(AbstractByteBufAllocator.java:131) io.netty.channel.DefaultMaxMessagesRecvByteBufAllocator$MaxMessageHandle.allocate(DefaultMaxMessagesRecvByteBufAllocator.java:73) io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:117) io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:651) io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:574) io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:488) io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:450) io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873) java.lang.Thread.run(Thread.java:748) /hw -- View this message in context: http://activemq.2283324.n4.nabble.com/artemis-2-1-0-logging-disaster-tp4726922p4727533.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
