AbstractChannel
in package
Table of Contents
- PROTOCOL_080 = PhpAmqpLibWireConstants080::VERSION
- PROTOCOL_091 = PhpAmqpLibWireConstants091::VERSION
- $auto_decode : bool
- $channel_id : int|null
- $connection : null|AbstractConnection
- $constants : Constants
- $debug : DebugHelper
- $dispatch_reader : AMQPBufferReader
- $frame_queue : SplQueue|array<string|int, Frame>
- Lower level queue for frames
- $maxBodySize : int
- $method_queue : array<string|int, mixed>
- Higher level queue for methods
- $methodMap : MethodMap080|MethodMap091
- $msg_property_reader : AMQPBufferReader
- $protocolVersion : string
- $protocolWriter : Protocol080|Protocol091
- $waitHelper : Wait080|Wait091
- __construct() : mixed
- dispatch() : mixed
- getChannelId() : int|null
- getConnection() : AbstractConnection|null
- getMethodQueue() : array<string|int, mixed>
- getProtocolVersion() : string
- hasPendingMethods() : bool
- setBodySizeLimit() : $this
- wait() : mixed
- Wait for some expected AMQP methods and dispatch to them.
- wait_content() : AMQPMessage
- createMessage() : AMQPMessage
- dispatch_deferred_method() : mixed
- dispatch_to_handler() : mixed
- maybe_wait_for_content() : AMQPMessage|null
- next_frame() : Frame
- parseMethod() : Method
- prepare_method_frame() : AMQPWriter
- This is here for performance reasons to batch calls to fwrite from basic.publish
- process_deferred_methods() : array<string|int, mixed>
- send_method_frame() : mixed
- should_dispatch_method() : bool
- validate_frame() : void
- validate_frame_payload() : void
- validate_method_frame() : void
Constants
PROTOCOL_080
public
mixed
PROTOCOL_080
= PhpAmqpLibWireConstants080::VERSION
Tags
PROTOCOL_091
public
mixed
PROTOCOL_091
= PhpAmqpLibWireConstants091::VERSION
Tags
Properties
$auto_decode
protected
bool
$auto_decode
= false
$channel_id
protected
int|null
$channel_id
$connection
protected
null|AbstractConnection
$connection
$constants
protected
Constants
$constants
$debug
protected
DebugHelper
$debug
$dispatch_reader
protected
AMQPBufferReader
$dispatch_reader
$frame_queue
Lower level queue for frames
protected
SplQueue|array<string|int, Frame>
$frame_queue
$maxBodySize
protected
int
$maxBodySize
$method_queue
Higher level queue for methods
protected
array<string|int, mixed>
$method_queue
= array()
$methodMap
protected
MethodMap080|MethodMap091
$methodMap
$msg_property_reader
protected
AMQPBufferReader
$msg_property_reader
$protocolVersion
protected
string
$protocolVersion
Tags
$protocolWriter
protected
Protocol080|Protocol091
$protocolWriter
$waitHelper
protected
Wait080|Wait091
$waitHelper
Methods
__construct()
public
__construct(AbstractConnection $connection, int $channel_id) : mixed
Parameters
- $connection : AbstractConnection
- $channel_id : int
Tags
Return values
mixed —dispatch()
public
dispatch(string $method_sig, string $args, AMQPMessage|null $amqpMessage) : mixed
Parameters
- $method_sig : string
- $args : string
- $amqpMessage : AMQPMessage|null
Tags
Return values
mixed —getChannelId()
public
getChannelId() : int|null
Return values
int|null —getConnection()
public
getConnection() : AbstractConnection|null
Return values
AbstractConnection|null —getMethodQueue()
public
getMethodQueue() : array<string|int, mixed>
Return values
array<string|int, mixed> —getProtocolVersion()
public
static getProtocolVersion() : string
Tags
Return values
string —hasPendingMethods()
public
hasPendingMethods() : bool
Return values
bool —setBodySizeLimit()
public
setBodySizeLimit(int $max_bytes) : $this
Parameters
- $max_bytes : int
-
Max message body size for this channel
Return values
$this —wait()
Wait for some expected AMQP methods and dispatch to them.
public
wait([array<string|int, mixed>|null $allowed_methods = null ][, bool $non_blocking = false ], int|float|null $timeout) : mixed
Unexpected methods are queued up for later calls to this PHP method.
Parameters
- $allowed_methods : array<string|int, mixed>|null = null
- $non_blocking : bool = false
- $timeout : int|float|null
Tags
Return values
mixed —wait_content()
public
wait_content() : AMQPMessage
Tags
Return values
AMQPMessage —createMessage()
protected
createMessage(AMQPReader $propertyReader, int $bodySize) : AMQPMessage
Parameters
- $propertyReader : AMQPReader
- $bodySize : int
Return values
AMQPMessage —dispatch_deferred_method()
protected
dispatch_deferred_method(array<string|int, mixed> $queued_method) : mixed
Parameters
- $queued_method : array<string|int, mixed>
Return values
mixed —dispatch_to_handler()
protected
dispatch_to_handler(callable $handler[, array<string|int, mixed> $arguments = [] ]) : mixed
Parameters
- $handler : callable
- $arguments : array<string|int, mixed> = []
Return values
mixed —maybe_wait_for_content()
protected
maybe_wait_for_content(string $method_sig) : AMQPMessage|null
Parameters
- $method_sig : string
Return values
AMQPMessage|null —next_frame()
protected
next_frame(int|float|null $timeout) : Frame
Parameters
- $timeout : int|float|null
Return values
Frame —parseMethod()
protected
parseMethod(string $payload) : Method
Parameters
- $payload : string
Return values
Method —prepare_method_frame()
This is here for performance reasons to batch calls to fwrite from basic.publish
protected
prepare_method_frame(array<string|int, mixed> $method_sig[, AMQPWriter|string $args = '' ][, AMQPWriter $pkt = null ]) : AMQPWriter
Parameters
- $method_sig : array<string|int, mixed>
- $args : AMQPWriter|string = ''
- $pkt : AMQPWriter = null
Return values
AMQPWriter —process_deferred_methods()
protected
process_deferred_methods(array<string|int, mixed>|null $allowed_methods) : array<string|int, mixed>
Parameters
- $allowed_methods : array<string|int, mixed>|null
Return values
array<string|int, mixed> —send_method_frame()
protected
send_method_frame(array<string|int, mixed> $method_sig[, AMQPWriter|string $args = '' ]) : mixed
Parameters
- $method_sig : array<string|int, mixed>
- $args : AMQPWriter|string = ''
Return values
mixed —should_dispatch_method()
protected
should_dispatch_method(array<string|int, mixed>|null $allowed_methods, string $method_sig) : bool
Parameters
- $allowed_methods : array<string|int, mixed>|null
- $method_sig : string
Return values
bool —validate_frame()
protected
validate_frame(Frame $frame, int $expectedType) : void
Parameters
- $frame : Frame
- $expectedType : int
Tags
Return values
void —validate_frame_payload()
protected
validate_frame_payload(Frame $frame) : void
Parameters
- $frame : Frame
Tags
Return values
void —validate_method_frame()
protected
validate_method_frame(Frame $frame) : void
Parameters
- $frame : Frame