diff options
Diffstat (limited to '')
| -rw-r--r-- | pysite/service_discovery.py | 26 | 
1 files changed, 0 insertions, 26 deletions
diff --git a/pysite/service_discovery.py b/pysite/service_discovery.py deleted file mode 100644 index a03341c4..00000000 --- a/pysite/service_discovery.py +++ /dev/null @@ -1,26 +0,0 @@ -import datetime -import socket -import time -from contextlib import closing - -from pysite.constants import RMQ_HOST, RMQ_PORT - -THIRTY_SECONDS = datetime.timedelta(seconds=30) - - -def wait_for_rmq(): -    start = datetime.datetime.now() - -    while True: -        if datetime.datetime.now() - start > THIRTY_SECONDS: -            return False - -        with closing(socket.socket(socket.AF_INET, socket.SOCK_STREAM)) as sock: -            try: -                state = sock.connect_ex((RMQ_HOST, RMQ_PORT)) -                if state == 0: -                    return True -            except socket.gaierror: -                pass - -        time.sleep(0.5)  |