ClickandJoin
/
go-cnj-helper
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

added logrus for logging

alpha v1.0.15
alex 2023-01-08 16:04:04 +01:00
parent f0aed7b9d6
commit 1053a20f2c
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
client.go
View File

@ -134,9 +134,8 @@ 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(logger *logrus.Logger, exchangeSettings ExchangeSettings, queueSettings QueueSettings, channelQosSettings ChannelQosSettings, config Config, addr string) *Client {
func NewClient(debugMode bool, exchangeSettings ExchangeSettings, queueSettings QueueSettings, channelQosSettings ChannelQosSettings, config Config, addr string) *Client {
client := Client{
logger: logger,
exchangeSettings: exchangeSettings,
queueSettings: queueSettings,
channelQosSettings: channelQosSettings,
@ -144,6 +143,10 @@ func NewClient(logger *logrus.Logger, exchangeSettings ExchangeSettings, queueSe
done: make(chan bool),
}
if debugMode {
logrus.SetLevel(logrus.DebugLevel)
}
go client.handleReconnect(addr)
return &client
}