@@ -13,8 +13,8 @@ def __init__(self) -> None:
1313 self .publisher = InternalBrokerPublisher ()
1414 self .publisher .start_loop ()
1515
16- def pub (self , topic : str , payload , qos : int = 0 , retain : bool = True ) -> None :
17- if payload == "" :
16+ def pub (self , topic : str , payload , qos : int = 0 , retain : bool = True , no_json : bool = False ) -> None :
17+ if payload == "" or no_json :
1818 self .publisher .client .publish (topic , payload , qos = qos , retain = retain )
1919 else :
2020 self .publisher .client .publish (topic , payload = json .dumps (payload ), qos = qos , retain = retain )
@@ -31,7 +31,8 @@ def __getattr__(self, name):
3131 return getattr (self .instance , name )
3232
3333
34- def pub_single (topic , payload , hostname = "localhost" , port = 1883 , no_json = False , retain = True ):
34+ def pub_single (topic : str , payload , hostname : str = "localhost" , port : int = 1883 ,
35+ no_json : bool = False , retain : bool = True ):
3536 """ Sendet eine einzelne Nachricht an einen Host.
3637
3738 Parameter
@@ -46,10 +47,7 @@ def pub_single(topic, payload, hostname="localhost", port=1883, no_json=False, r
4647 Kompatibilität mit ISSS, die ramdisk verwenden.
4748 """
4849 if hostname == "localhost" :
49- Pub ().pub (topic , payload , qos = 0 , retain = retain )
50+ Pub ().pub (topic , payload , qos = 0 , no_json = no_json , retain = retain )
5051 return
5152
52- if no_json :
53- publish .single (topic , payload , hostname = hostname , port = port , retain = retain )
54- else :
55- publish .single (topic , json .dumps (payload ), hostname = hostname , port = port , retain = retain )
53+ publish .single (topic , payload if no_json else json .dumps (payload ), hostname = hostname , port = port , retain = retain )
0 commit comments