agatha/pair-monitor
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

use env var for rabbitmq host

Browse Source
This commit is contained in:
agatha 2024-06-12 22:00:21 -04:00
parent 488f173176
commit cb64c49092
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main.py
View File

@ -1,4 +1,5 @@
import asyncio import asyncio
import os
import sys import sys
import threading import threading
from queue import Queue from queue import Queue
@ -28,7 +29,7 @@ async def main():
monitor_thread.start() monitor_thread.start()
# RabbitMQ # RabbitMQ
host = 'localhost' host = os.getenv("RABBITMQ_HOST", "localhost")
port = 5672 port = 5672
exchange = 'matrix_alerts' exchange = 'matrix_alerts'
producer = RabbitMQProducer(host=host, port=port, exchange=exchange) producer = RabbitMQProducer(host=host, port=port, exchange=exchange)