arena.arena_mqtt

class ArenaMQTT:

Wrapper around Paho MQTT client and EventLoop.

ArenaMQTT( web_host='arenaxr.org', realm='realm', network_latency_interval=10000, on_msg_callback=None, end_program_callback=None, video=False, debug=False, **kwargs)

scene = None

device = None

auth = None

debug

username

remote_auth_token

mqttc_id

config_url

config_data

mqtt_host

subscribe_topic

latency_topic

ignore_topic

mqttc

can_publish

on_msg_callback

end_program_callback

event_loop

mqtt_connect_evt

msg_io

msg_rate_time_start

msg_queue

connected_evt

def parse_cli(self):

Reusable command-line options to give apps flexible options to avoid hard-coding locations.

def generate_client_id(self):

Returns a random 6 digit id

def network_latency_update(self):

Update client latency in $NETWORK/latency

def msg_rate_update(self):

Update Message rate

def run_once(self, func=None, **kwargs):

Runs a user-defined function on startup

def run_after_interval(self, func=None, interval_ms=1000, **kwargs):

Runs a user-defined function after a interval_ms milliseconds

def run_async(self, func=None, **kwargs):

Runs a user defined aynscio function

def run_forever(self, func=None, interval_ms=1000, **kwargs):

Runs a function every interval_ms milliseconds

def run_tasks(self):

Run event loop

def stop_tasks(self):

Stop event loop

async def sleep(self, interval_ms):

Public function for sleeping in async functions

def on_connect(self, client, userdata, flags, rc):

Paho MQTT client on_connect callback

def on_message(self, client, userdata, msg):

async def process_message(self):

def on_disconnect(self, client, userdata, rc):

Paho MQTT client on_disconnect callback

def disconnect(self):

Disconnects Paho MQTT client

def on_publish(self, client, userdata, mid):

def message_callback_add(self, sub, callback):

Subscribes to new topic and adds callback

def message_callback_remove(self, sub):

Unsubscribes to topic and removes callback