(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 |
成功时返回 TRUE
, 或者在失败时返回 FALSE
。
Throws an AMQPExchangeException on failure.
Throws AMQPChannelException if the channel is not open.
Throws AMQPConnectionException if the connection to the broker was lost.