diff --git a/common/components/RabbitMQ/Component.php b/common/components/RabbitMQ/Component.php index 89da8f8..0ce0f91 100644 --- a/common/components/RabbitMQ/Component.php +++ b/common/components/RabbitMQ/Component.php @@ -111,8 +111,8 @@ class Component extends \yii\base\Component { public function sendToExchange($exchangeName, $routingKey, $message, $exchangeArgs = [], $publishArgs = []) { $message = $this->prepareMessage($message); $channel = $this->getChannel(); - call_user_func_array([$channel, 'exchange_declare'], $this->prepareExchangeArgs($exchangeName, $exchangeArgs)); - call_user_func_array([$channel, 'basic_publish'], $this->preparePublishArgs($message, $exchangeName, $routingKey, $publishArgs)); + $channel->exchange_declare(...$this->prepareExchangeArgs($exchangeName, $exchangeArgs)); + $channel->basic_publish(...$this->preparePublishArgs($message, $exchangeName, $routingKey, $publishArgs)); } /**