feat (--connection-name): natsOpts() now ensures that connection-name will be set to '"NATS CLI Version " + Version' if no connection-name has been supplied or if the given connection-name is dud
@@ -387,8 +387,13 @@ func natsOpts() []nats.Option {
copts, err := opts.Config.NATSOptions()
kingpin.FatalIfError(err, "configuration error")
+ connectionName := strings.TrimSpace(opts.ConnectionName)
+ if len(connectionName) == 0 {
+ connectionName = "NATS CLI Version " + Version
+ }
+
return append(copts, []nats.Option{
- nats.Name(opts.ConnectionName),
+ nats.Name(connectionName),
nats.MaxReconnects(-1),
nats.DisconnectErrHandler(func(nc *nats.Conn, err error) {
if err != nil {
