Make the rpc emit events and use durable queues