2
0

SubscribeHandler not working with NonVerbose mode

This commit is contained in:
kevin96666
2020-02-13 12:24:24 +01:00
parent d84791c16d
commit 2760c722c4
+12 -10
View File
@@ -404,25 +404,27 @@ func (rc *RecConn) connect() {
rc.httpResp = httpResp
rc.mu.Unlock()
if err == nil {
if !rc.getNonVerbose() {
log.Printf("Dial: connection was successfully established with %s\n", rc.url)
}
if !rc.hasSubscribeHandler() {
return
}
if rc.hasSubscribeHandler() {
if err := rc.SubscribeHandler(); err != nil {
log.Fatalf("Dial: connect handler failed with %s", err.Error())
if !rc.getNonVerbose() {
log.Fatalf("Dial: connect handler failed with %s", err.Error())
}
}
log.Printf("Dial: connect handler was successfully established with %s\n", rc.url)
if rc.getKeepAliveTimeout() != 0 {
rc.keepAlive()
if !rc.getNonVerbose() {
log.Printf("Dial: connect handler was successfully established with %s\n", rc.url)
}
}
if rc.getKeepAliveTimeout() != 0 {
rc.keepAlive()
}
return
}