diff --git a/connection.go b/connection.go index 1179046..7862fa3 100644 --- a/connection.go +++ b/connection.go @@ -74,6 +74,7 @@ func NewConnection(urlStr string, config *Config, logger *slog.Logger) (*Connect dialer: NewDialer(), socket: nil, config: config, + logger: logger, incoming: make(chan []byte, 100), outgoing: make(chan []byte, 100), errors: make(chan error, 10), @@ -81,14 +82,6 @@ func NewConnection(urlStr string, config *Config, logger *slog.Logger) (*Connect done: make(chan struct{}), } - if logger != nil { - conn.logger = logger.With( - "library", "honeybee", - "component", "Connection", - "url", parsedURL.String(), - ) - } - return conn, nil } @@ -110,6 +103,7 @@ func NewConnectionFromSocket(socket Socket, config *Config, logger *slog.Logger) dialer: nil, socket: socket, config: config, + logger: logger, incoming: make(chan []byte, 100), outgoing: make(chan []byte, 100), errors: make(chan error, 10), @@ -117,13 +111,6 @@ func NewConnectionFromSocket(socket Socket, config *Config, logger *slog.Logger) done: make(chan struct{}), } - if logger != nil { - conn.logger = logger.With( - "library", "honeybee", - "component", "Connection", - ) - } - if config.CloseHandler != nil { socket.SetCloseHandler(config.CloseHandler) }