@@ -32,8 +32,8 @@ protected function setUp()
32
32
33
33
$ this ->context = $ this ->buildSqsContext ();
34
34
35
- $ this ->queue = $ this -> context -> createQueue ( uniqid ('enqueue_test_queue_ ' )) ;
36
- $ this ->queueName = $ this ->queue -> getQueueName ( );
35
+ $ this ->queueName = str_replace ( ' . ' , ' _dot_ ' , uniqid ('enqueue_test_queue_ ' , true )); ;
36
+ $ this ->queue = $ this ->context -> createQueue ( $ this -> queueName );
37
37
38
38
$ this ->context ->declareQueue ($ this ->queue );
39
39
}
@@ -121,26 +121,4 @@ public function testProduceAndReceiveOneMessageSentDirectlyToTopic()
121
121
122
122
$ this ->assertEquals (__METHOD__ , $ message ->getBody ());
123
123
}
124
-
125
- public function testConsumerReceiveMessageWithZeroTimeout ()
126
- {
127
- $ topic = $ this ->context ->createTopic ($ this ->queueName );
128
-
129
- $ consumer = $ this ->context ->createConsumer ($ topic );
130
-
131
- //guard
132
- $ this ->assertNull ($ consumer ->receive (1000 ));
133
-
134
- $ message = $ this ->context ->createMessage (__METHOD__ );
135
-
136
- $ producer = $ this ->context ->createProducer ();
137
- $ producer ->send ($ topic , $ message );
138
- usleep (1000 );
139
- $ actualMessage = $ consumer ->receive (0 );
140
-
141
- $ this ->assertInstanceOf (SqsMessage::class, $ actualMessage );
142
- $ consumer ->acknowledge ($ actualMessage );
143
-
144
- $ this ->assertEquals (__METHOD__ , $ message ->getBody ());
145
- }
146
124
}
0 commit comments