From 3bc827fdab45b054382a0f5e6a1a56584f957b46 Mon Sep 17 00:00:00 2001 From: wagslane Date: Fri, 20 May 2022 09:54:07 -0600 Subject: [PATCH] notify blocked --- publish.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/publish.go b/publish.go index 7113a4f..e10274c 100644 --- a/publish.go +++ b/publish.go @@ -113,6 +113,7 @@ func NewPublisher(url string, config Config, optionFuncs ...func(*PublisherOptio } go publisher.startNotifyFlowHandler() + go publisher.startNotifyBlockedHandler() go publisher.handleRestarts() @@ -123,6 +124,7 @@ func (publisher *Publisher) handleRestarts() { for err := range publisher.chManager.notifyCancelOrClose { publisher.options.Logger.InfoF("successful publisher recovery from: %v", err) go publisher.startNotifyFlowHandler() + go publisher.startNotifyBlockedHandler() if publisher.notifyReturnChan != nil { go publisher.startNotifyReturnHandler() }