Fix

ClickHouse · Feb 20, 2024 · 5ef4a30 · 5ef4a30
1 parent 0b2c3a7
commit 5ef4a30
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/src/Storages/RabbitMQ/RabbitMQSource.cpp b/src/Storages/RabbitMQ/RabbitMQSource.cpp
@@ -129,12 +129,6 @@ Chunk RabbitMQSource::generateImpl()
         return {};
     }
 
-    if (consumer->needChannelUpdate())
-    {
-        LOG_TRACE(log, "Channel {} is in error state, will update", consumer->getChannelID());
-        consumer->updateChannel(storage.getConnection());
-    }
-
     /// Currently it is one time usage source: to make sure data is flushed
     /// strictly by timeout or by block size.
     is_finished = true;