AMQPExchange::publish
AMQPQueue::ack
AMQP
PHP Manual
The AMQPQueue class
Introduction
Represents an AMQP queue.
Class synopsis
AMQPQueue
{
/* Methods */
public
void
ack
(
int
$delivery_tag
[,
int
$flags
= NULL
] )
public
void
bind
(
string
$exchange_name
[,
string
$routing_key
= ""
] )
public
void
cancel
(
string
$consumer_tag
)
__construct
(
string
$amqp_connection
[,
string
$queue_name
= ""
] )
public
void
consume
(
string
$num_messages
[,
string
$flags
= NULL
] )
public
void
declare
(
string
$queue_name
[,
int
$flags
=
AMQP_AUTODELETE
] )
public
void
delete
(
string
$queue_name
)
public
void
get
(
string
$flags
)
public
void
purge
(
string
$queue_name
)
public
void
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