From d068af352c78dc9e6b7d923f0f9d6611935b2081 Mon Sep 17 00:00:00 2001
From: atlurie <atlurie@uab.edu>
Date: Thu, 7 Apr 2022 15:54:08 -0500
Subject: [PATCH] Add missing imports and initiate the RMQ object
---
account_manager.py | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/account_manager.py b/account_manager.py
index 30265d1..11330b7 100755
--- a/account_manager.py
+++ b/account_manager.py
@@ -5,6 +5,8 @@ import argparse
import signal
import uuid
import rc_util
+from rc_rmq import RCRMQ
+import rabbit_config as rcfg
parser = argparse.ArgumentParser(description = "Account management driver script")
parser.add_argument("username", help="Username that should be locked/unlocked")
@@ -26,6 +28,9 @@ state = args.state
service = args.service
corr_id = str(uuid.uuid4())
+
+# Instantiate rabbitmq object
+rc_rmq = RCRMQ({"exchange": rcfg.Exchange, "exchange_type": "topic"})
callback_queue = rc_rmq.bind_queue(exclusive=True)
msg = {}
--
GitLab