diff --git a/account_manager.py b/account_manager.py index 30265d1b7281e16b88178c53bd5d01bb0e5be19d..11330b76d0390dd41d1651572c5572ceee9c7233 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 = {}