From 2ed37736dc8de402f7674d52df59c6bff857b989 Mon Sep 17 00:00:00 2001
From: Dong Wook Kim <dehypnosis@gmail.com>
Date: Fri, 3 May 2019 15:46:02 +0900
Subject: [PATCH] allow reconnect in NATS transporter

---
 transit/nats/nats.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/transit/nats/nats.go b/transit/nats/nats.go
index 23163593..f3061c47 100644
--- a/transit/nats/nats.go
+++ b/transit/nats/nats.go
@@ -30,7 +30,7 @@ func CreateNATSTransporter(options NATSOptions) transit.Transport {
 	opts := nats.GetDefaultOptions()
 	opts.Name = options.ClientID
 	opts.Url = options.URL
-	opts.AllowReconnect = false
+	opts.AllowReconnect = true
 	opts.ReconnectWait = time.Second * 2
 	opts.MaxReconnect = -1