Skip to content

Commit 8ba4727

Browse files
authored
Merge pull request #413 from xdbas/patch-1
Fix AMQP(s) code in amqp.md
2 parents 8ca5144 + d24ea5b commit 8ba4727

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Diff for: docs/transport/amqp.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ use Interop\Amqp\AmqpTopic;
7878
/** @var \Enqueue\AmqpExt\AmqpContext $psrContext */
7979

8080
$fooTopic = $psrContext->createTopic('foo');
81-
$fooTopic->addFlag(AmqpTopic::TYPE_FANOUT);
81+
$fooTopic->setType(AmqpTopic::TYPE_FANOUT);
8282
$psrContext->declareTopic($fooTopic);
8383

8484
// to remove topic use delete topic method

0 commit comments

Comments
 (0)