fix lint

kubemq-io · Feb 1, 2021 · db2ae9c · db2ae9c
1 parent e6ac90e
commit db2ae9c
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/sources/command/client.go b/sources/command/client.go
@@ -45,7 +45,7 @@ func (c *Client) Init(ctx context.Context, cfg config.Spec) error {
 		}
 		client, err := kubemq.NewClient(ctx,
 			kubemq.WithAddress(c.opts.host, c.opts.port),
-			kubemq.WithClientId(c.opts.clientId),
+			kubemq.WithClientId(clientId),
 			kubemq.WithTransportType(kubemq.TransportTypeGRPC),
 			kubemq.WithCheckConnection(true),
 			kubemq.WithAuthToken(c.opts.authToken),

diff --git a/sources/events-store/client.go b/sources/events-store/client.go
@@ -46,7 +46,7 @@ func (c *Client) Init(ctx context.Context, cfg config.Spec) error {
 		}
 		client, err := kubemq.NewClient(ctx,
 			kubemq.WithAddress(c.opts.host, c.opts.port),
-			kubemq.WithClientId(c.opts.clientId),
+			kubemq.WithClientId(clientId),
 			kubemq.WithTransportType(kubemq.TransportTypeGRPC),
 			kubemq.WithCheckConnection(true),
 			kubemq.WithAuthToken(c.opts.authToken),

diff --git a/sources/events/client.go b/sources/events/client.go
@@ -46,7 +46,7 @@ func (c *Client) Init(ctx context.Context, cfg config.Spec) error {
 		}
 		client, err := kubemq.NewClient(ctx,
 			kubemq.WithAddress(c.opts.host, c.opts.port),
-			kubemq.WithClientId(c.opts.clientId),
+			kubemq.WithClientId(clientId),
 			kubemq.WithTransportType(kubemq.TransportTypeGRPC),
 			kubemq.WithCheckConnection(true),
 			kubemq.WithAuthToken(c.opts.authToken),

diff --git a/sources/query/client.go b/sources/query/client.go
@@ -48,7 +48,7 @@ func (c *Client) Init(ctx context.Context, cfg config.Spec) error {
 		}
 		client, err := kubemq.NewClient(ctx,
 			kubemq.WithAddress(c.opts.host, c.opts.port),
-			kubemq.WithClientId(c.opts.clientId),
+			kubemq.WithClientId(clientId),
 			kubemq.WithTransportType(kubemq.TransportTypeGRPC),
 			kubemq.WithCheckConnection(true),
 			kubemq.WithAuthToken(c.opts.authToken),