diff --git a/handler.go b/handler.go index 503d9c1..5f8c93e 100644 --- a/handler.go +++ b/handler.go @@ -31,13 +31,13 @@ type options struct { consumerBurstSize int } -func NewClient(addr, queueName string, opts ...Option) (*Client, error) { +func NewClient(addr, queueName string, opts ...Option) *Client { if addr == "" { - return nil, errNoAddr + log.Fatal(errNoAddr) } if queueName == "" { - return nil, errNoQueue + log.Fatal(errNoQueue) } client := Client{