|
@@ 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 |
|
{ |