mirror of
https://github.com/Seldaek/monolog.git
synced 2025-10-21 00:26:10 +02:00
Type fixes
This commit is contained in:
@@ -32,14 +32,14 @@ class AmqpHandler extends AbstractProcessingHandler
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* @param AMQPExchange|AMQPChannel $exchange AMQPExchange (php AMQP ext) or PHP AMQP lib channel, ready for use
|
* @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 string|null $exchangeName Optional exchange name, for AMQPChannel (PhpAmqpLib) only
|
||||||
* @param string|int $level The minimum logging level at which this handler will be triggered
|
* @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
|
* @param bool $bubble Whether the messages that are handled can bubble up the stack or not
|
||||||
*/
|
*/
|
||||||
public function __construct($exchange, ?string $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) {
|
if ($exchange instanceof AMQPChannel) {
|
||||||
$this->exchangeName = $exchangeName;
|
$this->exchangeName = (string) $exchangeName;
|
||||||
} elseif (!$exchange instanceof AMQPExchange) {
|
} elseif (!$exchange instanceof AMQPExchange) {
|
||||||
throw new \InvalidArgumentException('PhpAmqpLib\Channel\AMQPChannel or AMQPExchange instance required');
|
throw new \InvalidArgumentException('PhpAmqpLib\Channel\AMQPChannel or AMQPExchange instance required');
|
||||||
} elseif ($exchangeName) {
|
} elseif ($exchangeName) {
|
||||||
|
@@ -74,7 +74,7 @@ class BrowserConsoleHandler extends AbstractProcessingHandler
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public function close()
|
public function close(): void
|
||||||
{
|
{
|
||||||
self::resetStatic();
|
self::resetStatic();
|
||||||
}
|
}
|
||||||
|
@@ -102,7 +102,7 @@ class GroupHandler extends Handler implements ProcessableHandlerInterface, Reset
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public function close()
|
public function close(): void
|
||||||
{
|
{
|
||||||
parent::close();
|
parent::close();
|
||||||
|
|
||||||
|
@@ -135,7 +135,7 @@ class Logger implements LoggerInterface, ResettableInterface
|
|||||||
protected $timezone;
|
protected $timezone;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @var ?callable
|
* @var callable|null
|
||||||
*/
|
*/
|
||||||
protected $exceptionHandler;
|
protected $exceptionHandler;
|
||||||
|
|
||||||
@@ -343,7 +343,7 @@ class Logger implements LoggerInterface, ResettableInterface
|
|||||||
* This is useful at the end of a request and will be called automatically on every handler
|
* This is useful at the end of a request and will be called automatically on every handler
|
||||||
* when they get destructed.
|
* when they get destructed.
|
||||||
*/
|
*/
|
||||||
public function close()
|
public function close(): void
|
||||||
{
|
{
|
||||||
foreach ($this->handlers as $handler) {
|
foreach ($this->handlers as $handler) {
|
||||||
$handler->close();
|
$handler->close();
|
||||||
@@ -360,7 +360,7 @@ class Logger implements LoggerInterface, ResettableInterface
|
|||||||
* have a long running process like a worker or an application server serving multiple requests
|
* have a long running process like a worker or an application server serving multiple requests
|
||||||
* in one process.
|
* in one process.
|
||||||
*/
|
*/
|
||||||
public function reset()
|
public function reset(): void
|
||||||
{
|
{
|
||||||
foreach ($this->handlers as $handler) {
|
foreach ($this->handlers as $handler) {
|
||||||
if ($handler instanceof ResettableInterface) {
|
if ($handler instanceof ResettableInterface) {
|
||||||
|
Reference in New Issue
Block a user