panic on empty values
This commit is contained in:
parent
23b439f0aa
commit
2846c1eda0
1 changed files with 3 additions and 3 deletions
|
|
@ -31,13 +31,13 @@ type options struct {
|
||||||
consumerBurstSize int
|
consumerBurstSize int
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewClient(addr, queueName string, opts ...Option) (*Client, error) {
|
func NewClient(addr, queueName string, opts ...Option) *Client {
|
||||||
if addr == "" {
|
if addr == "" {
|
||||||
return nil, errNoAddr
|
log.Fatal(errNoAddr)
|
||||||
}
|
}
|
||||||
|
|
||||||
if queueName == "" {
|
if queueName == "" {
|
||||||
return nil, errNoQueue
|
log.Fatal(errNoQueue)
|
||||||
}
|
}
|
||||||
|
|
||||||
client := Client{
|
client := Client{
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue