Skip to content

Commit d319c5a

Browse files
authored
Fix AMQP(s) code in amqp.md
1 parent 397526a commit d319c5a

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)