check for connection mq connection open

This commit is contained in:
abhishek9686 2024-03-26 11:46:09 +07:00
parent cdfab770ae
commit 13b11033b0

View file

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