release v1.5.1

Author: Lior Nabat

Taskfile.yml

@@ -1,7 +1,7 @@
 version: '3'
 vars:
   BINARY_NAME: kubemq-sources
-  VERSION: v1.5.0
+  VERSION: v1.5.1
 tasks:
   default:
     cmds:

logs/kubemq-sources.log

@@ -187690,3 +187690,4 @@ caused by: context canceled	{"source": "s3.down"}
 2022-12-12T07:38:30.498+0200	INFO	generated manifest.json completed	{"source": "kubemq-sources"}
 2022-12-12T07:51:55.567+0200	INFO	generated manifest.json completed	{"source": "kubemq-sources"}
 2023-05-06T11:19:18.215+0300	INFO	generated manifest.json completed	{"source": "kubemq-sources"}
+2023-05-06T20:09:25.139+0300	INFO	generated manifest.json completed	{"source": "kubemq-sources"}

targets/command/client.go

@@ -45,7 +45,7 @@ func (c *Client) Init(ctx context.Context, cfg config.Spec, bindingName string,
 	}
 	c.client, err = kubemq.NewClient(ctx,
 		kubemq.WithAddress(c.opts.host, c.opts.port),
-		kubemq.WithClientId(fmt.Sprintf("kubemq-sources/%s/%s", bindingName, c.opts.clientId)),
+		kubemq.WithClientId(fmt.Sprintf("kubemq-sources_%s_%s", bindingName, c.opts.clientId)),
 		kubemq.WithTransportType(kubemq.TransportTypeGRPC),
 		kubemq.WithAuthToken(c.opts.authToken),
 		// making sure that this stays false in order the http source will work correctly

targets/events-store/client.go

@@ -48,7 +48,7 @@ func (c *Client) Init(ctx context.Context, cfg config.Spec, bindingName string,
 
 	c.client, err = kubemq.NewClient(ctx,
 		kubemq.WithAddress(c.opts.host, c.opts.port),
-		kubemq.WithClientId(fmt.Sprintf("kubemq-sources/%s/%s", bindingName, c.opts.clientId)),
+		kubemq.WithClientId(fmt.Sprintf("kubemq-sources_%s_%s", bindingName, c.opts.clientId)),
 		kubemq.WithTransportType(kubemq.TransportTypeGRPC),
 		kubemq.WithAuthToken(c.opts.authToken),
 		// making sure that this stays false in order the http source will work correctly

targets/events/client.go

@@ -52,7 +52,7 @@ func (c *Client) Init(ctx context.Context, cfg config.Spec, bindingName string,
 
 	c.client, err = kubemq.NewClient(ctx,
 		kubemq.WithAddress(c.opts.host, c.opts.port),
-		kubemq.WithClientId(fmt.Sprintf("kubemq-sources/%s/%s", bindingName, c.opts.clientId)),
+		kubemq.WithClientId(fmt.Sprintf("kubemq-sources_%s_%s", bindingName, c.opts.clientId)),
 		kubemq.WithTransportType(kubemq.TransportTypeGRPC),
 		kubemq.WithAuthToken(c.opts.authToken),
 		// making sure that this stays false in order the http source will work correctly

targets/query/client.go

@@ -39,7 +39,7 @@ func (c *Client) Init(ctx context.Context, cfg config.Spec, bindingName string,
 	}
 	c.client, err = kubemq.NewClient(ctx,
 		kubemq.WithAddress(c.opts.host, c.opts.port),
-		kubemq.WithClientId(fmt.Sprintf("kubemq-sources/%s/%s", bindingName, c.opts.clientId)),
+		kubemq.WithClientId(fmt.Sprintf("kubemq-sources_%s_%s", bindingName, c.opts.clientId)),
 		kubemq.WithTransportType(kubemq.TransportTypeGRPC),
 		kubemq.WithAuthToken(c.opts.authToken),
 		// making sure that this stays false in order the http source will work correctly

targets/queue/client.go

@@ -39,7 +39,7 @@ func (c *Client) Init(ctx context.Context, cfg config.Spec, bindingName string,
 	}
 	c.client, err = queues_stream.NewQueuesStreamClient(ctx,
 		queues_stream.WithAddress(c.opts.host, c.opts.port),
-		queues_stream.WithClientId(fmt.Sprintf("kubemq-sources/%s/%s", bindingName, c.opts.clientId)),
+		queues_stream.WithClientId(fmt.Sprintf("kubemq-sources_%s_%s", bindingName, c.opts.clientId)),
 		queues_stream.WithCheckConnection(true),
 		queues_stream.WithAutoReconnect(true),
 		queues_stream.WithAuthToken(c.opts.authToken),