mirror of
https://gitee.com/hyperf/hyperf.git
synced 2024-11-30 02:37:58 +08:00
commit
9100c09e0f
@ -92,7 +92,7 @@ class Consumer extends Builder
|
||||
public function declare(MessageInterface $message, ?AMQPChannel $channel = null): void
|
||||
{
|
||||
if (! $message instanceof ConsumerMessageInterface) {
|
||||
throw new MessageException('Message must instanceof ' . ConsumerInterface::class);
|
||||
throw new MessageException('Message must instanceof ' . ConsumerMessageInterface::class);
|
||||
}
|
||||
|
||||
if (! $channel) {
|
||||
|
Loading…
Reference in New Issue
Block a user