Seldaek_monolog/src/Monolog/Handler/AmqpHandler.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\Logger;
use Monolog\Formatter\JsonFormatter;

class AmqpHandler extends AbstractProcessingHandler
{
    /**
     * @var \AMQPExchange $exchange
     */
    protected $exchange;

    /**
     * Describes current issuer (e.g. "database", "landing", "server" and so on)
     * @var string $issuer
     */
    protected $issuer;

    /**
     * @param \AMQPExchange $exchange AMQP exchange, ready for use
     * @param string $exchangeName
     * @param string $issuer isser name
     * @param int $level
     * @param bool $bubble Whether the messages that are handled can bubble up the stack or not
     */
    public function __construct($exchange, $exchangeName = 'log', $issuer = 'default', $level = Logger::DEBUG, $bubble = true)
    {
        if (!$exchange instanceof \AMQPExchange) {
            throw new \LogicException('AMQP handler requires a valid exchange to be provided');
        }

        $this->exchange = $exchange;
        $this->exchange->setName($exchangeName);

        parent::__construct($level, $bubble);
    }

    /**
     * Writes the record down to the log of the implementing handler
     *
     * @param array $record
     * @return void
     */
    protected function write(array $record)
    {
        $data = $record["formatted"];

        $routingKey = sprintf('%s.%s',
            substr($record['level_name'], 0, 4),
            $this->getIssuer());

        //we do not check return value because no handler really does
        $this->exchange->publish($data,
            strtolower($routingKey),
            0,
            array(
                'delivery_mode' => 2,
                'Content-type' => 'application/json'
            ));
    }

    /**
     * {@inheritDoc}
     */
    protected function getDefaultFormatter()
    {
        return new JsonFormatter();
    }

    /**
     * Issuer setter
     * @param string $issuer
     */
    public function setIssuer($issuer)
    {
        $this->issuer = $issuer;
    }

    /**
     * Issuer getter
     * @return string
     */
    public function getIssuer()
    {
        return $this->issuer;
    }
}