diff --git a/src/Storages/RabbitMQ/RabbitMQSource.cpp b/src/Storages/RabbitMQ/RabbitMQSource.cpp
index 25e4b120f42d..72196e7dd3ca 100644
--- 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;