Recurring Class Reference

Inheritance diagram for Recurring:

Public Member Functions
	__construct (MessageQueueConfig $messageQueueConfig)
	install (SchemaSetupInterface $setup, ModuleContextInterface $context)

Detailed Description

Class Recurring

Definition at line 16 of file Recurring.php.

Constructor & Destructor Documentation

__construct()

__construct

(

MessageQueueConfig

$messageQueueConfig

)

Parameters

MessageQueueConfig

$messageQueueConfig

Definition at line 26 of file Recurring.php.

    {
        $this->messageQueueConfig = $messageQueueConfig;
    }

Member Function Documentation

install()

install	(	SchemaSetupInterface	$setup,
		ModuleContextInterface	$context
	)

{Installs DB schema for a module

Parameters

SchemaSetupInterface	$setup
ModuleContextInterface	$context

Returns

void

}

Populate 'queue' table

Implements InstallSchemaInterface.

Definition at line 34 of file Recurring.php.

    {
        $setup->startSetup();

        $binds = $this->messageQueueConfig->getBinds();
        $queues = [];
        foreach ($binds as $bind) {
            $queues[] = $bind[MessageQueueConfig::BIND_QUEUE];
        }
        $connection = $setup->getConnection();
        $existingQueues = $connection->fetchCol($connection->select()->from($setup->getTable('queue'), 'name'));
        $queues = array_unique(array_diff($queues, $existingQueues));
        if (!empty($queues)) {
            $connection->insertArray($setup->getTable('queue'), ['name'], $queues);
        }

        $setup->endSetup();
    }

---

The documentation for this class was generated from the following file:

• vendor/magento/module-mysql-mq/Setup/Recurring.php