@@ 157-164 (lines=8) @@ | ||
154 | $this->assertTrue($this->provider->delete($messageId)); |
|
155 | } |
|
156 | ||
157 | public function testDeleteAReservedMessage() |
|
158 | { |
|
159 | $this->provider = $this->getIronMqProvider(['push_notifications' => false]); |
|
160 | $this->provider->publish(['Hello' => 'World']); |
|
161 | $messages = $this->provider->receive(); |
|
162 | ||
163 | $this->assertTrue($this->provider->delete($messages[0]->getId())); |
|
164 | } |
|
165 | ||
166 | public function testOnNotification() |
|
167 | { |
|
@@ 181-192 (lines=12) @@ | ||
178 | ); |
|
179 | } |
|
180 | ||
181 | public function testOnMessageReceived() |
|
182 | { |
|
183 | $this->provider = $this->getIronMqProvider(['push_notifications' => false]); |
|
184 | $this->provider->destroy(); |
|
185 | $this->provider->publish(['bob' => 'ball']); |
|
186 | $messages = $this->provider->receive(); |
|
187 | ||
188 | $this->provider->onMessageReceived(new MessageEvent( |
|
189 | 'test', |
|
190 | $messages[0] |
|
191 | )); |
|
192 | } |
|
193 | ||
194 | public function testQueueInfo() |
|
195 | { |