|
|
@@ -32,7 +32,19 @@ class AmqpHandlerTest extends TestCase
|
|
|
|
|
|
public function testHandle()
|
|
|
{
|
|
|
- $exchange = $this->getExchange();
|
|
|
+ $messages = array();
|
|
|
+
|
|
|
+ $exchange = $this->getMock('AMQPExchange', array('publish', 'setName'), array(), '', false);
|
|
|
+ $exchange->expects($this->once())
|
|
|
+ ->method('setName')
|
|
|
+ ->with('log')
|
|
|
+ ;
|
|
|
+ $exchange->expects($this->any())
|
|
|
+ ->method('publish')
|
|
|
+ ->will($this->returnCallback(function ($message, $routing_key, $flags = 0, $attributes = array()) use (&$messages) {
|
|
|
+ $messages[] = array($message, $routing_key, $flags, $attributes);
|
|
|
+ }))
|
|
|
+ ;
|
|
|
|
|
|
$handler = new AmqpHandler($exchange, 'log');
|
|
|
|
|
|
@@ -60,15 +72,9 @@ class AmqpHandlerTest extends TestCase
|
|
|
|
|
|
$handler->handle($record);
|
|
|
|
|
|
- $messages = $exchange->getMessages();
|
|
|
$this->assertCount(1, $messages);
|
|
|
$messages[0][0] = json_decode($messages[0][0], true);
|
|
|
unset($messages[0][0]['datetime']);
|
|
|
$this->assertEquals($expected, $messages[0]);
|
|
|
}
|
|
|
-
|
|
|
- protected function getExchange()
|
|
|
- {
|
|
|
- return new AmqpExchangeMock();
|
|
|
- }
|
|
|
}
|