Remove NSQ related code

hypothesis · Apr 19, 2016 · 6650fc0 · 6650fc0
1 parent 11c3701
commit 6650fc0
Show file tree

Hide file tree

Showing 9 changed files with 5 additions and 858 deletions.
diff --git a/h/app.py b/h/app.py
@@ -109,7 +109,6 @@ def includeme(config):
     config.include('h.features')
     config.include('h.form')
     config.include('h.models')
-    config.include('h.queue')
     config.include('h.realtime')
     config.include('h.sentry')
     config.include('h.stats')

diff --git a/h/celery.py b/h/celery.py
@@ -35,7 +35,7 @@
     CELERY_ACCEPT_CONTENT=['json'],
     # Enable at-least-once delivery mode. This probably isn't actually what we
     # want for all of our queues, but it makes the failure-mode behaviour of
-    # Celery the same as our NSQ worker:
+    # Celery the same as our old NSQ worker:
     CELERY_ACKS_LATE=True,
     CELERY_DISABLE_RATE_LIMITS=True,
     CELERY_IGNORE_RESULT=True,

diff --git a/h/queue.py b/h/queue.py
diff --git a/h/streamer/nsq.py b/h/streamer/nsq.py
diff --git a/h/streamer/streamer.py b/h/streamer/streamer.py
@@ -7,9 +7,7 @@
 
 from h import db
 from h import stats
-from h.queue import resolve_topic
 from h.streamer import messages
-from h.streamer import nsq
 from h.streamer import websocket
 
 log = logging.getLogger(__name__)