Pass keyDecoder and msgDecoder into connector.createMessageStreams

KeyDecoder and MsgDecoder from props was not passed into createMessageStreams, resulting in messages to only be decoded as Array[Byte]