1414 */
1515class AmqpCommonUseCasesTest extends TestCase
1616{
17- use RabbitmqAmqpExtension;
1817 use RabbitManagementExtensionTrait;
18+ use RabbitmqAmqpExtension;
1919
2020 /**
2121 * @var AmqpContext
2222 */
2323 private $ amqpContext ;
2424
25- public function setUp ()
25+ protected function setUp (): void
2626 {
2727 $ this ->amqpContext = $ this ->buildAmqpContext ();
2828
2929 $ this ->removeQueue ('amqp_ext.test ' );
3030 $ this ->removeExchange ('amqp_ext.test_exchange ' );
3131 }
3232
33- public function tearDown (): void
33+ protected function tearDown (): void
3434 {
3535 $ this ->amqpContext ->close ();
3636 }
@@ -128,7 +128,7 @@ public function testProduceAndReceiveOneMessageSentDirectlyToTemporaryQueue()
128128 public function testProduceAndReceiveOneMessageSentDirectlyToTopic ()
129129 {
130130 $ topic = $ this ->amqpContext ->createTopic ('amqp_ext.test_exchange ' );
131- $ topic ->setType (AMQP_EX_TYPE_FANOUT );
131+ $ topic ->setType (\ AMQP_EX_TYPE_FANOUT );
132132 $ this ->amqpContext ->declareTopic ($ topic );
133133
134134 $ queue = $ this ->amqpContext ->createQueue ('amqp_ext.test ' );
@@ -153,7 +153,7 @@ public function testProduceAndReceiveOneMessageSentDirectlyToTopic()
153153 public function testConsumerReceiveMessageFromTopicDirectly ()
154154 {
155155 $ topic = $ this ->amqpContext ->createTopic ('amqp_ext.test_exchange ' );
156- $ topic ->setType (AMQP_EX_TYPE_FANOUT );
156+ $ topic ->setType (\ AMQP_EX_TYPE_FANOUT );
157157
158158 $ this ->amqpContext ->declareTopic ($ topic );
159159
@@ -176,7 +176,7 @@ public function testConsumerReceiveMessageFromTopicDirectly()
176176 public function testConsumerReceiveMessageWithZeroTimeout ()
177177 {
178178 $ topic = $ this ->amqpContext ->createTopic ('amqp_ext.test_exchange ' );
179- $ topic ->setType (AMQP_EX_TYPE_FANOUT );
179+ $ topic ->setType (\ AMQP_EX_TYPE_FANOUT );
180180
181181 $ this ->amqpContext ->declareTopic ($ topic );
182182
0 commit comments