AMQPExchange::publish
AMQPQueue::ack
AMQP
PHP Manual
The AMQPQueue class
Introduction
Represents an AMQP queue.
Class synopsis
AMQPQueue
{
/* Methods */
public
bool
ack
(
int
$delivery_tag
[,
int
$flags
= NULL
] )
public
bool
bind
(
string
$exchange_name
,
string
$routing_key
)
public
bool
cancel
([
string
$consumer_tag
= ""
] )
__construct
(
AMQPConnection
$amqp_connection
[,
string
$queue_name
= ""
] )
public
array
consume
([
array
$options
= array()
] )
public
int
declare
([
string
$queue_name
= ""
[,
int
$flags
=
AMQP_AUTODELETE
]] )
public
bool
delete
(
string
$queue_name
)
public
array
get
([
int
$flags
=
AMQP_NOACK
] )
public
bool
purge
(
string
$queue_name
)
public
bool
unbind
(
string
$exchange_name
,
string
$routing_key
)
}
Table of Contents
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
— The consume purpose
AMQPQueue::declare
— Declare a new queue
AMQPQueue::delete
— Delete a queue and its contents.
AMQPQueue::get
— Retrieve the next message from the queue.
AMQPQueue::purge
— Purge the contents of a queue
AMQPQueue::unbind
— Unbind the queue from a routing key.
AMQPExchange::publish
AMQPQueue::ack
AMQP
PHP Manual