Added ControlMessageDecoder and Encoder for ActiveMQ