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

Fix tests

Browse Source
This commit is contained in:
kssenii 2021-09-12 16:55:37 +03:00
parent 4e5958d721
commit 0978c8baab
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -224,6 +224,8 @@ std::shared_ptr<Context> StorageRabbitMQ::addSettings(ContextPtr local_context)
void StorageRabbitMQ::loopingFunc() void StorageRabbitMQ::loopingFunc()
{ {
if (!rabbit_is_ready)
return;
if (connection->isConnected()) if (connection->isConnected())
connection->getHandler().startLoop(); connection->getHandler().startLoop();
} }