1
0
mirror of https://github.com/Seldaek/monolog.git synced 2025-10-24 18:16:10 +02:00

get issuer name from record param channel, instead of passing it through handler constructor

This commit is contained in:
pomaxa
2012-06-15 13:18:44 +03:00
parent 6a86fa4444
commit 6b4f4af85f
3 changed files with 31 additions and 28 deletions

View File

@@ -21,12 +21,6 @@ class AmqpHandler extends AbstractProcessingHandler
*/
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
@@ -34,9 +28,8 @@ class AmqpHandler extends AbstractProcessingHandler
* @param int $level
* @param bool $bubble Whether the messages that are handled can bubble up the stack or not
*/
public function __construct(\AMQPExchange $exchange, $exchangeName = 'log', $issuer = 'default', $level = Logger::DEBUG, $bubble = true)
public function __construct(\AMQPExchange $exchange, $exchangeName = 'log', $level = Logger::DEBUG, $bubble = true)
{
$this->issuer = $issuer;
$this->exchange = $exchange;
$this->exchange->setName($exchangeName);
@@ -55,7 +48,7 @@ class AmqpHandler extends AbstractProcessingHandler
$routingKey = sprintf('%s.%s',
substr($record['level_name'], 0, 4),
$this->getIssuer());
$record['channel']);
//we do not check return value because no handler really does
$this->exchange->publish($data,
@@ -74,22 +67,4 @@ class AmqpHandler extends AbstractProcessingHandler
{
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;
}
}