public
/
kuvalda-amqp
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

#110780 Не работает консольная команда

This commit is contained in:
Александр Рыбкин 2025-04-10 14:34:14 +03:00
parent 23b75f0e43
commit c9f761bd69
2 changed files with 16 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
AmqpHelper.php
View File

@ -23,26 +23,26 @@ class AmqpHelper
public function getController($queue) public function getController($queue)
{ {
$key = json_encode($queue); $key = json_encode($queue);
if (!isset(self::$connection[$key])) if (!isset(self::$connection[$key]))
{ {
$credentials = ['heartbeat' => $queue['heartbeat']] ; $credentials = ['heartbeat' => $queue['heartbeat']] ;
self::$connection = new \AMQPConnection($credentials); self::$connection[$key] = new \AMQPConnection($credentials);
self::$connection->setLogin(Yii::$app->params['amqp']['login']); self::$connection[$key]->setLogin(Yii::$app->params['amqp']['login']);
self::$connection->setPassword(Yii::$app->params['amqp']["pass"]); self::$connection[$key]->setPassword(Yii::$app->params['amqp']["pass"]);
self::$connection->setHost(Yii::$app->params['amqp']["serverName"]); self::$connection[$key]->setHost(Yii::$app->params['amqp']["serverName"]);
self::$connection->setPort(Yii::$app->params['amqp']["port"]); self::$connection[$key]->setPort(Yii::$app->params['amqp']["port"]);
self::$connection->setVhost(Yii::$app->params['amqp']["vhostName"]); self::$connection[$key]->setVhost(Yii::$app->params['amqp']["vhostName"]);
try try
{ {
self::$connection->connect(); self::$connection[$key]->connect();
} catch (\AMQPConnectionException $exception) } catch (\AMQPConnectionException $exception)
{ {
AmqpLoger::log('error', $exception->getCode() . ' ' . $exception->getMessage(), 'system'); AmqpLoger::log('error', $exception->getCode() . ' ' . $exception->getMessage(), 'system');
throw $exception; throw $exception;
} }
} }
return self::$connection; return self::$connection[$key];
} }
public function getChannel($queue) public function getChannel($queue)

10
console/AmqpController.php
View File

@ -28,10 +28,14 @@ class AmqpController extends Controller
*/ */
public function actionCreateAllQueue() public function actionCreateAllQueue()
{ {
$amqp = new AmqpHelper; foreach(Yii::$app->params['amqp']['projects'] as $keyProject =>$project)
foreach(Yii::$app->params['amqp']['queue'] as $key =>$value)
{ {
$amqp->getQueueObject($key); $amqp = new AmqpHelper;
$amqp->setProject($keyProject);
foreach ($project["queues"] as $key =>$value)
{
$amqp->getQueueObject($key);
}
} }
return ExitCode::OK; return ExitCode::OK;
} }