diff --git a/lib/ansible/modules/messaging/rabbitmq_binding.py b/lib/ansible/modules/messaging/rabbitmq_binding.py index b4df153233..d01589ea07 100644 --- a/lib/ansible/modules/messaging/rabbitmq_binding.py +++ b/lib/ansible/modules/messaging/rabbitmq_binding.py @@ -103,9 +103,14 @@ EXAMPLES = ''' ''' import json -import requests import urllib +try: + import requests + HAS_REQUESTS = True +except ImportError as e: + HAS_REQUESTS = False + from ansible.module_utils.basic import AnsibleModule @@ -127,6 +132,9 @@ def main(): supports_check_mode = True ) + if not HAS_REQUESTS: + module.fail_json(msg="requests library is required for this module. To install, use `pip install requests`") + if module.params['destination_type'] == "queue": dest_type="q" else: diff --git a/lib/ansible/modules/messaging/rabbitmq_exchange.py b/lib/ansible/modules/messaging/rabbitmq_exchange.py index a0db064ed3..0851dbf1a9 100644 --- a/lib/ansible/modules/messaging/rabbitmq_exchange.py +++ b/lib/ansible/modules/messaging/rabbitmq_exchange.py @@ -105,7 +105,11 @@ EXAMPLES = ''' ''' import json -import requests +try: + import requests + HAS_REQUESTS = True +except ImportError as e: + HAS_REQUESTS = False import urllib from ansible.module_utils.basic import AnsibleModule @@ -137,6 +141,9 @@ def main(): urllib.quote(module.params['name'],'') ) + if not HAS_REQUESTS: + module.fail_json(msg="requests library is required for this module. To install, use `pip install requests`") + # Check if exchange already exists r = requests.get( url, auth=(module.params['login_user'],module.params['login_password'])) diff --git a/lib/ansible/modules/messaging/rabbitmq_queue.py b/lib/ansible/modules/messaging/rabbitmq_queue.py index 9849128f71..97e962870c 100644 --- a/lib/ansible/modules/messaging/rabbitmq_queue.py +++ b/lib/ansible/modules/messaging/rabbitmq_queue.py @@ -120,7 +120,11 @@ EXAMPLES = ''' ''' import json -import requests +try: + import requests + HAS_REQUESTS = True +except ImportError as e: + HAS_REQUESTS = False import urllib from ansible.module_utils.basic import AnsibleModule @@ -155,6 +159,9 @@ def main(): module.params['name'] ) + if not HAS_REQUESTS: + module.fail_json(msg="requests library is required for this module. To install, use `pip install requests`") + # Check if queue already exists r = requests.get( url, auth=(module.params['login_user'],module.params['login_password']))