From 4c43af576d4f62ea5a98da75d420ad43c7cb0532 Mon Sep 17 00:00:00 2001
From: Heman Jayam <heman_jayam@comcast.com>
Date: Tue, 14 Apr 2026 09:46:50 -0500
Subject: [PATCH] mqtt changes

---
 chans/mqtt/mqtt.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/chans/mqtt/mqtt.go b/chans/mqtt/mqtt.go
index e6ff3d0..3c61f76 100644
--- a/chans/mqtt/mqtt.go
+++ b/chans/mqtt/mqtt.go
@@ -239,7 +239,7 @@ func dur(ms int64) time.Duration {
 
 // Opts constructions an mq.ClientOptions.
 func (o *MQTTOpts) Opts(ctx *dsl.Ctx) (*mq.ClientOptions, error) {
-	opts := mq.ClientOptions{}
+	opts := mq.NewClientOptions()
 
 	ctx.Logf("MQTT Opts broker: %s", o.BrokerURL)
 	opts.AddBroker(o.BrokerURL)
@@ -337,7 +337,7 @@ func (o *MQTTOpts) Opts(ctx *dsl.Ctx) (*mq.ClientOptions, error) {
 		ctx.Logf("MQTT %s connection lost", o.ClientID)
 	}
 
-	return &opts, nil
+	return opts, nil
 }
 
 func (c *MQTT) Kind() dsl.ChanKind {