eventbus/nats: never give up trying to reconnect

Author: jkralik

resource-aggregate/cqrs/eventbus/nats/publisher.go

@@ -36,6 +36,7 @@ func NewPublisher(config Config, opts ...Option) (*Publisher, error) {
 
 // NewPublisher creates a publisher.
 func newPublisher(url string, eventMarshaler MarshalerFunc, options ...nats.Option) (*Publisher, error) {
+	options = append(options, nats.MaxReconnects(-1))
 	conn, err := nats.Connect(url, options...)
 	if err != nil {
 		return nil, fmt.Errorf("cannot connect to server: %w", err)

resource-aggregate/cqrs/eventbus/nats/subscriber.go

@@ -58,6 +58,7 @@ func newSubscriber(url string, eventUnmarshaler UnmarshalerFunc, goroutinePoolGo
 		return nil, fmt.Errorf("invalid errFunc")
 	}
 
+	options = append(options, nats.MaxReconnects(-1))
 	conn, err := nats.Connect(url, options...)
 	if err != nil {
 		return nil, fmt.Errorf("cannot create client: %w", err)