import config
+# Because tests are very long running, turn off heartbeats.
+# https://stackoverflow.com/questions/14572020/handling-long-running-tasks-in-pika-rabbitmq
connection = pika.BlockingConnection(pika.ConnectionParameters(
- host = config.mq_server))
+ host = config.mq_server, heartbeat_interval=0))
channel = connection.channel()
def ack(method):