diff --git a/shard_connection.cpp b/shard_connection.cpp
index b9fe31c3..6fbcd856 100644
--- a/shard_connection.cpp
+++ b/shard_connection.cpp
@@ -465,8 +465,10 @@ void shard_connection::fill_pipeline(void)
         }
 
         // don't exceed requests
-        if (m_conns_manager->hold_pipeline(m_id))
+        if (m_conns_manager->hold_pipeline(m_id)) {
+            bufferevent_disable(m_bev, EV_WRITE|EV_READ);
             break;
+        }
 
         // client manage requests logic
         m_conns_manager->create_request(now, m_id);