|
@@ -38,8 +38,8 @@ class LogConsumer implements ConsumerInterface
|
|
|
$msgBody = json_decode($msg->body, true);
|
|
|
if (!json_last_error() && isset($msgBody['message']) && !empty($msgBody['message'])) {
|
|
|
$message = $msgBody['message'];
|
|
|
- $level = $msgBody['level_name'];
|
|
|
- $channel = $msgBody['channel'];
|
|
|
+ $level = isset($msgBody['level_name']) ? $msgBody['level_name'] : $level;
|
|
|
+ $channel = isset($msgBody['channel']) ? $msgBody['channel'] : $channel;
|
|
|
}
|
|
|
} catch (\Exception $ex) {
|
|
|
$message = $ex->getMessage();
|
|
@@ -67,7 +67,7 @@ class LogConsumer implements ConsumerInterface
|
|
|
private function createLog($message, $level, $channel)
|
|
|
{
|
|
|
$logClass = 'LogBundle\Entity\Log';
|
|
|
- if ($message && class_exists($logClass)) {
|
|
|
+ if ($message !== '' && class_exists($logClass)) {
|
|
|
$log = new $logClass();
|
|
|
$log->setMessage($message);
|
|
|
$log->setLevel($level);
|