1
0
mirror of https://github.com/Seldaek/monolog.git synced 2025-10-22 00:56:08 +02:00
This commit is contained in:
Jordi Boggiano
2016-03-01 18:00:33 +00:00
parent fa96f6aa8f
commit 127d7720c9
5 changed files with 64 additions and 60 deletions

View File

@@ -83,6 +83,7 @@ class AmqpHandler extends AbstractProcessingHandler
{
if ($this->exchange instanceof AMQPExchange) {
parent::handleBatch($records);
return;
}
@@ -107,7 +108,7 @@ class AmqpHandler extends AbstractProcessingHandler
/**
* Gets the routing key for the AMQP exchange
*
* @param array $record
* @param array $record
* @return string
*/
private function getRoutingKey(array $record)
@@ -123,7 +124,7 @@ class AmqpHandler extends AbstractProcessingHandler
}
/**
* @param string $data
* @param string $data
* @return AMQPMessage
*/
private function createAmqpMessage($data)