Fix AMQP(s) code in amqp.md

php-enqueue · Mar 26, 2018 · d24ea5b · d24ea5b
1 parent 8ca5144
commit d24ea5b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/docs/transport/amqp.md b/docs/transport/amqp.md
@@ -78,7 +78,7 @@ use Interop\Amqp\AmqpTopic;
 /** @var \Enqueue\AmqpExt\AmqpContext $psrContext */
 
 $fooTopic = $psrContext->createTopic('foo');
-$fooTopic->addFlag(AmqpTopic::TYPE_FANOUT);
+$fooTopic->setType(AmqpTopic::TYPE_FANOUT);
 $psrContext->declareTopic($fooTopic);
 
 // to remove topic use delete topic method