RabbitMQConsumer
in package
AbstractYes
Table of Contents
Properties
- $channel : AbstractChannel
- $connection : AMQPStreamConnection
Methods
- handle() : mixed
- getMessageHeaders() : array<string|int, mixed>
- publishMessage() : mixed
- setup() : mixed
Properties
$channel
protected
AbstractChannel
$channel
$connection
protected
AMQPStreamConnection
$connection
Methods
handle()
public
handle() : mixed
getMessageHeaders()
protected
getMessageHeaders(AMQPMessage $message) : array<string|int, mixed>
Parameters
- $message : AMQPMessage
Return values
array<string|int, mixed>publishMessage()
protected
publishMessage(array<string|int, mixed> $headers, string $exchange, string $routingKey, array<string|int, mixed> $payload) : mixed
Parameters
- $headers : array<string|int, mixed>
- $exchange : string
- $routingKey : string
- $payload : array<string|int, mixed>
setup()
protected
abstract setup() : mixed