pump the queue on reconnection

EOSIO · Jun 11, 2020 · 64ca69a · 64ca69a
1 parent 52bf637
commit 64ca69a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/libraries/reliable_amqp_publisher/reliable_amqp_publisher.cpp b/libraries/reliable_amqp_publisher/reliable_amqp_publisher.cpp
@@ -155,6 +155,7 @@ struct reliable_amqp_publisher_impl final : reliable_amqp_publisher_callbacks {
          elog("Channel error for AMQP connection ${s} publishing to \"${e}\": ${m}; restarting connection", ("s", (std::string)*amqp_address)("e", exchange)("m",s));
          retry_connection();
       });
+      pump_queue();
    }
 
    void amqp_error(const char* message) override {