Upgrades

beatlabs · Nov 16, 2024 · 4c2c77f · 4c2c77f
1 parent b2f1677
commit 4c2c77f
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 3 deletions.
diff --git a/client/mqtt/publisher_test.go b/client/mqtt/publisher_test.go
@@ -35,7 +35,6 @@ func TestDefaultConfig(t *testing.T) {
 				assert.Equal(t, got.ClientID, tt.args.clientID)
 				assert.Equal(t, u, got.BrokerUrls[0])
 				assert.Equal(t, uint16(30), got.KeepAlive)
-				assert.Equal(t, 5*time.Second, got.ConnectRetryDelay)
 				assert.Equal(t, 1*time.Second, got.ConnectTimeout)
 				assert.NotNil(t, got.OnConnectionUp)
 				assert.NotNil(t, got.OnConnectError)

diff --git a/component/kafka/kafka_test.go b/component/kafka/kafka_test.go
@@ -33,7 +33,7 @@ func Test_messageWrapper(t *testing.T) {
 	assert.Equal(t, ctx, msgCtx)
 	assert.NotNil(t, consumerMessage)
 	assert.Equal(t, "topicone", consumerMessage.Topic)
-	assert.Equal(t, []byte(`{"key":"value"}`), consumerMessage.Value)
+	assert.JSONEq(t, `{"key":"value"}`, string(consumerMessage.Value))
 }
 
 func Test_NewBatch(t *testing.T) {

diff --git a/options_test.go b/options_test.go
@@ -61,7 +61,7 @@ func TestSIGHUP(t *testing.T) {
 
 		err := WithSIGHUP(nil)(svc)
 		assert.Equal(t, errors.New("provided WithSIGHUP handler was nil"), err)
-		assert.Nil(t, nil, svc.sighupHandler)
+		assert.Nil(t, svc.sighupHandler)
 	})
 
 	t.Run("non empty value for sighup handler", func(t *testing.T) {