thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 00:30:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

API of pika for rabbitmq has changed

Browse Source
This commit is contained in:
Mikhail f. Shiryaev 2023-06-23 02:51:18 +02:00
parent a18300c497
commit 4f1982e25e
No known key found for this signature in database
GPG Key ID: 4B02ED204C7D93F4
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tests/integration/test_storage_rabbitmq/test.py
View File

@ -858,7 +858,7 @@ def test_rabbitmq_insert(rabbitmq_cluster):
if len(insert_messages) == 50:
channel.stop_consuming()
consumer.basic_consume(onReceived, queue_name)
consumer.basic_consume(queue_name, onReceived)
consumer.start_consuming()
consumer_connection.close()
@ -921,7 +921,7 @@ def test_rabbitmq_insert_headers_exchange(rabbitmq_cluster):
if len(insert_messages) == 50:
channel.stop_consuming()
consumer.basic_consume(onReceived, queue_name)
consumer.basic_consume(queue_name, onReceived)
consumer.start_consuming()
consumer_connection.close()
@ -2991,7 +2991,7 @@ def test_format_with_prefix_and_suffix(rabbitmq_cluster):
if len(insert_messages) == 2:
channel.stop_consuming()
consumer.basic_consume(onReceived, queue_name)
consumer.basic_consume(queue_name, onReceived)
consumer.start_consuming()
consumer_connection.close()
@ -3050,7 +3050,7 @@ def test_max_rows_per_message(rabbitmq_cluster):
if len(insert_messages) == 2:
channel.stop_consuming()
consumer.basic_consume(onReceived, queue_name)
consumer.basic_consume(queue_name, onReceived)
consumer.start_consuming()
consumer_connection.close()
@ -3148,7 +3148,7 @@ def test_row_based_formats(rabbitmq_cluster):
if insert_messages == 2:
channel.stop_consuming()
consumer.basic_consume(onReceived, queue_name)
consumer.basic_consume(queue_name, onReceived)
consumer.start_consuming()
consumer_connection.close()
@ -3211,7 +3211,7 @@ def test_block_based_formats_1(rabbitmq_cluster):
if len(insert_messages) == 3:
channel.stop_consuming()
consumer.basic_consume(onReceived, queue_name)
consumer.basic_consume(queue_name, onReceived)
consumer.start_consuming()
consumer_connection.close()
@ -3296,7 +3296,7 @@ def test_block_based_formats_2(rabbitmq_cluster):
if insert_messages == 9:
channel.stop_consuming()
consumer.basic_consume(onReceived, queue_name)
consumer.basic_consume(queue_name, onReceived)
consumer.start_consuming()
consumer_connection.close()