Merge pull request #10111 from EOSIO/shutdown-amqp

amqp shutdown hang
EOSIO · Mar 5, 2021 · 634657f · 634657f
2 parents edabd8a + 284eb62
commit 634657f
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/libraries/amqp/include/eosio/amqp/amqp_handler.hpp b/libraries/amqp/include/eosio/amqp/amqp_handler.hpp
@@ -99,10 +99,18 @@ class amqp {
          std::promise<void> stop_promise;
          auto future = stop_promise.get_future();
          boost::asio::post( *handler_->amqp_strand(), [&]() {
-            if( channel_ ) {
+            if( channel_ && channel_->usable() ) {
                auto& cb = channel_->close();
                cb.onFinalize( [&]() {
-                  stop_promise.set_value();
+                  try {
+                     stop_promise.set_value();
+                  } catch(...) {}
+               } );
+               cb.onError( [&](const char* message) {
+                  elog( "Error on stop: ${m}", ("m", message) );
+                  try {
+                     stop_promise.set_value();
+                  } catch(...) {}
                } );
             } else {
                stop_promise.set_value();