Reimplemented using native PHP AMQP library.