[Messenger] minor: Remove logging middleware
This commit is contained in:
parent
9cc2a4ecd1
commit
2e6fbd5210
@ -1,58 +0,0 @@
|
||||
<?php
|
||||
|
||||
/*
|
||||
* This file is part of the Symfony package.
|
||||
*
|
||||
* (c) Fabien Potencier <fabien@symfony.com>
|
||||
*
|
||||
* For the full copyright and license information, please view the LICENSE
|
||||
* file that was distributed with this source code.
|
||||
*/
|
||||
|
||||
namespace Symfony\Component\Messenger\Middleware;
|
||||
|
||||
@trigger_error(sprintf('The "%s" class is deprecated since Symfony 4.3, pass a logger to SendMessageMiddleware instead.', LoggingMiddleware::class), E_USER_DEPRECATED);
|
||||
|
||||
use Psr\Log\LoggerInterface;
|
||||
use Symfony\Component\Messenger\Envelope;
|
||||
|
||||
/**
|
||||
* @author Samuel Roze <samuel.roze@gmail.com>
|
||||
*
|
||||
* @deprecated since 4.3, pass a logger to SendMessageMiddleware instead
|
||||
*/
|
||||
class LoggingMiddleware implements MiddlewareInterface
|
||||
{
|
||||
private $logger;
|
||||
|
||||
public function __construct(LoggerInterface $logger)
|
||||
{
|
||||
$this->logger = $logger;
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
*/
|
||||
public function handle(Envelope $envelope, StackInterface $stack): Envelope
|
||||
{
|
||||
$message = $envelope->getMessage();
|
||||
$context = [
|
||||
'message' => $message,
|
||||
'class' => \get_class($envelope->getMessage()),
|
||||
];
|
||||
$this->logger->debug('Starting handling message "{class}"', $context);
|
||||
|
||||
try {
|
||||
$envelope = $stack->next()->handle($envelope, $stack);
|
||||
} catch (\Throwable $e) {
|
||||
$context['exception'] = $e;
|
||||
$this->logger->warning('An exception occurred while handling message "{class}": '.$e->getMessage(), $context);
|
||||
|
||||
throw $e;
|
||||
}
|
||||
|
||||
$this->logger->debug('Finished handling message "{class}"', $context);
|
||||
|
||||
return $envelope;
|
||||
}
|
||||
}
|
@ -1,61 +0,0 @@
|
||||
<?php
|
||||
|
||||
/*
|
||||
* This file is part of the Symfony package.
|
||||
*
|
||||
* (c) Fabien Potencier <fabien@symfony.com>
|
||||
*
|
||||
* For the full copyright and license information, please view the LICENSE
|
||||
* file that was distributed with this source code.
|
||||
*/
|
||||
|
||||
namespace Symfony\Component\Messenger\Tests\Middleware;
|
||||
|
||||
use Psr\Log\LoggerInterface;
|
||||
use Symfony\Component\Messenger\Envelope;
|
||||
use Symfony\Component\Messenger\Middleware\LoggingMiddleware;
|
||||
use Symfony\Component\Messenger\Test\Middleware\MiddlewareTestCase;
|
||||
use Symfony\Component\Messenger\Tests\Fixtures\DummyMessage;
|
||||
|
||||
/**
|
||||
* @group legacy
|
||||
*/
|
||||
class LoggingMiddlewareTest extends MiddlewareTestCase
|
||||
{
|
||||
public function testDebugLogAndNextMiddleware()
|
||||
{
|
||||
$message = new DummyMessage('Hey');
|
||||
$envelope = new Envelope($message);
|
||||
|
||||
$logger = $this->createMock(LoggerInterface::class);
|
||||
$logger
|
||||
->expects($this->exactly(2))
|
||||
->method('debug')
|
||||
;
|
||||
|
||||
(new LoggingMiddleware($logger))->handle($envelope, $this->getStackMock());
|
||||
}
|
||||
|
||||
/**
|
||||
* @expectedException \RuntimeException
|
||||
* @expectedExceptionMessage Thrown from next middleware.
|
||||
*/
|
||||
public function testWarningLogOnException()
|
||||
{
|
||||
$message = new DummyMessage('Hey');
|
||||
$envelope = new Envelope($message);
|
||||
|
||||
$logger = $this->createMock(LoggerInterface::class);
|
||||
$logger
|
||||
->expects($this->once())
|
||||
->method('debug')
|
||||
;
|
||||
$logger
|
||||
->expects($this->once())
|
||||
->method('warning')
|
||||
;
|
||||
$stack = $this->getThrowingStackMock();
|
||||
|
||||
(new LoggingMiddleware($logger))->handle($envelope, $stack);
|
||||
}
|
||||
}
|
Reference in New Issue
Block a user