From 64ca69ace3dfdaaa8e4ede0532b7de2e8ee5ccb9 Mon Sep 17 00:00:00 2001
From: Matt Witherspoon <32485495+spoonincode@users.noreply.github.com>
Date: Thu, 28 May 2020 19:50:06 -0400
Subject: [PATCH] pump the queue on reconnection

---
 libraries/reliable_amqp_publisher/reliable_amqp_publisher.cpp | 1 +
 1 file changed, 1 insertion(+)

diff --git a/libraries/reliable_amqp_publisher/reliable_amqp_publisher.cpp b/libraries/reliable_amqp_publisher/reliable_amqp_publisher.cpp
index c4e99bd48ec..7c8c17956d9 100644
--- 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 {