Documentation

ChannelsMethods

Table of Contents

Methods

basicAck()  : bool
send AMQP basic.ack frame
basicCancel()  : bool
send AMQP basic.cancel frame
basicConsume()  : bool
send AMQP basic.consume frame
basicGet()  : bool
send AMQP basic.get frame
basicNack()  : bool
send AMQP basic.nack frame
basicPublish()  : int|null
send AMQP basic.publish frame
basicQos()  : bool
send AMQP basic.qos frame
basicRecover()  : bool
send AMQP basic.recover frame
basicReject()  : bool
send AMQP basic.reject frame
channelClose()  : bool
send AMQP channel.close frame
channelCloseOk()  : bool
send AMQP channel.close-ok frame
channelFlow()  : bool
send AMQP channel.flow frame
channelFlowOk()  : bool
send AMQP channel.flow-ok frame
channelOpen()  : bool
send AMQP channel.open frame
confirmSelect()  : bool
send AMQP confirm.select frame
exchangeBind()  : bool|MethodExchangeBindOkFrame
send AMQP exchange.bind frame
exchangeDeclare()  : bool|MethodExchangeDeclareOkFrame
send AMQP exchange.declare frame
exchangeDelete()  : bool|MethodExchangeDeleteOkFrame
send AMQP exchange.delete frame
exchangeUnbind()  : bool|MethodExchangeUnbindOkFrame
send AMQP exchange.unbind frame
queueBind()  : bool|MethodQueueBindOkFrame
send AMQP queue.bind frame
queueDeclare()  : bool|MethodQueueDeclareOkFrame
send AMQP queue.declare frame
queueDelete()  : bool|MethodQueueDeleteOkFrame
send AMQP queue.delete frame
queuePurge()  : bool|MethodQueuePurgeOkFrame
send AMQP queue.purge frame
queueUnbind()  : bool
send AMQP queue.unbind frame
txCommit()  : bool
send AMQP tx.commit frame
txRollback()  : bool
send AMQP tx.rollback frame
txSelect()  : bool
send AMQP tx.select frame

Methods

basicAck()

send AMQP basic.ack frame

public basicAck(int $channel, int $deliveryTag[, bool $multiple = false ]) : bool
Parameters
$channel : int
$deliveryTag : int
$multiple : bool = false
Return values
bool

basicCancel()

send AMQP basic.cancel frame

public basicCancel(int $channel, string $consumerTag[, bool $nowait = false ]) : bool
Parameters
$channel : int
$consumerTag : string
$nowait : bool = false
Return values
bool

basicConsume()

send AMQP basic.consume frame

public basicConsume(int $channel[, string $queue = '' ][, string $consumerTag = '' ][, bool $noLocal = false ][, bool $noAck = false ][, bool $exclusive = false ][, bool $nowait = false ][, array<string|int, mixed> $arguments = [] ]) : bool
Parameters
$channel : int
$queue : string = ''
$consumerTag : string = ''
$noLocal : bool = false
$noAck : bool = false
$exclusive : bool = false
$nowait : bool = false
$arguments : array<string|int, mixed> = []
Return values
bool

basicGet()

send AMQP basic.get frame

public basicGet(int $channel[, string $queue = '' ][, bool $noAck = false ]) : bool
Parameters
$channel : int
$queue : string = ''
$noAck : bool = false
Return values
bool

basicNack()

send AMQP basic.nack frame

public basicNack(int $channel, int $deliveryTag[, bool $multiple = false ][, bool $requeue = false ]) : bool
Parameters
$channel : int
$deliveryTag : int
$multiple : bool = false
$requeue : bool = false
Return values
bool

basicPublish()

send AMQP basic.publish frame

public basicPublish(int $channel, string $exchange[, array<string|int, mixed> $headers = [] ][, string $body = '' ][, string $routingKey = '' ][, bool $mandatory = false ][, bool $immediate = false ]) : int|null
Parameters
$channel : int
$exchange : string
$headers : array<string|int, mixed> = []
$body : string = ''
$routingKey : string = ''
$mandatory : bool = false
$immediate : bool = false
Return values
int|null

basicQos()

send AMQP basic.qos frame

public basicQos(int $channel[, int $prefetchSize = 0 ][, int $prefetchCount = 0 ][, bool $global = false ]) : bool
Parameters
$channel : int
$prefetchSize : int = 0
$prefetchCount : int = 0
$global : bool = false
Return values
bool

basicRecover()

send AMQP basic.recover frame

public basicRecover(int $channel[, bool $requeue = false ]) : bool
Parameters
$channel : int
$requeue : bool = false
Return values
bool

basicReject()

send AMQP basic.reject frame

public basicReject(int $channel, int $deliveryTag[, bool $requeue = false ]) : bool
Parameters
$channel : int
$deliveryTag : int
$requeue : bool = false
Return values
bool

channelClose()

send AMQP channel.close frame

public channelClose(int $channel, int $replyCode, string $replyText, int $closeClassId, int $closeMethodId) : bool
Parameters
$channel : int
$replyCode : int
$replyText : string
$closeClassId : int
$closeMethodId : int
Return values
bool

channelCloseOk()

send AMQP channel.close-ok frame

public channelCloseOk(int $channel) : bool
Parameters
$channel : int
Return values
bool

channelFlow()

send AMQP channel.flow frame

public channelFlow(int $channel, bool $active) : bool
Parameters
$channel : int
$active : bool
Return values
bool

channelFlowOk()

send AMQP channel.flow-ok frame

public channelFlowOk(int $channel, bool $active) : bool
Parameters
$channel : int
$active : bool
Return values
bool

channelOpen()

send AMQP channel.open frame

public channelOpen(int $channel[, string $outOfBand = '' ]) : bool
Parameters
$channel : int
$outOfBand : string = ''
Return values
bool

confirmSelect()

send AMQP confirm.select frame

public confirmSelect(int $channel) : bool
Parameters
$channel : int
Return values
bool

exchangeBind()

send AMQP exchange.bind frame

public exchangeBind(int $channel, string $destination, string $source[, string $routingKey = '' ][, bool $nowait = false ][, array<string|int, mixed> $arguments = [] ]) : bool|MethodExchangeBindOkFrame
Parameters
$channel : int
$destination : string
$source : string
$routingKey : string = ''
$nowait : bool = false
$arguments : array<string|int, mixed> = []
Return values
bool|MethodExchangeBindOkFrame

exchangeDeclare()

send AMQP exchange.declare frame

public exchangeDeclare(int $channel, string $exchange[, string $exchangeType = 'direct' ][, bool $passive = false ][, bool $durable = false ][, bool $autoDelete = false ][, bool $internal = false ][, bool $nowait = false ][, array<string|int, mixed> $arguments = [] ]) : bool|MethodExchangeDeclareOkFrame
Parameters
$channel : int
$exchange : string
$exchangeType : string = 'direct'
$passive : bool = false
$durable : bool = false
$autoDelete : bool = false
$internal : bool = false
$nowait : bool = false
$arguments : array<string|int, mixed> = []
Return values
bool|MethodExchangeDeclareOkFrame

exchangeDelete()

send AMQP exchange.delete frame

public exchangeDelete(int $channel, string $exchange[, bool $ifUnused = false ][, bool $nowait = false ]) : bool|MethodExchangeDeleteOkFrame
Parameters
$channel : int
$exchange : string
$ifUnused : bool = false
$nowait : bool = false
Return values
bool|MethodExchangeDeleteOkFrame

exchangeUnbind()

send AMQP exchange.unbind frame

public exchangeUnbind(int $channel, string $destination, string $source[, string $routingKey = '' ][, bool $nowait = false ][, array<string|int, mixed> $arguments = [] ]) : bool|MethodExchangeUnbindOkFrame
Parameters
$channel : int
$destination : string
$source : string
$routingKey : string = ''
$nowait : bool = false
$arguments : array<string|int, mixed> = []
Return values
bool|MethodExchangeUnbindOkFrame

queueBind()

send AMQP queue.bind frame

public queueBind(int $channel, string $queue, string $exchange[, string $routingKey = '' ][, bool $nowait = false ][, array<string|int, mixed> $arguments = [] ]) : bool|MethodQueueBindOkFrame
Parameters
$channel : int
$queue : string
$exchange : string
$routingKey : string = ''
$nowait : bool = false
$arguments : array<string|int, mixed> = []
Return values
bool|MethodQueueBindOkFrame

queueDeclare()

send AMQP queue.declare frame

public queueDeclare(int $channel[, string $queue = '' ][, bool $passive = false ][, bool $durable = false ][, bool $exclusive = false ][, bool $autoDelete = false ][, bool $nowait = false ][, array<string|int, mixed> $arguments = [] ]) : bool|MethodQueueDeclareOkFrame
Parameters
$channel : int
$queue : string = ''
$passive : bool = false
$durable : bool = false
$exclusive : bool = false
$autoDelete : bool = false
$nowait : bool = false
$arguments : array<string|int, mixed> = []
Return values
bool|MethodQueueDeclareOkFrame

queueDelete()

send AMQP queue.delete frame

public queueDelete(int $channel[, string $queue = '' ][, bool $ifUnused = false ][, bool $ifEmpty = false ][, bool $nowait = false ]) : bool|MethodQueueDeleteOkFrame
Parameters
$channel : int
$queue : string = ''
$ifUnused : bool = false
$ifEmpty : bool = false
$nowait : bool = false
Return values
bool|MethodQueueDeleteOkFrame

queuePurge()

send AMQP queue.purge frame

public queuePurge(int $channel[, string $queue = '' ][, bool $nowait = false ]) : bool|MethodQueuePurgeOkFrame
Parameters
$channel : int
$queue : string = ''
$nowait : bool = false
Return values
bool|MethodQueuePurgeOkFrame

queueUnbind()

send AMQP queue.unbind frame

public queueUnbind(int $channel, string $queue, string $exchange[, string $routingKey = '' ][, array<string|int, mixed> $arguments = [] ]) : bool
Parameters
$channel : int
$queue : string
$exchange : string
$routingKey : string = ''
$arguments : array<string|int, mixed> = []
Return values
bool

txCommit()

send AMQP tx.commit frame

public txCommit(int $channel) : bool
Parameters
$channel : int
Return values
bool

txRollback()

send AMQP tx.rollback frame

public txRollback(int $channel) : bool
Parameters
$channel : int
Return values
bool

txSelect()

send AMQP tx.select frame

public txSelect(int $channel) : bool
Parameters
$channel : int
Return values
bool 

        

        
    




    

    

                                

                

                                
    

        On this page

        
    


                

                            

            

    

        

            
Search results