|
@@ -11,37 +11,16 @@ class StatsConsumerListener
|
|
|
{
|
|
|
private $connectionAMQP;
|
|
|
private $channelAMQP;
|
|
|
- private $nameQueue;
|
|
|
|
|
|
public function __construct()
|
|
|
{
|
|
|
- $this->connectionAMQP = new AMQPStreamConnection(getenv('HOST_AMQP'), getenv('PORT_AMQP'), getenv('USER_AMQP'), getenv('PASS_AMQP'));
|
|
|
+ $this->connectionAMQP = new AMQPStreamConnection('amqp', '5672', 'guest', 'guest');
|
|
|
$this->channelAMQP = $this->connectionAMQP->channel();
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * @return mixed
|
|
|
- */
|
|
|
- public function getNameQueue()
|
|
|
- {
|
|
|
- return $this->nameQueue;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * @param mixed $nameQueue
|
|
|
- */
|
|
|
- public function setNameQueue($nameQueue)
|
|
|
- {
|
|
|
- $this->nameQueue = $nameQueue;
|
|
|
- }
|
|
|
-
|
|
|
public function run(){
|
|
|
echo 'Running listener';
|
|
|
|
|
|
- $envNameQueue = getenv('NAME_QUEUE');
|
|
|
- if($this->getNameQueue()){
|
|
|
- $envNameQueue = $this->getNameQueue();
|
|
|
- }
|
|
|
$callbackMessage = function($msg) {
|
|
|
$msgBody = unserialize($msg->body);
|
|
|
|
|
@@ -90,8 +69,8 @@ class StatsConsumerListener
|
|
|
return false;
|
|
|
};
|
|
|
|
|
|
- $this->channelAMQP->queue_declare($envNameQueue, false, true ,false, false);
|
|
|
- $this->channelAMQP->basic_consume($envNameQueue, '', false, true, false, false, $callbackMessage);
|
|
|
+ $this->channelAMQP->queue_declare('command.stats', false, true ,false, false);
|
|
|
+ $this->channelAMQP->basic_consume('command.stats', '', false, true, false, false, $callbackMessage);
|
|
|
|
|
|
while (count($this->channelAMQP->callbacks)){
|
|
|
try {
|