@@ -12,14 +12,13 @@ signal unsubscribed(message_id, topic)
12
12
signal log_received (level , message )
13
13
signal error_received (message , reason_code )
14
14
15
-
16
15
@export var client_id : String = "MQTTClient"
17
16
@export var clean_session : bool = true
18
- @export var broker_protocol : String = "tcp"
19
- @export var broker_address : String = "localhost"
20
- @export var broker_port : int = 1883
21
- @export var broker_address_end : String = ""
22
- @export var broker_keep_alive : int = 60
17
+ @export var protocol : String = "tcp"
18
+ @export var address : String = "localhost"
19
+ @export var port : int = 1883
20
+ @export var subdir : String = ""
21
+ @export var keep_alive : int = 60
23
22
@export var username : String = ""
24
23
@export var password : String = ""
25
24
@@ -37,14 +36,14 @@ func initialise() -> void:
37
36
_mqtt_client .connect ("log" , Callable (self , "_on_MQTTClient_log" ))
38
37
_mqtt_client .connect ("error" , Callable (self , "_on_MQTTClient_error" ))
39
38
40
- var rc_initialise : int = _mqtt_client .initialise_full_address (client_id , broker_protocol + "://" + broker_address + ":" + str (broker_port ) + "/" + broker_address_end )
39
+ var rc_initialise : int = _mqtt_client .initialise_full_address (client_id , protocol + "://" + address + ":" + str (port ) + "/" + subdir )
41
40
var rc = rc_initialise
42
41
if not rc_initialise :
43
42
if username != "" and password != "" :
44
43
var rc_username_pwt : int = _mqtt_client .username_pw_set (username , password )
45
44
if rc_username_pwt :
46
45
printerr ("[" + client_id + "] error during connect, " + _mqtt_client .reason_code_string (rc_username_pwt ))
47
- var rc_connect : int = _mqtt_client .broker_connect (clean_session , broker_keep_alive )
46
+ var rc_connect : int = _mqtt_client .broker_connect (clean_session , keep_alive )
48
47
rc = rc + rc_connect
49
48
if rc_connect :
50
49
printerr ("[" + client_id + "] error during connect, " + _mqtt_client .reason_code_string (rc_connect ))
@@ -64,11 +63,11 @@ func reason_code_string(rc: int) -> String:
64
63
return _mqtt_client .reason_code_string (rc )
65
64
66
65
67
- func broker_connect (new_clean_session : bool = false , new_broker_keep_alive : int = 60 ) -> int :
68
- var rc_connect : int = _mqtt_client .broker_connect (new_clean_session , new_broker_keep_alive )
66
+ func broker_connect (new_clean_session : bool = false , new_keep_alive : int = 60 ) -> int :
67
+ var rc_connect : int = _mqtt_client .broker_connect (new_clean_session , new_keep_alive )
69
68
if not rc_connect :
70
69
clean_session = new_clean_session
71
- broker_keep_alive = new_broker_keep_alive
70
+ keep_alive = new_keep_alive
72
71
return rc_connect
73
72
74
73
0 commit comments