mirror/php-monolog
1
0
Fork 0
mirror of https://github.com/Seldaek/monolog.git synced 2025-10-20 16:16:37 +02:00
Code Issues Releases Wiki Activity

More type hints on some handler classes

Browse Source
This commit is contained in:
Jordi Boggiano
2018-07-18 09:55:49 +02:00
parent 06143b03e5
commit 334b8d8783
13 changed files with 43 additions and 71 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/Monolog/Handler/AmqpHandler.php
View File

@@ -33,10 +33,10 @@ class AmqpHandler extends AbstractProcessingHandler
/**
* @param AMQPExchange|AMQPChannel $exchange AMQPExchange (php AMQP ext) or PHP AMQP lib channel, ready for use
* @param string $exchangeName Optional exchange name, for AMQPChannel (PhpAmqpLib) only
* @param int $level
* @param string|int $level The minimum logging level at which this handler will be triggered
* @param bool $bubble Whether the messages that are handled can bubble up the stack or not
*/
public function __construct($exchange, $exchangeName = null, $level = Logger::DEBUG, bool $bubble = true)
public function __construct($exchange, ?string $exchangeName = null, $level = Logger::DEBUG, bool $bubble = true)
{
if ($exchange instanceof AMQPChannel) {
$this->exchangeName = $exchangeName;
@@ -108,25 +108,18 @@ class AmqpHandler extends AbstractProcessingHandler
/**
* Gets the routing key for the AMQP exchange
*
* @param array $record
* @return string
*/
protected function getRoutingKey(array $record)
protected function getRoutingKey(array $record): string
{
$routingKey = sprintf('%s.%s', $record['level_name'], $record['channel']);
return strtolower($routingKey);
}
/**
* @param string $data
* @return AMQPMessage
*/
private function createAmqpMessage($data)
private function createAmqpMessage(string $data): AMQPMessage
{
return new AMQPMessage(
(string) $data,
$data,
[
'delivery_mode' => 2,
'content_type' => 'application/json',