heka amqp changes