@@ -561,7 +561,7 @@ def connect(self, clean_session=True, host=None, port=None, keep_alive=None):
561
561
562
562
def disconnect (self ):
563
563
"""Disconnects the MiniMQTT client from the MQTT broker."""
564
- self .is_connected ()
564
+ self ._connected ()
565
565
if self .logger is not None :
566
566
self .logger .debug ("Sending DISCONNECT packet to broker" )
567
567
try :
@@ -582,7 +582,7 @@ def ping(self):
582
582
there is an active network connection.
583
583
Returns response codes of any messages received while waiting for PINGRESP.
584
584
"""
585
- self .is_connected ()
585
+ self ._connected ()
586
586
if self .logger is not None :
587
587
self .logger .debug ("Sending PINGREQ" )
588
588
self ._sock .send (MQTT_PINGREQ )
@@ -607,7 +607,7 @@ def publish(self, topic, msg, retain=False, qos=0):
607
607
:param int qos: Quality of Service level for the message, defaults to zero.
608
608
609
609
"""
610
- self .is_connected ()
610
+ self ._connected ()
611
611
self ._valid_topic (topic )
612
612
if "+" in topic or "#" in topic :
613
613
raise MMQTTException ("Publish topic can not contain wildcards." )
@@ -703,7 +703,7 @@ def subscribe(self, topic, qos=0):
703
703
(send at least once), or ``2`` (send exactly once).
704
704
705
705
"""
706
- self .is_connected ()
706
+ self ._connected ()
707
707
topics = None
708
708
if isinstance (topic , tuple ):
709
709
topic , qos = topic
@@ -1046,13 +1046,18 @@ def _valid_qos(qos_level):
1046
1046
else :
1047
1047
raise MMQTTException ("QoS must be an integer." )
1048
1048
1049
- def is_connected (self ):
1049
+ def _connected (self ):
1050
1050
"""Returns MQTT client session status as True if connected, raises
1051
1051
a `MMQTTException` if `False`.
1052
1052
"""
1053
- if self ._sock is None or self ._is_connected is False :
1054
- raise MMQTTException ("MiniMQTT is not connected." )
1055
- return self ._is_connected
1053
+ if not self .is_connected ():
1054
+ raise MMQTTException ("MiniMQTT is not connected" )
1055
+
1056
+ def is_connected (self ):
1057
+ """Returns MQTT client session status as True if connected, False
1058
+ if not.
1059
+ """
1060
+ return self ._is_connected and self ._sock is not None
1056
1061
1057
1062
# Logging
1058
1063
def enable_logger (self , logger , log_level = 20 ):
0 commit comments