The ProtocolCodecFilter works on batches instead of stream based. You have
to be careful when you use it to ensure that you obtained all of the
processed messages. This could explain the dropped messages you are seeing.
On Sep 16, 2013 3:20 PM, "Karrys, Michael (IS)" wrote:
> Thanks. Knew it was
Thanks. Knew it was something simple. I added the following and it now works.
connector.getFilterChain().addLast(
"codec",
new ProtocolCodecFilter(
new ObjectSerializationCodecFactory()));
connector.getFilterChain().addLast("logger", n
