This also requires an update to pika 1.x and some minor test code changes.
@@ -12,8 +12,8 @@ def callback(ch, method, properties, body):
print(body.decode('utf-8'))
connection.close()
-channel.basic_consume(callback,
- queue='hello',
- no_ack=True)
+channel.basic_consume(queue='hello',
+ auto_ack=True,
+ on_message_callback=callback)
channel.start_consuming()
@@ -9,8 +9,8 @@ serverImage="$1"
clientImage="$("$dir/../image-name.sh" librarytest/rabbitmq-basics "$serverImage")"
"$dir/../docker-build.sh" "$dir" "$clientImage" <<EOD
-FROM python:3.6-slim
-RUN pip install pika==0.11.0
+FROM python:3.7-alpine3.11
+RUN pip install pika==1.1.0
COPY dir/*.py /usr/local/bin/
EOD