mirror of
https://github.com/Seldaek/monolog.git
synced 2025-02-23 14:32:44 +01:00
137 lines
4.1 KiB
PHP
137 lines
4.1 KiB
PHP
<?php
|
|
|
|
/*
|
|
* This file is part of the Monolog package.
|
|
*
|
|
* (c) Jordi Boggiano <j.boggiano@seld.be>
|
|
*
|
|
* For the full copyright and license information, please view the LICENSE
|
|
* file that was distributed with this source code.
|
|
*/
|
|
|
|
namespace Monolog\Handler;
|
|
|
|
use Monolog\TestCase;
|
|
use Monolog\Logger;
|
|
use PhpAmqpLib\Message\AMQPMessage;
|
|
use PhpAmqpLib\Connection\AMQPConnection;
|
|
|
|
/**
|
|
* @covers Monolog\Handler\RotatingFileHandler
|
|
*/
|
|
class AmqpHandlerTest extends TestCase
|
|
{
|
|
public function testHandleAmqpExt()
|
|
{
|
|
if (!class_exists('AMQPConnection') || !class_exists('AMQPExchange')) {
|
|
$this->markTestSkipped("amqp-php not installed");
|
|
}
|
|
|
|
if (!class_exists('AMQPChannel')) {
|
|
$this->markTestSkipped("Please update AMQP to version >= 1.0");
|
|
}
|
|
|
|
$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');
|
|
|
|
$record = $this->getRecord(Logger::WARNING, 'test', array('data' => new \stdClass, 'foo' => 34));
|
|
|
|
$expected = array(
|
|
array(
|
|
'message' => 'test',
|
|
'context' => array(
|
|
'data' => array(),
|
|
'foo' => 34,
|
|
),
|
|
'level' => 300,
|
|
'level_name' => 'WARNING',
|
|
'channel' => 'test',
|
|
'extra' => array(),
|
|
),
|
|
'warn.test',
|
|
0,
|
|
array(
|
|
'delivery_mode' => 2,
|
|
'Content-type' => 'application/json'
|
|
)
|
|
);
|
|
|
|
$handler->handle($record);
|
|
|
|
$this->assertCount(1, $messages);
|
|
$messages[0][0] = json_decode($messages[0][0], true);
|
|
unset($messages[0][0]['datetime']);
|
|
$this->assertEquals($expected, $messages[0]);
|
|
}
|
|
|
|
public function testHandlePhpAmqpLib()
|
|
{
|
|
if (!class_exists('PhpAmqpLib\Connection\AMQPConnection')) {
|
|
$this->markTestSkipped("php-amqplib not installed");
|
|
}
|
|
|
|
$messages = array();
|
|
|
|
$exchange = $this->getMock('PhpAmqpLib\Channel\AMQPChannel', array('basic_publish', '__destruct'), array(), '', false);
|
|
|
|
$exchange->expects($this->any())
|
|
->method('basic_publish')
|
|
->will($this->returnCallback(function (AMQPMessage $msg, $exchange = "", $routing_key = "", $mandatory = false, $immediate = false, $ticket = null) use (&$messages) {
|
|
$messages[] = array($msg, $exchange, $routing_key, $mandatory, $immediate, $ticket);
|
|
}))
|
|
;
|
|
|
|
$handler = new AmqpHandler($exchange, 'log');
|
|
|
|
$record = $this->getRecord(Logger::WARNING, 'test', array('data' => new \stdClass, 'foo' => 34));
|
|
|
|
$expected = array(
|
|
array(
|
|
'message' => 'test',
|
|
'context' => array(
|
|
'data' => array(),
|
|
'foo' => 34,
|
|
),
|
|
'level' => 300,
|
|
'level_name' => 'WARNING',
|
|
'channel' => 'test',
|
|
'extra' => array(),
|
|
),
|
|
'log',
|
|
'warn.test',
|
|
false,
|
|
false,
|
|
null,
|
|
array(
|
|
'delivery_mode' => 2,
|
|
'content_type' => 'application/json'
|
|
)
|
|
);
|
|
|
|
$handler->handle($record);
|
|
|
|
$this->assertCount(1, $messages);
|
|
|
|
/* @var $msg AMQPMessage */
|
|
$msg = $messages[0][0];
|
|
$messages[0][0] = json_decode($msg->body, true);
|
|
$messages[0][] = $msg->get_properties();
|
|
unset($messages[0][0]['datetime']);
|
|
|
|
$this->assertEquals($expected, $messages[0]);
|
|
}
|
|
}
|