move queuegroup warning

Signed-off-by: Matt Siwiec <[email protected]>
infratographer · Jan 22, 2024 · 91543bb · 91543bb
1 parent b96dd43
commit 91543bb
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/events/nats_config.go b/events/nats_config.go
@@ -55,10 +55,6 @@ type NATSConfig struct {
 
 // Configured checks whether the provider has been configured.
 func (c NATSConfig) Configured() bool {
-	if c.QueueGroup == "" {
-		c.logger.Warn("NATS QueueGroup is not set. Subscriptions will not be durable.")
-	}
-
 	return c.URL != ""
 }
 

diff --git a/events/nats_connection.go b/events/nats_connection.go
@@ -121,6 +121,10 @@ func NewNATSConnection(config NATSConfig, options ...NATSOption) (*NATSConnectio
 		}
 	}
 
+	if config.QueueGroup == "" {
+		nc.logger.Warn("NATS QueueGroup is not set. Subscriptions will not be durable.")
+	}
+
 	conn, err := nats.Connect(config.URL, nc.connectOptions...)
 	if err != nil {
 		return nil, err