|
|
|
@ -61,11 +61,11 @@ class RabbitMQHandler extends AbstractProcessingHandler
|
|
|
|
|
{
|
|
|
|
|
if (is_array($record)) {
|
|
|
|
|
// Implementação para Monolog 1.x
|
|
|
|
|
$this->recordHandler($record);
|
|
|
|
|
$this->processRecord($record);
|
|
|
|
|
}elseif (class_exists(LogRecord::class) && $record instanceof LogRecord) {
|
|
|
|
|
// Implementação para Monolog 2.x
|
|
|
|
|
$arrayRecord = $record->toArray();
|
|
|
|
|
$this->recordHandler($arrayRecord);
|
|
|
|
|
$this->processRecord($arrayRecord);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@ -73,11 +73,11 @@ class RabbitMQHandler extends AbstractProcessingHandler
|
|
|
|
|
* @param array $record
|
|
|
|
|
* @return void
|
|
|
|
|
*/
|
|
|
|
|
protected function recordHandler(array $record)
|
|
|
|
|
protected function processRecord(array $record)
|
|
|
|
|
{
|
|
|
|
|
$data = json_encode($record);
|
|
|
|
|
$msg = new AMQPMessage($data, [
|
|
|
|
|
'delivery_mode' => 2
|
|
|
|
|
'delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT
|
|
|
|
|
]);
|
|
|
|
|
|
|
|
|
|
$this->channel->basic_publish($msg, $this->exchange, $this->routingKey);
|
|
|
|
|