thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-21 23:21:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix tests

Browse Source
This commit is contained in:
kssenii 2021-11-03 11:57:33 +03:00
parent b899dd9af5
commit 285742dcba
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Storages/RabbitMQ/StorageRabbitMQ.cpp
View File

@ -242,7 +242,6 @@ void StorageRabbitMQ::loopingFunc()
if (connection->isConnected())
{
connection->getHandler().updateLoopState(Loop::RUN);
connection->getHandler().startLoop();
}
}
@ -656,6 +655,7 @@ Pipe StorageRabbitMQ::read(
if (!connection->getHandler().loopRunning() && connection->isConnected())
{
connection->getHandler().updateLoopState(Loop::RUN);
looping_task->activateAndSchedule();
}
@ -1006,6 +1006,7 @@ bool StorageRabbitMQ::streamToViews()
if (!connection->getHandler().loopRunning())
{
connection->getHandler().updateLoopState(Loop::RUN);
looping_task->activateAndSchedule();
}