From d24ea5b4154f55dea1617af1ed8b53f22f5a4c97 Mon Sep 17 00:00:00 2001
From: Bas <xdbas@users.noreply.github.com>
Date: Mon, 26 Mar 2018 11:14:22 +0200
Subject: [PATCH] Fix AMQP(s) code in amqp.md

---
 docs/transport/amqp.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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