21 private $objectManager =
null;
28 private $instanceName =
null;
46 $instanceName = \
Magento\Framework\Amqp\Queue::class
49 $this->configPool = $configPool;
50 $this->instanceName = $instanceName;
57 public function create($queueName, $connectionName)
59 return $this->objectManager->create(
62 'amqpConfig' => $this->configPool->get($connectionName),
63 'queueName' => $queueName
create($queueName, $connectionName)
__construct(\Magento\Framework\ObjectManagerInterface $objectManager, ConfigPool $configPool, $instanceName=\Magento\Framework\Amqp\Queue::class)