fix
This commit is contained in:
parent
2846c1eda0
commit
13ee3230e3
1 changed files with 1 additions and 1 deletions
|
|
@ -61,7 +61,7 @@ func NewClient(addr, queueName string, opts ...Option) *Client {
|
||||||
|
|
||||||
go client.handleReconnect(addr)
|
go client.handleReconnect(addr)
|
||||||
|
|
||||||
return &client, nil
|
return &client
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewPublisher(client *Client) Publisher {
|
func NewPublisher(client *Client) Publisher {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue