If the bind() operation is blocking for you, make sure you're performing it on a fresh connection - use reconnect() or so. This took me hours to figure out.
AMQPQueue::bind
(PECL amqp >= Unknown)
AMQPQueue::bind — Bind the given queue to a routing key on an exchange.
说明
public bool AMQPQueue::bind
( string
$exchange_name
, string $routing_key
)The bind method will bind the given queue to the specified routing key on the given exchange.
Warning
本函数还未编写文档,仅有参数列表。
参数
-
exchange_name -
The exchange name on which to bind.
-
routing_key -
The routing key to which to bind.
错误/异常
Throws AMQPChannelException if the channel is not open.
Throws AMQPConnectionException if the connection to the broker was lost.
返回值
成功时返回 TRUE, 或者在失败时返回 FALSE。
gdr at go2 dot pl ¶
1 year ago
