AMQP

• Введение
• Установка и настройка
  • Требования
  • Установка
  • Настройка во время выполнения
  • Типы ресурсов
• Предопределенные константы
• Примеры
• AMQPConnection — Класс AMQPConnection
  • AMQPConnection::connect — Установить соединение с брокером AMQP
  • AMQPConnection::__construct — Создать новый экземпляр AMQPConnection
  • AMQPConnection::disconnect — Закрыть соединение с брокером AMQP
  • AMQPConnection::getHost — Get the configured host
  • AMQPConnection::getLogin — Get the configured login
  • AMQPConnection::getPassword — Get the configured password
  • AMQPConnection::getPort — Get the configured port
  • AMQPConnection::getTimeout — Get the configured timeout
  • AMQPConnection::getVhost — Get the configured vhost
  • AMQPConnection::isConnected — Определить, подключен ли объект AMQPConnection к брокеру
  • AMQPConnection::reconnect — Закрыть все открытые соединения и создать новое соединение с брокером AMQP
  • AMQPConnection::setHost — Установить хост AMPQ
  • AMQPConnection::setLogin — Установить логин
  • AMQPConnection::setPassword — Установить пароль
  • AMQPConnection::setPort — Установить порт AMPQ
  • AMQPConnection::setTimeout — Set the timeout.
  • AMQPConnection::setVhost — Установить виртуальный хост AMQP
• AMQPChannel — Класс AMQPChannel
  • AMQPChannel::commitTransaction — Commit a pending transaction
  • AMQPChannel::__construct — Create an instance of an AMQPChannel object
  • AMQPChannel::isConnected — Check the channel connection
  • AMQPChannel::qos — Set the Quality Of Service settings for the given channel
  • AMQPChannel::rollbackTransaction — Rollback a transaction
  • AMQPChannel::setPrefetchCount — Set the number of messages to prefetch from the broker
  • AMQPChannel::setPrefetchSize — Set the window size to prefetch from the broker
  • AMQPChannel::startTransaction — Start a transaction
• AMQPExchange — Класс AMQPExchange
  • AMQPExchange::bind — Привязка к другому обменнику
  • AMQPExchange::__construct — Создает экземпляр AMQPExchange
  • AMQPExchange::declare — Declare a new exchange on the broker.
  • AMQPExchange::delete — Удалить обменник из брокера
  • AMQPExchange::getArgument — Get the argument associated with the given key
  • AMQPExchange::getArguments — Get all arguments set on the given exchange
  • AMQPExchange::getFlags — Get the flag bitmask
  • AMQPExchange::getName — Get the configured name
  • AMQPExchange::getType — Get the configured type
  • AMQPExchange::publish — Опубликовать сообщение в обменнике
  • AMQPExchange::setArgument — Set the value for the given key
  • AMQPExchange::setArguments — Set all arguments on the exchange
  • AMQPExchange::setFlags — Set the flags on an exchange
  • AMQPExchange::setName — Set the name of the exchange
  • AMQPExchange::setType — Set the type of the exchange
• AMQPQueue — Класс AMQPQueue
  • AMQPQueue::ack — Подтвердить получение сообщения
  • AMQPQueue::bind — Связать данную очередь с ключом маршрутизации на обменнике
  • AMQPQueue::cancel — Отменить привязку очереди
  • AMQPQueue::__construct — Создать экземпляр объекта AMQPQueue
  • AMQPQueue::consume — Использовать сообщения из очереди
  • AMQPQueue::declare — Declare a new queue
  • AMQPQueue::delete — Удалить очередь и её содержимое
  • AMQPQueue::get — Получить следующее сообщение из очереди
  • AMQPQueue::getArgument — Get the argument associated with the given key
  • AMQPQueue::getArguments — Get all arguments set on the given queue
  • AMQPQueue::getFlags — Get the flag bitmask
  • AMQPQueue::getName — Get the configured name
  • AMQPQueue::nack — Mark a message as explicitly not acknowledged.
  • AMQPQueue::purge — Очистить содержимое очереди
  • AMQPQueue::setArgument — Set the value for the given key
  • AMQPQueue::setArguments — Set all arguments on the queue
  • AMQPQueue::setFlags — Set the queue flags
  • AMQPQueue::setName — Set the queue name
  • AMQPQueue::unbind — Удалить привязку очереди к ключу маршрутизации
• AMQPEnvelope — The AMQPEnvelope class
  • AMQPEnvelope::getAppId — Get the message appid
  • AMQPEnvelope::getBody — Get the message body
  • AMQPEnvelope::getContentEncoding — Get the message contentencoding
  • AMQPEnvelope::getContentType — Get the message contenttype
  • AMQPEnvelope::getCorrelationId — Get the message correlation id
  • AMQPEnvelope::getDeliveryTag — Get the message delivery tag
  • AMQPEnvelope::getExchange — Get the message exchange
  • AMQPEnvelope::getExpiration — Get the message expiration
  • AMQPEnvelope::getHeader — Get a specific message header
  • AMQPEnvelope::getHeaders — Get the message headers
  • AMQPEnvelope::getMessageId — Get the message id
  • AMQPEnvelope::getPriority — Get the message priority
  • AMQPEnvelope::getReplyTo — Get the message replyto
  • AMQPEnvelope::getRoutingKey — Get the message routing key
  • AMQPEnvelope::getTimeStamp — Get the message timestamp
  • AMQPEnvelope::getType — Get the message type
  • AMQPEnvelope::getUserId — Get the message user id
  • AMQPEnvelope::isRedelivery — Whether this is a redelivery of the message