use ifroz' amqp-rpc fork.