That is what the MultiDecoder was created for https://github.com/mozilla-services/heka/issues/307

Issue https://github.com/mozilla-services/heka/issues/308 should have called out AMQP too.