formatting and cleanup

destination.go

@@ -114,7 +114,10 @@ func (d *Destination) Open(ctx context.Context) (err error) {
 		if err != nil {
 			return fmt.Errorf("failed to bind queue to exchange: %w", err)
 		}
-		sdk.Logger(ctx).Debug().Msgf("bound queue %s to exchange %s with routing key %s", d.config.QueueName, d.config.Exchange.Name, d.config.RoutingKey)
+		sdk.Logger(ctx).Debug().Msgf(
+			"bound queue %s to exchange %s with routing key %s",
+			d.config.QueueName, d.config.Exchange.Name, d.config.RoutingKey,
+		)
 	}
 
 	return nil

source.go

@@ -84,7 +84,10 @@ func (s *Source) Open(ctx context.Context, sdkPos sdk.Position) (err error) {
 		}
 
 		if s.config.QueueName != "" && s.config.QueueName != pos.QueueName {
-			return fmt.Errorf("the old position contains a different queue name than the connector configuration (%q vs %q), please check if the configured queue name changed since the last run", pos.QueueName, s.config.QueueName)
+			return fmt.Errorf(
+				"the old position contains a different queue name than the connector configuration (%q vs %q), please check if the configured queue name changed since the last run",
+				pos.QueueName, s.config.QueueName,
+			)
 		}
 
 		sdk.Logger(ctx).Debug().Msg("got queue name from given position")

utils_test.go

@@ -25,13 +25,6 @@ import (
 	"github.com/rabbitmq/amqp091-go"
 )
 
-func init() {
-	// Uncomment this to set up a logger for tests to use. By default
-	// sdk.Logger log calls won't output anything
-	// log := log.Output(zerolog.ConsoleWriter{Out: os.Stderr})
-	// zerolog.DefaultContextLogger = &log
-}
-
 // cfgToMap converts a config struct to a map. This is useful for more type
 // safety on tests.
 func cfgToMap(cfg any) map[string]string {