AmqpLibReactorDelivery
in package
implements
ReactorDelivery
FinalYes
Adapts a `php-amqplib` {@see AMQPMessage} to {@see ReactorDelivery} (CONTRACT.md §22.1).
Table of Contents
Interfaces
- ReactorDelivery
- One message off the reactor's own queue (CONTRACT.md §22.1).
Methods
- __construct() : mixed
- ack() : void
- Acknowledges the delivery.
- body() : string
- The raw message bytes, exactly as received.
- correlationId() : string
- The delivery's AMQP `correlation_id` basic property, echoed onto the reply publication. Not the authenticated binding either — the one in the signed body is.
- nack() : void
- Negatively acknowledges the delivery WITHOUT requeue.
- replyTo() : string
- The reply queue named in the delivery's AMQP `reply_to` basic property — standard AMQP RPC.
Methods
__construct()
public
__construct(AMQPMessage $message) : mixed
Parameters
- $message : AMQPMessage
-
The delivery as
php-amqplibhanded it over.
ack()
Acknowledges the delivery.
public
ack() : void
body()
The raw message bytes, exactly as received.
public
body() : string
Return values
stringcorrelationId()
The delivery's AMQP `correlation_id` basic property, echoed onto the reply publication. Not the authenticated binding either — the one in the signed body is.
public
correlationId() : string
Return values
stringnack()
Negatively acknowledges the delivery WITHOUT requeue.
public
nack() : void
replyTo()
The reply queue named in the delivery's AMQP `reply_to` basic property — standard AMQP RPC.
public
replyTo() : string