AMQP

Table of Contents

The AMQPConnection class

Introduction

Represents a connection to an AMQP broker.

Class synopsis

AMQPConnection
class AMQPConnection {
/* Methods */
public bool connect ( void )
public __construct ([ array $credentials = array() ] )
public bool disconnect ( void )
public string getHost ( void )
public string getLogin ( void )
public string getPassword ( void )
public int getPort ( void )
public int getTimeout ( void )
public string getVhost ( void )
public bool isConnected ( void )
public bool reconnect ( void )
public bool setHost ( string $host )
public bool setLogin ( string $login )
public bool setPassword ( string $password )
public bool setPort ( int $port )
public bool setTimeout ( float $timeout )
public bool setVhost ( string $vhost )
}

The AMQPChannel class

Introduction

Represents a channel on an connection. Each connection can have multiple channels.

Class synopsis

AMQPChannel
class AMQPChannel {
/* Methods */
public void commitTransaction ( void )
__construct ( AMQPConnection $amqp_connection )
public void isConnected ( void )
public void qos ( int $size , int $count )
public void rollbackTransaction ( void )
public void setPrefetchCount ( int $count )
public void setPrefetchSize ( int $size )
public void startTransaction ( void )
}

The AMQPExchange class

Introduction

Represents an AMQP exchange.

Class synopsis

AMQPExchange
class AMQPExchange {
/* Methods */
public bool bind ( string $destination_exchange_name , string $source_exchange_name , string $routing_key )
public __construct ( AMQPChannel $amqp_channel )
public int declare ( void )
public bool delete ([ int $flags = AMQP_NOPARAM ] )
public mixed getArgument ( string $key )
public array getArguments ( void )
public int getFlags ( void )
public string getName ( void )
public string getType ( void )
public bool publish ( string $message , string $routing_key [, int $flags = AMQP_NOPARAM [, array $attributes = array() ]] )
public void setArgument ( string $key , mixed $value )
public void setArguments ( array $arguments )
public void setFlags ( int $flags )
public void setName ( string $exchange_name )
public string setType ( string $exchange_type )
}

The AMQPQueue class

Introduction

Represents an AMQP queue.

Class synopsis

AMQPQueue
class AMQPQueue {
/* Methods */
public bool ack ( int $delivery_tag [, int $flags = AMQP_NOPARAM ] )
public bool bind ( string $exchange_name , string $routing_key )
public bool cancel ([ string $consumer_tag = "" ] )
public __construct ( AMQPChannel $amqp_channel )
public void consume ( callable $callback [, int $flags = AMQP_NOPARAM ] )
public int declare ( void )
publicbool delete ( void )
public mixed get ([ int $flags = ini_get("amqp.auto_ack") ] )
public mixed getArgument ( string $key )
public array getArguments ( void )
public int getFlags ( void )
public string getName ( void )
public void nack ( string $delivery_tag [, string $flags = AMQP_NOPARAM ] )
public bool purge ( void )
public void setArgument ( string $key , mixed $value )
public void setArguments ( array $arguments )
public void setFlags ( int $flags )
public void setName ( string $queue_name )
public bool unbind ( string $exchange_name , string $routing_key )
}

The AMQPEnvelope class

Introduction

Contains a message and all of its attributes.

Class synopsis

AMQPEnvelope
class AMQPEnvelope {
/* Methods */
public string getAppId ( void )
public string getBody ( void )
public string getContentEncoding ( void )
public string getContentType ( void )
public string getCorrelationId ( void )
public string getDeliveryTag ( void )
public string getExchange ( void )
public string getExpiration ( void )
public string getHeader ( string $header_key )
public array getHeaders ( void )
public string getMessageId ( void )
public string getPriority ( void )
public string getReplyTo ( void )
public string getRoutingKey ( void )
public string getTimeStamp ( void )
public string getType ( void )
public string getUserId ( void )
public bool isRedelivery ( void )
}