AMQP

• 简介
• 安装／配置
  • 需求
  • 安装
  • 运行时配置
  • 资源类型
• 预定义常量
• 范例
• AMQPConnection — The AMQPConnection class
  • AMQPConnection::connect — Establish a connection with the AMQP broker.
  • AMQPConnection::__construct — Create an instance of AMQPConnection
  • AMQPConnection::disconnect — Closes the connection with the AMQP broker.
  • 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 — Determine if the AMQPConnection object is connected to the broker.
  • AMQPConnection::reconnect — Closes any open connection and creates a new connection with the AMQP broker.
  • AMQPConnection::setHost — Set the amqp host.
  • AMQPConnection::setLogin — Set the login.
  • AMQPConnection::setPassword — Set the password.
  • AMQPConnection::setPort — Set the port.
  • AMQPConnection::setTimeout — Set the timeout.
  • AMQPConnection::setVhost — Set the amqp virtual host
• AMQPChannel — The AMQPChannel class
  • 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 — The AMQPExchange class
  • AMQPExchange::bind — Bind to another exchange
  • AMQPExchange::__construct — Create an instance of AMQPExchange
  • AMQPExchange::declare — Declare a new exchange on the broker.
  • AMQPExchange::delete — Delete the exchange from the broker.
  • 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 — Publish a message to an exchange.
  • 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 — The AMQPQueue class
  • AMQPQueue::ack — Acknowledge the receipt of a message
  • AMQPQueue::bind — Bind the given queue to a routing key on an exchange.
  • AMQPQueue::cancel — Cancel a queue binding.
  • AMQPQueue::__construct — Create an instance of an AMQPQueue object
  • AMQPQueue::consume — Consume messages from a queue
  • AMQPQueue::declare — Declare a new queue
  • AMQPQueue::delete — Delete a queue and its contents.
  • AMQPQueue::get — Retrieve the next message from the queue.
  • 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 — Purge the contents of a queue
  • 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 — Unbind the queue from a routing key.
• 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