Connection
class Connection
An AMQP connection.
Methods
__construct(array $connectionCredentials, array $exchangeConfiguration, array $queueConfiguration, bool $debug = false, AmqpFactory $amqpFactory = null)
No description
static Connection
fromDsn(string $dsn, array $options = array(), bool $debug = false, AmqpFactory $amqpFactory = null)
No description
void
publish(string $body, array $headers = array())
No description
AMQPEnvelope|null
get()
Waits and gets a message from the configured queue.
bool
ack(AMQPEnvelope $message)
No description
bool
reject(AMQPEnvelope $message)
No description
bool
nack(AMQPEnvelope $message, int $flags = AMQP_NOPARAM)
No description
void
setup()
No description
AMQPChannel
channel()
No description
AMQPQueue
queue()
No description
AMQPExchange
exchange()
No description
array
getConnectionCredentials()
No description