A bridge between amqp queues and socket channels