Commit f2e108d6 authored by Tobias Munk's avatar Tobias Munk

use table prefix for redis workaround

parent 35025df2
Pipeline #76544 passed with stage
in 7 minutes and 2 seconds
......@@ -101,15 +101,14 @@ if (getenv('MYSQL_ATTR_SSL_CA')) {
}
// update Redis increment counter according to queue_manager db (workaround)
// TODO: use table_prefix
Event::on(Queue::class, Queue::EVENT_BEFORE_PUSH, function ($event) {
if (Yii::$app->cache->get('queue_id_synced') !== true) {
$lastQueueIdSql = <<<SQL
SELECT `AUTO_INCREMENT`
FROM INFORMATION_SCHEMA.TABLES
WHERE TABLE_SCHEMA = DATABASE() AND TABLE_NAME = 'app_queue_manager'
WHERE TABLE_SCHEMA = DATABASE() AND TABLE_NAME = '{table_prefix}queue_manager'
SQL;
$lastModelId = Yii::$app->db->createCommand($lastQueueIdSql)->queryScalar();
$lastModelId = Yii::$app->db->createCommand($lastQueueIdSql, ['{table_prefix}'=>getenv('DATABASE_TABLE_PREFIX')])->queryScalar();
Yii::$app->redis->set("queue.message_id", $lastModelId);
Yii::$app->cache->set('queue_id_synced', true);
Yii::info("Synced redis queue id with database ($lastModelId)");
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment