Protocol080
Table of Contents
-
accessRequest()
: array<string|int, mixed>
-
accessRequestOk()
: array<string|int, mixed>
-
basicAck()
: array<string|int, mixed>
-
basicCancel()
: array<string|int, mixed>
-
basicCancelOk()
: array<string|int, mixed>
-
basicConsume()
: array<string|int, mixed>
-
basicConsumeOk()
: array<string|int, mixed>
-
basicDeliver()
: array<string|int, mixed>
-
basicGet()
: array<string|int, mixed>
-
basicGetEmpty()
: array<string|int, mixed>
-
basicGetOk()
: array<string|int, mixed>
-
basicPublish()
: array<string|int, mixed>
-
basicQos()
: array<string|int, mixed>
-
basicQosOk()
: array<string|int, mixed>
-
basicRecover()
: array<string|int, mixed>
-
basicRecoverAsync()
: array<string|int, mixed>
-
basicRecoverOk()
: array<string|int, mixed>
-
basicReject()
: array<string|int, mixed>
-
basicReturn()
: array<string|int, mixed>
-
channelAlert()
: array<string|int, mixed>
-
channelClose()
: array<string|int, mixed>
-
channelCloseOk()
: array<string|int, mixed>
-
channelFlow()
: array<string|int, mixed>
-
channelFlowOk()
: array<string|int, mixed>
-
channelOpen()
: array<string|int, mixed>
-
channelOpenOk()
: array<string|int, mixed>
-
connectionClose()
: array<string|int, mixed>
-
connectionCloseOk()
: array<string|int, mixed>
-
connectionOpen()
: array<string|int, mixed>
-
connectionOpenOk()
: array<string|int, mixed>
-
connectionRedirect()
: array<string|int, mixed>
-
connectionSecure()
: array<string|int, mixed>
-
connectionSecureOk()
: array<string|int, mixed>
-
connectionStart()
: array<string|int, mixed>
-
connectionStartOk()
: array<string|int, mixed>
-
connectionTune()
: array<string|int, mixed>
-
connectionTuneOk()
: array<string|int, mixed>
-
dtxSelect()
: array<string|int, mixed>
-
dtxSelectOk()
: array<string|int, mixed>
-
dtxStart()
: array<string|int, mixed>
-
dtxStartOk()
: array<string|int, mixed>
-
exchangeDeclare()
: array<string|int, mixed>
-
exchangeDeclareOk()
: array<string|int, mixed>
-
exchangeDelete()
: array<string|int, mixed>
-
exchangeDeleteOk()
: array<string|int, mixed>
-
fileAck()
: array<string|int, mixed>
-
fileCancel()
: array<string|int, mixed>
-
fileCancelOk()
: array<string|int, mixed>
-
fileConsume()
: array<string|int, mixed>
-
fileConsumeOk()
: array<string|int, mixed>
-
fileDeliver()
: array<string|int, mixed>
-
fileOpen()
: array<string|int, mixed>
-
fileOpenOk()
: array<string|int, mixed>
-
filePublish()
: array<string|int, mixed>
-
fileQos()
: array<string|int, mixed>
-
fileQosOk()
: array<string|int, mixed>
-
fileReject()
: array<string|int, mixed>
-
fileReturn()
: array<string|int, mixed>
-
fileStage()
: array<string|int, mixed>
-
queueBind()
: array<string|int, mixed>
-
queueBindOk()
: array<string|int, mixed>
-
queueDeclare()
: array<string|int, mixed>
-
queueDeclareOk()
: array<string|int, mixed>
-
queueDelete()
: array<string|int, mixed>
-
queueDeleteOk()
: array<string|int, mixed>
-
queuePurge()
: array<string|int, mixed>
-
queuePurgeOk()
: array<string|int, mixed>
-
queueUnbind()
: array<string|int, mixed>
-
queueUnbindOk()
: array<string|int, mixed>
-
streamCancel()
: array<string|int, mixed>
-
streamCancelOk()
: array<string|int, mixed>
-
streamConsume()
: array<string|int, mixed>
-
streamConsumeOk()
: array<string|int, mixed>
-
streamDeliver()
: array<string|int, mixed>
-
streamPublish()
: array<string|int, mixed>
-
streamQos()
: array<string|int, mixed>
-
streamQosOk()
: array<string|int, mixed>
-
streamReturn()
: array<string|int, mixed>
-
testContent()
: array<string|int, mixed>
-
testContentOk()
: array<string|int, mixed>
-
testInteger()
: array<string|int, mixed>
-
testIntegerOk()
: array<string|int, mixed>
-
testString()
: array<string|int, mixed>
-
testStringOk()
: array<string|int, mixed>
-
testTable()
: array<string|int, mixed>
-
testTableOk()
: array<string|int, mixed>
-
tunnelRequest()
: array<string|int, mixed>
-
txCommit()
: array<string|int, mixed>
-
txCommitOk()
: array<string|int, mixed>
-
txRollback()
: array<string|int, mixed>
-
txRollbackOk()
: array<string|int, mixed>
-
txSelect()
: array<string|int, mixed>
-
txSelectOk()
: array<string|int, mixed>
accessRequest()
public
accessRequest([string $realm = '/data' ][, bool $exclusive = false ][, bool $passive = true ][, bool $active = true ][, bool $write = true ][, bool $read = true ]) : array<string|int, mixed>
Parameters
-
$realm
: string
= '/data'
-
-
$exclusive
: bool
= false
-
-
$passive
: bool
= true
-
-
$active
: bool
= true
-
-
$write
: bool
= true
-
-
$read
: bool
= true
-
Return values
array<string|int, mixed>
—
accessRequestOk()
public
static accessRequestOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
basicAck()
public
basicAck(int $delivery_tag[, bool $multiple = false ]) : array<string|int, mixed>
Parameters
-
$delivery_tag
: int
-
-
$multiple
: bool
= false
-
Return values
array<string|int, mixed>
—
basicCancel()
public
basicCancel(string $consumer_tag[, bool $nowait = false ]) : array<string|int, mixed>
Parameters
-
$consumer_tag
: string
-
-
$nowait
: bool
= false
-
Return values
array<string|int, mixed>
—
basicCancelOk()
public
static basicCancelOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
basicConsume()
public
basicConsume([int $ticket = 1 ][, string $queue = '' ][, string $consumer_tag = '' ][, bool $no_local = false ][, bool $no_ack = false ][, bool $exclusive = false ][, bool $nowait = false ]) : array<string|int, mixed>
Parameters
-
$ticket
: int
= 1
-
-
$queue
: string
= ''
-
-
$consumer_tag
: string
= ''
-
-
$no_local
: bool
= false
-
-
$no_ack
: bool
= false
-
-
$exclusive
: bool
= false
-
-
$nowait
: bool
= false
-
Return values
array<string|int, mixed>
—
basicConsumeOk()
public
static basicConsumeOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
basicDeliver()
public
basicDeliver(string $consumer_tag, int $delivery_tag, bool $redelivered, string $exchange, string $routing_key) : array<string|int, mixed>
Parameters
-
$consumer_tag
: string
-
-
$delivery_tag
: int
-
-
$redelivered
: bool
-
-
$exchange
: string
-
-
$routing_key
: string
-
Return values
array<string|int, mixed>
—
basicGet()
public
basicGet([int $ticket = 1 ][, string $queue = '' ][, bool $no_ack = false ]) : array<string|int, mixed>
Parameters
-
$ticket
: int
= 1
-
-
$queue
: string
= ''
-
-
$no_ack
: bool
= false
-
Return values
array<string|int, mixed>
—
basicGetEmpty()
public
static basicGetEmpty(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
basicGetOk()
public
static basicGetOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
basicPublish()
public
basicPublish([int $ticket = 1 ][, string $exchange = '' ][, string $routing_key = '' ][, bool $mandatory = false ][, bool $immediate = false ]) : array<string|int, mixed>
Parameters
-
$ticket
: int
= 1
-
-
$exchange
: string
= ''
-
-
$routing_key
: string
= ''
-
-
$mandatory
: bool
= false
-
-
$immediate
: bool
= false
-
Return values
array<string|int, mixed>
—
basicQos()
public
basicQos(int $prefetch_size, int $prefetch_count[, bool $global = false ]) : array<string|int, mixed>
Parameters
-
$prefetch_size
: int
-
-
$prefetch_count
: int
-
-
$global
: bool
= false
-
Return values
array<string|int, mixed>
—
basicQosOk()
public
static basicQosOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
basicRecover()
public
basicRecover([bool $requeue = false ]) : array<string|int, mixed>
Parameters
-
$requeue
: bool
= false
-
Return values
array<string|int, mixed>
—
basicRecoverAsync()
public
basicRecoverAsync([bool $requeue = false ]) : array<string|int, mixed>
Parameters
-
$requeue
: bool
= false
-
Return values
array<string|int, mixed>
—
basicRecoverOk()
public
static basicRecoverOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
basicReject()
public
basicReject(int $delivery_tag[, bool $requeue = true ]) : array<string|int, mixed>
Parameters
-
$delivery_tag
: int
-
-
$requeue
: bool
= true
-
Return values
array<string|int, mixed>
—
basicReturn()
public
basicReturn(int $reply_code, string $reply_text, string $exchange, string $routing_key) : array<string|int, mixed>
Parameters
-
$reply_code
: int
-
-
$reply_text
: string
-
-
$exchange
: string
-
-
$routing_key
: string
-
Return values
array<string|int, mixed>
—
channelAlert()
public
channelAlert(int $reply_code[, string $reply_text = '' ][, AMQPTable|array<string|int, mixed> $details = array() ]) : array<string|int, mixed>
Parameters
-
$reply_code
: int
-
-
$reply_text
: string
= ''
-
-
$details
: AMQPTable|array<string|int, mixed>
= array()
-
Return values
array<string|int, mixed>
—
channelClose()
public
channelClose(int $reply_code, string $reply_text, int $class_id, int $method_id) : array<string|int, mixed>
Parameters
-
$reply_code
: int
-
-
$reply_text
: string
-
-
$class_id
: int
-
-
$method_id
: int
-
Return values
array<string|int, mixed>
—
channelCloseOk()
public
static channelCloseOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
channelFlow()
public
channelFlow(bool $active) : array<string|int, mixed>
Parameters
-
$active
: bool
-
Return values
array<string|int, mixed>
—
channelFlowOk()
public
static channelFlowOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
channelOpen()
public
channelOpen([string $out_of_band = '' ]) : array<string|int, mixed>
Parameters
-
$out_of_band
: string
= ''
-
Return values
array<string|int, mixed>
—
channelOpenOk()
public
static channelOpenOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
connectionClose()
public
connectionClose(int $reply_code, string $reply_text, int $class_id, int $method_id) : array<string|int, mixed>
Parameters
-
$reply_code
: int
-
-
$reply_text
: string
-
-
$class_id
: int
-
-
$method_id
: int
-
Return values
array<string|int, mixed>
—
connectionCloseOk()
public
static connectionCloseOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
connectionOpen()
public
connectionOpen([string $virtual_host = '/' ][, string $capabilities = '' ][, bool $insist = false ]) : array<string|int, mixed>
Parameters
-
$virtual_host
: string
= '/'
-
-
$capabilities
: string
= ''
-
-
$insist
: bool
= false
-
Return values
array<string|int, mixed>
—
connectionOpenOk()
public
static connectionOpenOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
connectionRedirect()
public
connectionRedirect(string $host[, string $known_hosts = '' ]) : array<string|int, mixed>
Parameters
-
$host
: string
-
-
$known_hosts
: string
= ''
-
Return values
array<string|int, mixed>
—
connectionSecure()
public
connectionSecure(string $challenge) : array<string|int, mixed>
Parameters
-
$challenge
: string
-
Return values
array<string|int, mixed>
—
connectionSecureOk()
public
static connectionSecureOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
connectionStart()
public
connectionStart(int $version_major[, int $version_minor = 8 ][, mixed $server_properties = [] ][, string $mechanisms = 'PLAIN' ][, string $locales = 'en_US' ]) : array<string|int, mixed>
Parameters
-
$version_major
: int
-
-
$version_minor
: int
= 8
-
-
$server_properties
: mixed
= []
-
-
$mechanisms
: string
= 'PLAIN'
-
-
$locales
: string
= 'en_US'
-
Return values
array<string|int, mixed>
—
connectionStartOk()
public
static connectionStartOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
connectionTune()
public
connectionTune(int $channel_max, int $frame_max, int $heartbeat) : array<string|int, mixed>
Parameters
-
$channel_max
: int
-
-
$frame_max
: int
-
-
$heartbeat
: int
-
Return values
array<string|int, mixed>
—
connectionTuneOk()
public
static connectionTuneOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
dtxSelect()
public
dtxSelect() : array<string|int, mixed>
Return values
array<string|int, mixed>
—
dtxSelectOk()
public
static dtxSelectOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
dtxStart()
public
dtxStart(string $dtx_identifier) : array<string|int, mixed>
Parameters
-
$dtx_identifier
: string
-
Return values
array<string|int, mixed>
—
dtxStartOk()
public
static dtxStartOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
exchangeDeclare()
public
exchangeDeclare([int $ticket = 1 ][, string $exchange = '' ][, string $type = 'direct' ][, bool $passive = false ][, bool $durable = false ][, bool $auto_delete = false ][, bool $internal = false ][, bool $nowait = false ][, AMQPTable|array<string|int, mixed> $arguments = array() ]) : array<string|int, mixed>
Parameters
-
$ticket
: int
= 1
-
-
$exchange
: string
= ''
-
-
$type
: string
= 'direct'
-
-
$passive
: bool
= false
-
-
$durable
: bool
= false
-
-
$auto_delete
: bool
= false
-
-
$internal
: bool
= false
-
-
$nowait
: bool
= false
-
-
$arguments
: AMQPTable|array<string|int, mixed>
= array()
-
Return values
array<string|int, mixed>
—
exchangeDeclareOk()
public
static exchangeDeclareOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
exchangeDelete()
public
exchangeDelete([int $ticket = 1 ][, string $exchange = '' ][, bool $if_unused = false ][, bool $nowait = false ]) : array<string|int, mixed>
Parameters
-
$ticket
: int
= 1
-
-
$exchange
: string
= ''
-
-
$if_unused
: bool
= false
-
-
$nowait
: bool
= false
-
Return values
array<string|int, mixed>
—
exchangeDeleteOk()
public
static exchangeDeleteOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
fileAck()
public
fileAck(int $delivery_tag[, bool $multiple = false ]) : array<string|int, mixed>
Parameters
-
$delivery_tag
: int
-
-
$multiple
: bool
= false
-
Return values
array<string|int, mixed>
—
fileCancel()
public
fileCancel(string $consumer_tag[, bool $nowait = false ]) : array<string|int, mixed>
Parameters
-
$consumer_tag
: string
-
-
$nowait
: bool
= false
-
Return values
array<string|int, mixed>
—
fileCancelOk()
public
static fileCancelOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
fileConsume()
public
fileConsume([int $ticket = 1 ][, string $queue = '' ][, string $consumer_tag = '' ][, bool $no_local = false ][, bool $no_ack = false ][, bool $exclusive = false ][, bool $nowait = false ]) : array<string|int, mixed>
Parameters
-
$ticket
: int
= 1
-
-
$queue
: string
= ''
-
-
$consumer_tag
: string
= ''
-
-
$no_local
: bool
= false
-
-
$no_ack
: bool
= false
-
-
$exclusive
: bool
= false
-
-
$nowait
: bool
= false
-
Return values
array<string|int, mixed>
—
fileConsumeOk()
public
static fileConsumeOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
fileDeliver()
public
fileDeliver(string $consumer_tag, int $delivery_tag, bool $redelivered, string $exchange, string $routing_key, string $identifier) : array<string|int, mixed>
Parameters
-
$consumer_tag
: string
-
-
$delivery_tag
: int
-
-
$redelivered
: bool
-
-
$exchange
: string
-
-
$routing_key
: string
-
-
$identifier
: string
-
Return values
array<string|int, mixed>
—
fileOpen()
public
fileOpen(string $identifier, int $content_size) : array<string|int, mixed>
Parameters
-
$identifier
: string
-
-
$content_size
: int
-
Return values
array<string|int, mixed>
—
fileOpenOk()
public
static fileOpenOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
filePublish()
public
filePublish([int $ticket = 1 ][, string $exchange = '' ][, string $routing_key = '' ][, bool $mandatory = false ][, bool $immediate = false ][, string $identifier = '' ]) : array<string|int, mixed>
Parameters
-
$ticket
: int
= 1
-
-
$exchange
: string
= ''
-
-
$routing_key
: string
= ''
-
-
$mandatory
: bool
= false
-
-
$immediate
: bool
= false
-
-
$identifier
: string
= ''
-
Return values
array<string|int, mixed>
—
fileQos()
public
fileQos(int $prefetch_size, int $prefetch_count[, bool $global = false ]) : array<string|int, mixed>
Parameters
-
$prefetch_size
: int
-
-
$prefetch_count
: int
-
-
$global
: bool
= false
-
Return values
array<string|int, mixed>
—
fileQosOk()
public
static fileQosOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
fileReject()
public
fileReject(int $delivery_tag[, bool $requeue = true ]) : array<string|int, mixed>
Parameters
-
$delivery_tag
: int
-
-
$requeue
: bool
= true
-
Return values
array<string|int, mixed>
—
fileReturn()
public
fileReturn([int $reply_code = 200 ][, string $reply_text = '' ][, string $exchange = '' ][, string $routing_key = '' ]) : array<string|int, mixed>
Parameters
-
$reply_code
: int
= 200
-
-
$reply_text
: string
= ''
-
-
$exchange
: string
= ''
-
-
$routing_key
: string
= ''
-
Return values
array<string|int, mixed>
—
fileStage()
public
fileStage() : array<string|int, mixed>
Return values
array<string|int, mixed>
—
queueBind()
public
queueBind([int $ticket = 1 ][, string $queue = '' ][, string $exchange = '' ][, string $routing_key = '' ][, bool $nowait = false ][, AMQPTable|array<string|int, mixed> $arguments = array() ]) : array<string|int, mixed>
Parameters
-
$ticket
: int
= 1
-
-
$queue
: string
= ''
-
-
$exchange
: string
= ''
-
-
$routing_key
: string
= ''
-
-
$nowait
: bool
= false
-
-
$arguments
: AMQPTable|array<string|int, mixed>
= array()
-
Return values
array<string|int, mixed>
—
queueBindOk()
public
static queueBindOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
queueDeclare()
public
queueDeclare([int $ticket = 1 ][, string $queue = '' ][, bool $passive = false ][, bool $durable = false ][, bool $exclusive = false ][, bool $auto_delete = false ][, bool $nowait = false ][, AMQPTable|array<string|int, mixed> $arguments = array() ]) : array<string|int, mixed>
Parameters
-
$ticket
: int
= 1
-
-
$queue
: string
= ''
-
-
$passive
: bool
= false
-
-
$durable
: bool
= false
-
-
$exclusive
: bool
= false
-
-
$auto_delete
: bool
= false
-
-
$nowait
: bool
= false
-
-
$arguments
: AMQPTable|array<string|int, mixed>
= array()
-
Return values
array<string|int, mixed>
—
queueDeclareOk()
public
static queueDeclareOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
queueDelete()
public
queueDelete([int $ticket = 1 ][, string $queue = '' ][, bool $if_unused = false ][, bool $if_empty = false ][, bool $nowait = false ]) : array<string|int, mixed>
Parameters
-
$ticket
: int
= 1
-
-
$queue
: string
= ''
-
-
$if_unused
: bool
= false
-
-
$if_empty
: bool
= false
-
-
$nowait
: bool
= false
-
Return values
array<string|int, mixed>
—
queueDeleteOk()
public
static queueDeleteOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
queuePurge()
public
queuePurge([int $ticket = 1 ][, string $queue = '' ][, bool $nowait = false ]) : array<string|int, mixed>
Parameters
-
$ticket
: int
= 1
-
-
$queue
: string
= ''
-
-
$nowait
: bool
= false
-
Return values
array<string|int, mixed>
—
queuePurgeOk()
public
static queuePurgeOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
queueUnbind()
public
queueUnbind([int $ticket = 1 ][, string $queue = '' ][, string $exchange = '' ][, string $routing_key = '' ][, AMQPTable|array<string|int, mixed> $arguments = array() ]) : array<string|int, mixed>
Parameters
-
$ticket
: int
= 1
-
-
$queue
: string
= ''
-
-
$exchange
: string
= ''
-
-
$routing_key
: string
= ''
-
-
$arguments
: AMQPTable|array<string|int, mixed>
= array()
-
Return values
array<string|int, mixed>
—
queueUnbindOk()
public
static queueUnbindOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
streamCancel()
public
streamCancel(string $consumer_tag[, bool $nowait = false ]) : array<string|int, mixed>
Parameters
-
$consumer_tag
: string
-
-
$nowait
: bool
= false
-
Return values
array<string|int, mixed>
—
streamCancelOk()
public
static streamCancelOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
streamConsume()
public
streamConsume([int $ticket = 1 ][, string $queue = '' ][, string $consumer_tag = '' ][, bool $no_local = false ][, bool $exclusive = false ][, bool $nowait = false ]) : array<string|int, mixed>
Parameters
-
$ticket
: int
= 1
-
-
$queue
: string
= ''
-
-
$consumer_tag
: string
= ''
-
-
$no_local
: bool
= false
-
-
$exclusive
: bool
= false
-
-
$nowait
: bool
= false
-
Return values
array<string|int, mixed>
—
streamConsumeOk()
public
static streamConsumeOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
streamDeliver()
public
streamDeliver(string $consumer_tag, int $delivery_tag, string $exchange, string $queue) : array<string|int, mixed>
Parameters
-
$consumer_tag
: string
-
-
$delivery_tag
: int
-
-
$exchange
: string
-
-
$queue
: string
-
Return values
array<string|int, mixed>
—
streamPublish()
public
streamPublish([int $ticket = 1 ][, string $exchange = '' ][, string $routing_key = '' ][, bool $mandatory = false ][, bool $immediate = false ]) : array<string|int, mixed>
Parameters
-
$ticket
: int
= 1
-
-
$exchange
: string
= ''
-
-
$routing_key
: string
= ''
-
-
$mandatory
: bool
= false
-
-
$immediate
: bool
= false
-
Return values
array<string|int, mixed>
—
streamQos()
public
streamQos(int $prefetch_size, int $prefetch_count, int $consume_rate[, bool $global = false ]) : array<string|int, mixed>
Parameters
-
$prefetch_size
: int
-
-
$prefetch_count
: int
-
-
$consume_rate
: int
-
-
$global
: bool
= false
-
Return values
array<string|int, mixed>
—
streamQosOk()
public
static streamQosOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
streamReturn()
public
streamReturn([int $reply_code = 200 ][, string $reply_text = '' ][, string $exchange = '' ][, string $routing_key = '' ]) : array<string|int, mixed>
Parameters
-
$reply_code
: int
= 200
-
-
$reply_text
: string
= ''
-
-
$exchange
: string
= ''
-
-
$routing_key
: string
= ''
-
Return values
array<string|int, mixed>
—
testContent()
public
testContent() : array<string|int, mixed>
Return values
array<string|int, mixed>
—
testContentOk()
public
static testContentOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
testInteger()
public
testInteger(int $integer_1, int $integer_2, int $integer_3, int $integer_4, int $operation) : array<string|int, mixed>
Parameters
-
$integer_1
: int
-
-
$integer_2
: int
-
-
$integer_3
: int
-
-
$integer_4
: int
-
-
$operation
: int
-
Return values
array<string|int, mixed>
—
testIntegerOk()
public
static testIntegerOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
testString()
public
testString(string $string_1, string $string_2, int $operation) : array<string|int, mixed>
Parameters
-
$string_1
: string
-
-
$string_2
: string
-
-
$operation
: int
-
Return values
array<string|int, mixed>
—
testStringOk()
public
static testStringOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
testTable()
public
testTable(AMQPTable|array<string|int, mixed> $table, int $integer_op, int $string_op) : array<string|int, mixed>
Parameters
-
$table
: AMQPTable|array<string|int, mixed>
-
-
$integer_op
: int
-
-
$string_op
: int
-
Return values
array<string|int, mixed>
—
testTableOk()
public
static testTableOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
tunnelRequest()
public
tunnelRequest(AMQPTable|array<string|int, mixed> $meta_data) : array<string|int, mixed>
Parameters
-
$meta_data
: AMQPTable|array<string|int, mixed>
-
Return values
array<string|int, mixed>
—
txCommit()
public
txCommit() : array<string|int, mixed>
Return values
array<string|int, mixed>
—
txCommitOk()
public
static txCommitOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
txRollback()
public
txRollback() : array<string|int, mixed>
Return values
array<string|int, mixed>
—
txRollbackOk()
public
static txRollbackOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—
txSelect()
public
txSelect() : array<string|int, mixed>
Return values
array<string|int, mixed>
—
txSelectOk()
public
static txSelectOk(AMQPReader $reader) : array<string|int, mixed>
Parameters
-
$reader
: AMQPReader
-
Return values
array<string|int, mixed>
—