The AMQP input was only expected to accept protobuf serialized, or plain text messages. If you use 'plain-text' then you're expected to decode them yourself.