Utilities to use amqp with the pipes library.