(PECL amqp >= Unknown)
AMQPExchange::publish — Publish a message to an exchange.
$message
, string $routing_key
[, int $flags
= AMQP_NOPARAM
[, array $attributes
= array()
]] )Publish a message to the exchange represented by the AMQPExchange object.
message
The message to publish.
routing_key
The routing key to which to publish.
flags
One or more of AMQP_MANDATORY
and
AMQP_IMMEDIATE
.
attributes
key | Description | Default value |
---|---|---|
content_type | text/plain | |
content_encoding | NULL | |
message_id | NULL | |
user_id | NULL | |
app_id | NULL | |
delivery_mode | NULL | |
priority | NULL | |
timestamp | NULL | |
expiration | time in milliseconds | NULL |
type | NULL | |
reply_to | NULL | |
headers | custom attributes to pass along with message | array |
Returns TRUE
on success or FALSE
on failure.
Throws an AMQPExchangeException on failure.
Throws AMQPChannelException if the channel is not open.
Throws AMQPConnectionException if the connection to the broker was lost.