--- a/service/rdf_to_mqtt/rdf_to_mqtt.py	Thu Nov 09 14:55:26 2023 -0800
+++ b/service/rdf_to_mqtt/rdf_to_mqtt.py	Thu Nov 09 17:21:33 2023 -0800
@@ -137,7 +137,7 @@
 
     async def start2():
         global mqtt
-        async with aiomqtt.Client(os.environ.get('MOSQUITTO', "mosquitto-ext"), 1883, client_id="rdf_to_mqtt-%s" % time.time(), keepalive=6) as mqtt:
+        async with aiomqtt.Client('mqtt2.bigasterisk.com', 1883, client_id="rdf_to_mqtt-%s" % time.time(), keepalive=6) as mqtt:
             log.info(f'connected to mqtt {mqtt}')
             while True:
                 await asyncio.sleep(5)