File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
pkg/amqp-ext/Tests/Functional Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -128,7 +128,7 @@ public function testProduceAndReceiveOneMessageSentDirectlyToTemporaryQueue()
128
128
public function testProduceAndReceiveOneMessageSentDirectlyToTopic ()
129
129
{
130
130
$ topic = $ this ->amqpContext ->createTopic ('amqp_ext.test_exchange ' );
131
- $ topic ->setType (AMQP_EX_TYPE_FANOUT );
131
+ $ topic ->setType (\ AMQP_EX_TYPE_FANOUT );
132
132
$ this ->amqpContext ->declareTopic ($ topic );
133
133
134
134
$ queue = $ this ->amqpContext ->createQueue ('amqp_ext.test ' );
@@ -153,7 +153,7 @@ public function testProduceAndReceiveOneMessageSentDirectlyToTopic()
153
153
public function testConsumerReceiveMessageFromTopicDirectly ()
154
154
{
155
155
$ topic = $ this ->amqpContext ->createTopic ('amqp_ext.test_exchange ' );
156
- $ topic ->setType (AMQP_EX_TYPE_FANOUT );
156
+ $ topic ->setType (\ AMQP_EX_TYPE_FANOUT );
157
157
158
158
$ this ->amqpContext ->declareTopic ($ topic );
159
159
@@ -176,7 +176,7 @@ public function testConsumerReceiveMessageFromTopicDirectly()
176
176
public function testConsumerReceiveMessageWithZeroTimeout ()
177
177
{
178
178
$ topic = $ this ->amqpContext ->createTopic ('amqp_ext.test_exchange ' );
179
- $ topic ->setType (AMQP_EX_TYPE_FANOUT );
179
+ $ topic ->setType (\ AMQP_EX_TYPE_FANOUT );
180
180
181
181
$ this ->amqpContext ->declareTopic ($ topic );
182
182
You can’t perform that action at this time.
0 commit comments