diff --git a/docs/transport/amqp.md b/docs/transport/amqp.md
index ac7636604..126ff9f6d 100644
--- 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