pkg/stream: fix the error that could occur due to nil option (#331)

rabbitmq · Jul 12, 2024 · baed3d5 · baed3d5
1 parent 1e03806
commit baed3d5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/stream/environment.go b/pkg/stream/environment.go
@@ -573,7 +573,7 @@ func (cc *environmentCoordinator) newProducer(leader *Broker, tcpParameters *TCP
 		if err != nil {
 			return nil, err
 		}
-		clientResult = cc.newClientForProducer(options.ClientProvidedName, leader, tcpParameters, saslConfiguration, rpcTimeout)
+		clientResult = cc.newClientForProducer(clientProvidedName, leader, tcpParameters, saslConfiguration, rpcTimeout)
 		err = clientResult.connect()
 		if err != nil {
 			return nil, err