Подключение

__construct(array $connectionCredentials, array $exchangeConfiguration, array $queueConfiguration, bool $debug = false, AmqpFactory $amqpFactory = null)

Параметры

array	$connectionCredentials
array	$exchangeConfiguration
array	$queueConfiguration
bool	$debug
AmqpFactory	$amqpFactory

static Подключение fromDsn(string $dsn, array $options = array(), bool $debug = false, AmqpFactory $amqpFactory = null)

Параметры

string	$dsn
array	$options
bool	$debug
AmqpFactory	$amqpFactory

Возвращаемое значение

Подключение

void publish(string $body, array $headers = array())

Параметры

string	$body
array	$headers

Возвращаемое значение

void

Исключения

AMQPException

AMQPEnvelope|null get()

Ожидает и получает сообщение из настроенной очереди.

Возвращаемое значение

AMQPEnvelope|null

Исключения

AMQPException

bool ack(AMQPEnvelope $message)

Параметры

AMQPEnvelope

$message

Возвращаемое значение

bool

bool reject(AMQPEnvelope $message)

Параметры

AMQPEnvelope

$message

Возвращаемое значение

bool

bool nack(AMQPEnvelope $message, int $flags = AMQP_NOPARAM)

Параметры

AMQPEnvelope	$message
int	$flags

Возвращаемое значение

bool

void setup()

Возвращаемое значение

void

AMQPChannel channel()

Возвращаемое значение

AMQPChannel

AMQPQueue queue()

Возвращаемое значение

AMQPQueue

AMQPExchange exchange()

Возвращаемое значение

AMQPExchange

array getConnectionCredentials()

Возвращаемое значение

array