AMQPTable of Contents
The AMQPConnection classIntroductionRepresents a connection to an AMQP broker. Class synopsisAMQPConnection
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 classIntroductionRepresents a channel on an connection. Each connection can have multiple channels. Class synopsisAMQPChannel
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 classIntroductionRepresents an AMQP exchange. Class synopsisAMQPExchange
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 classIntroductionRepresents an AMQP queue. Class synopsisAMQPQueue
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 classIntroductionContains a message and all of its attributes. Class synopsisAMQPEnvelope
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
)
} |