@@ 8-33 (lines=26) @@ | ||
5 | use Psr\Log\LoggerInterface; |
|
6 | use Happyr\SimpleBusBundle\Message\Command\Ping; |
|
7 | ||
8 | class PingHandler |
|
9 | { |
|
10 | /** |
|
11 | * @var LoggerInterface |
|
12 | */ |
|
13 | private $logger; |
|
14 | ||
15 | /** |
|
16 | * @param LoggerInterface $logger |
|
17 | */ |
|
18 | public function __construct(LoggerInterface $logger = null) |
|
19 | { |
|
20 | $this->logger = $logger; |
|
21 | } |
|
22 | ||
23 | public function handle(Ping $command) |
|
24 | { |
|
25 | $data = $command->getData(); |
|
26 | ||
27 | if (null !== $this->logger) { |
|
28 | $this->logger->error('Ping command handler works!', ['data' => $data]); |
|
29 | } |
|
30 | ||
31 | return; |
|
32 | } |
|
33 | } |
|
34 |
@@ 8-33 (lines=26) @@ | ||
5 | use Psr\Log\LoggerInterface; |
|
6 | use Happyr\SimpleBusBundle\Message\Event\Pong; |
|
7 | ||
8 | class WhenPongWriteLog |
|
9 | { |
|
10 | /** |
|
11 | * @var LoggerInterface |
|
12 | */ |
|
13 | private $logger; |
|
14 | ||
15 | /** |
|
16 | * @param LoggerInterface $logger |
|
17 | */ |
|
18 | public function __construct(LoggerInterface $logger = null) |
|
19 | { |
|
20 | $this->logger = $logger; |
|
21 | } |
|
22 | ||
23 | public function notify(Pong $event) |
|
24 | { |
|
25 | $data = $event->getData(); |
|
26 | ||
27 | if (null !== $this->logger) { |
|
28 | $this->logger->error('Pong event subscriber works!', ['data' => $data]); |
|
29 | } |
|
30 | ||
31 | return; |
|
32 | } |
|
33 | } |
|
34 |