When you call createMessageStreams() in ConsumerConnector, you can pass in a decoder.
Thanks, Jun On Tue, Nov 6, 2012 at 4:24 AM, Hussein Baghdadi <hubaghd...@hotmail.com>wrote: > > Hi, > Foe the sender, I wrote a encoder for MessagePack. Why the consumer > doesn't need the accompanying decoder? > Thanks.
