mirror/php-monolog
1
0
Fork 0
mirror of https://github.com/Seldaek/monolog.git synced 2025-02-24 15:02:28 +01:00
Code Issues Releases Wiki Activity

Fixed issues

Browse Source
This commit is contained in:
pomaxa 2012-06-13 11:17:30 +03:00
parent b4a33da363
commit 4c46dce153
1 changed files with 20 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/Monolog/Handler/AmqpHandler.php
View File

@ -1,22 +1,34 @@
<?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; namespace Monolog\Handler;
use Monolog\Logger; use Monolog\Logger;
use Monolog\Formatter\NormalizerFormatter;
use Monolog\Formatter\JsonFormatter; use Monolog\Formatter\JsonFormatter;
/**
* handle sending logs to the rabbitmq, using Amqp protocol;
*
* @author pomaxa none <pomaxa@gmail.com>
*/
class AmqpHandler extends AbstractProcessingHandler class AmqpHandler extends AbstractProcessingHandler
{ {
protected $exchange; protected $exchange;
protected $space; protected $space;
/**
* @param \AMQPConnection $amqp Amqp connection, ready for use
* @param string $exchange exchange name
* @param string $space string to be able better manage routing keys
* @param int $level
* @param bool $bubble
*/
function __construct(\AMQPConnection $amqp, $exchange = 'log', $space = '', $level = Logger::DEBUG, $bubble = true) function __construct(\AMQPConnection $amqp, $exchange = 'log', $space = '', $level = Logger::DEBUG, $bubble = true)
{ {
$this->space = $space;
$channel = new \AMQPChannel($amqp); $channel = new \AMQPChannel($amqp);
$this->exchange = new \AMQPExchange($channel); $this->exchange = new \AMQPExchange($channel);
$this->exchange->setName($exchange); $this->exchange->setName($exchange);
@ -31,11 +43,8 @@ class AmqpHandler extends AbstractProcessingHandler
*/ */
protected function write(array $record) protected function write(array $record)
{ {
$data = $record["formatted"];
$data = json_encode($record["formatted"]);
$routingKey = substr(strtolower($record['level_name']),0,4 ).'.'.$this->space; $routingKey = substr(strtolower($record['level_name']),0,4 ).'.'.$this->space;
$this->exchange->publish($data, $routingKey, 0, $this->exchange->publish($data, $routingKey, 0,
array('delivery_mode' => 2, 'Content-type' => 'application/json')); array('delivery_mode' => 2, 'Content-type' => 'application/json'));
} }
@ -45,6 +54,6 @@ class AmqpHandler extends AbstractProcessingHandler
*/ */
protected function getDefaultFormatter() protected function getDefaultFormatter()
{ {
return new NormalizerFormatter(); return new JsonFormatter();
} }
} }