Pass keyDecoder and msgDecoder into connector.createMessageStreams
Merge pull request #1 from kelvl/master

Pass keyDecoder and msgDecoder into connector.createMessageStreams