diff --git a/errors.go b/errors.go index 7933fee..48f9326 100644 --- a/errors.go +++ b/errors.go @@ -7,7 +7,6 @@ var ( // Config errors InvalidKeepaliveTimeout = errors.New("keepalive timeout cannot be negative") InvalidReconnectDelay = errors.New("reconnect delay cannot be negative") - InvalidMaxQueueSize = errors.New("maximum queue size cannot be negative") InvalidBufferSize = errors.New("buffer size must be greater than zero") // Pool errors diff --git a/pool.go b/pool.go index c4bc77c..7d44e3a 100644 --- a/pool.go +++ b/pool.go @@ -142,7 +142,7 @@ func (p *Pool) Peers() []string { defer p.mu.RUnlock() ids := make([]string, 0, len(p.peers)) - for i, _ := range p.peers { + for i := range p.peers { ids = append(ids, i) } return ids @@ -255,9 +255,11 @@ func (p *Pool) Connect(id string) error { } var logger *slog.Logger - if p.handler != nil && p.config.WorkerConfig.LoggingEnabled { - logger = logging.NewOutboundWorkerLogger( - logging.WrapOrDefault(p.config.WorkerConfig.LogLevel, p.handler), p.id, id) + if p.handler != nil && p.config.WorkerConfig != nil { + if p.config.WorkerConfig.LoggingEnabled { + logger = logging.NewOutboundWorkerLogger( + logging.WrapOrDefault(p.config.WorkerConfig.LogLevel, p.handler), p.id, id) + } } // The worker factory must be non-blocking to avoid deadlocks