parent
2ab3b54628
commit
f2ea680dbe
|
@ -99,11 +99,12 @@ func GetConnectionString(username string, password string, host string) string {
|
|||
|
||||
// New creates a new consumer state instance, and automatically
|
||||
// attempts to connect to the server.
|
||||
func NewClient(exchangeSettings ExchangeSettings, queueSettings QueueSettings, addr string) *Client {
|
||||
func NewClient(exchangeSettings ExchangeSettings, queueSettings QueueSettings, config Config, addr string) *Client {
|
||||
client := Client{
|
||||
logger: log.New(os.Stdout, "", log.LstdFlags),
|
||||
exchangeSettings: exchangeSettings,
|
||||
queueSettings: queueSettings,
|
||||
config: config,
|
||||
done: make(chan bool),
|
||||
}
|
||||
go client.handleReconnect(addr)
|
||||
|
|
Loading…
Reference in New Issue