|
|
@@ -81,9 +81,11 @@ class SubscribeForm extends BaseForm
|
|
|
try {
|
|
|
$connect = $this->getConnect();
|
|
|
$channel = $connect->channel();
|
|
|
- $channel->queue_unbind($this->name, false, false );
|
|
|
+ $channel->queue_unbind($this->endpoint, $this->topicName, false );
|
|
|
+
|
|
|
+ list($subscriptionName,,) = $channel->queue_unbind($this->endpoint, $this->topicName, is_null($this->bindingKey)?'*':$this->bindingKey);
|
|
|
return [
|
|
|
- 'name' => $this->name,
|
|
|
+ 'name' => $this->endpoint,
|
|
|
'result' => '删除成功'
|
|
|
];
|
|
|
|
