Connection
class Connection
An AMQP connection.
Methods
__construct(array $connectionCredentials, array $exchangeConfiguration, array $queueConfiguration, bool $debug = false, AmqpFactory $amqpFactory = null) | ||
static Connection | fromDsn(string $dsn, array $options = array(), bool $debug = false, AmqpFactory $amqpFactory = null) | |
void | publish(string $body, array $headers = array()) | |
AMQPEnvelope|null | get() Waits and gets a message from the configured queue. | |
bool | ack(AMQPEnvelope $message) | |
bool | reject(AMQPEnvelope $message) | |
bool | nack(AMQPEnvelope $message, int $flags = AMQP_NOPARAM) | |
void | setup() | |
AMQPChannel | channel() | |
AMQPQueue | queue() | |
AMQPExchange | exchange() | |
array | getConnectionCredentials() |
Details
__construct(array $connectionCredentials, array $exchangeConfiguration, array $queueConfiguration, bool $debug = false, AmqpFactory $amqpFactory = null)
Parameters
array | $connectionCredentials | |
array | $exchangeConfiguration | |
array | $queueConfiguration | |
bool | $debug | |
AmqpFactory | $amqpFactory |
static Connection fromDsn(string $dsn, array $options = array(), bool $debug = false, AmqpFactory $amqpFactory = null)
Parameters
string | $dsn | |
array | $options | |
bool | $debug | |
AmqpFactory | $amqpFactory |
Return Value
Connection |
void publish(string $body, array $headers = array())
Parameters
string | $body | |
array | $headers |
Return Value
void |
Exceptions
AMQPException |
AMQPEnvelope|null get()
Waits and gets a message from the configured queue.
Return Value
AMQPEnvelope|null |
Exceptions
AMQPException |
bool ack(AMQPEnvelope $message)
Parameters
AMQPEnvelope | $message |
Return Value
bool |
bool reject(AMQPEnvelope $message)
Parameters
AMQPEnvelope | $message |
Return Value
bool |
bool nack(AMQPEnvelope $message, int $flags = AMQP_NOPARAM)
Parameters
AMQPEnvelope | $message | |
int | $flags |
Return Value
bool |
void setup()
Return Value
void |
AMQPChannel channel()
Return Value
AMQPChannel |
AMQPQueue queue()
Return Value
AMQPQueue |
AMQPExchange exchange()
Return Value
AMQPExchange |
array getConnectionCredentials()
Return Value
array |
© 2004–2017 Fabien Potencier
Licensed under the MIT License.
https://api.symfony.com/4.1/Symfony/Component/Messenger/Transport/AmqpExt/Connection.html