请教如何实现topic模式,exchange对应多个队列对应各自消费者

感谢作者提供简单好用的插件!

当前使用1.0版本

我想实现的效果是:

实现topic模式, 比如exchange = mqTopic ,
这个交换机有两个队列mqTopic_1和mqTopic_2,
两个队列分别通过routing_key = task.1 (mqTopic_1)和routing_key = task.2 (mqTopic_2)绑定
每个队列有各自的消费者进程去消费

我的做法:

通过php webman workbunny:rabbitmq-builder mqTopic 2创建了builder

投递消息使用sync_publish() 目前情况是投递消息可以到达,但是无法消费


$b = MqTopicBuilder::instance();
$b->setMessage(new Message([
     'exchange_name'     => 'mqTopic',
      'exchange_type'     => Constants::TOPIC,
      'queue_name'        => 'mqTopic_'.$request->get('queue_name', 0), //对应mqTopic_1 mqTopic_2
      'routing_key'       => $request->get('routing_key',get_called_class()), //对应 task.1 task.2
      'consumer_tag'      => 'mqTopic',
      'prefetch_size'     => 0,
      'prefetch_count'    => 30,
      'is_global'         => false,
  ]));
  sync_publish($b, json_encode($data));



请问我该如何实现?如果有demo最好!

**在次感谢作者无私奉献!**

workbunny / webman-rabbitmq

请教如何实现topic模式,exchange对应多个队列对应各自消费者 #15