From 2a6d6f207e543414b4529c446bb941740ef5e08f Mon Sep 17 00:00:00 2001 From: Fedor Ortyanov Date: Mon, 21 Mar 2022 17:04:50 +0300 Subject: [PATCH] WithPublisherOptionsReconnectInterval fix --- publish.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/publish.go b/publish.go index 3c7f7b3..3b47959 100644 --- a/publish.go +++ b/publish.go @@ -58,8 +58,8 @@ type PublisherOptions struct { // WithPublisherOptionsReconnectInterval sets the interval at which the publisher will // attempt to reconnect to the rabbit server -func WithPublisherOptionsReconnectInterval(reconnectInterval time.Duration) func(options *ConsumerOptions) { - return func(options *ConsumerOptions) { +func WithPublisherOptionsReconnectInterval(reconnectInterval time.Duration) func(options *PublisherOptions) { + return func(options *PublisherOptions) { options.ReconnectInterval = reconnectInterval } }