handling publish subscribe fanout
- Dominant language
- PHP
- Stars
- 23
- Forks
- 16
- PR merge metrics
- No merged PRs in 30d
Description
hyperf is awesome framework but i have problem when using amqp on rabbitmq, when i want to use fanout in Publish/Subscribe implementation but when doing queue_declare queue name cannot be null.
```
/**
* @Consumer(exchange="broadcast", routingKey="", queue="", name="SubribeMessage", nums=1)
*/
#[Consumer(exchange: 'broadcast', routingKey: '', queue: '', name: "SubribeMessage", nums: 1)]
class SubribeMessage extends ConsumerMessage
{
protected $type = Type::FANOUT;
public function consumeMessage($data, AMQPMessage $message): string
{
var_dump($data);
return Result::ACK;
}
}
```
```
public function setQueue(string $queue): self
{
$this->queue = $queue;
return $this;
}
public function getQueue(): string
{
return $this->queue;
}
```
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.