pavel/nats-scheduler
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1450

Browse Source
This commit is contained in:
pavel
2026-02-11 14:50:30 +02:00
parent 46ea4359ed
commit 5d19eb0f26
1 changed files with 12 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
files/nats_registration_listener.py
View File

@@ -402,17 +402,18 @@ async def main():
)
# Publish disabled (kept in place, commented out)
# resp, code = http_post_json(rmq_url, rmq_body, user=RMQ_USER, password=RMQ_PASS, timeout=RMQ_TIMEOUT)
# if code != 200:
# await log_status(f"[{ts()}] rmq: publish immediate http={code} host={host}")
# else:
# routed = False
# try:
# routed = bool((resp or {}).get("routed", False))
# except Exception:
# routed = False
# if not routed:
# await log_status(f"[{ts()}] rmq: publish immediate routed=false host={host}")
resp, code = http_post_json(rmq_url, rmq_body, user=RMQ_USER, password=RMQ_PASS, timeout=RMQ_TIMEOUT)
if code != 200:
await log_status(f"[{ts()}] rmq: publish immediate http={code} host={host}")
else:
routed = False
try:
routed = bool((resp or {}).get("routed", False))
except Exception:
routed = False
if not routed:
await log_status(f"[{ts()}] rmq: publish immediate routed=false host={host}")
# Bell behavior: ring 3x BEL when action_next present
bell_prefix = "\a" * 3