|
@@ -125,7 +125,7 @@ func Keepalive(ctx context.Context) {
|
|
|
|
|
|
// IsConnected - function for determining if the mqclient is connected or not
|
|
// IsConnected - function for determining if the mqclient is connected or not
|
|
func IsConnected() bool {
|
|
func IsConnected() bool {
|
|
- return mqclient != nil && mqclient.IsConnected()
|
|
|
|
|
|
+ return mqclient != nil && mqclient.IsConnectionOpen()
|
|
}
|
|
}
|
|
|
|
|
|
// CloseClient - function to close the mq connection from server
|
|
// CloseClient - function to close the mq connection from server
|