DEVOPS-10175 linux remove channel closes

BITERP · Jul 1, 2024 · 1ccc3a9 · 1ccc3a9
1 parent dbfe2f8
commit 1ccc3a9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/Connection.cpp b/src/Connection.cpp
@@ -42,7 +42,7 @@ void Connection::loop() {
 	std::unique_lock<std::mutex> lock(_mutex);
 	if (!cvBroken.wait_for(lock, std::chrono::seconds(timeout), [&] { return broken; })) {
 		broken = false;
-		channel()->close();
+		//channel()->close();
 		throw Biterp::Error("AMQP server timeout error");
 	}
 	broken = false;

diff --git a/src/linux/ConnectionImpl.cpp b/src/linux/ConnectionImpl.cpp
@@ -73,9 +73,9 @@ void ConnectionImpl::openChannel(std::unique_ptr<AMQP::TcpChannel>& channel) {
 }
 
 void ConnectionImpl::closeChannel(std::unique_ptr<AMQP::TcpChannel>& channel) {
-    if (channel && channel->usable()) {
-        channel->close();
-    }
+    //if (channel && channel->usable()) {
+    //    channel->close();
+    //}
     channel.reset(nullptr);
 }