Я хочу установить TTL на 1 секунду для очереди Rabbitmq, используя pika. Я попробовал следующий код
import ctypes
int32=ctypes.c_int
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
this=channel.queue_declare(queue='hello',
arguments={'x-message-ttl' : int32(1000)}
)
channel.basic_publish(exchange='',
routing_key='hello',
body=message)
print this.method.consumer_count
Я получаю следующую ошибку
Traceback (most recent call last):
File "rabt.py", line 8, in <module>
arguments={'x-message-ttl' : int32(1000)}
File "build\bdist.win32\egg\pika\adapters\blocking_connection.py", line 2397, in queue_declare
File "build\bdist.win32\egg\pika\channel.py", line 815, in queue_declare
File "build\bdist.win32\egg\pika\channel.py", line 1312, in _rpc
File "build\bdist.win32\egg\pika\channel.py", line 1324, in _send_method
File "build\bdist.win32\egg\pika\connection.py", line 2139, in _send_method
File "build\bdist.win32\egg\pika\connection.py", line 2119, in _send_frame
File "build\bdist.win32\egg\pika\frame.py", line 74, in marshal
File "build\bdist.win32\egg\pika\spec.py", line 1015, in encode
File "build\bdist.win32\egg\pika\data.py", line 85, in encode_table
File "build\bdist.win32\egg\pika\data.py", line 153, in encode_value
pika.exceptions.UnsupportedAMQPFieldException: (['\x00\x00', '\x05', 'hello', '\x00', None, '\r', 'x-message-ttl'], c_long(1000))
Я пытаюсь заблокировать все сообщения в этой конкретной очереди через 1 секунду. Могу ли я узнать, как установить TTL с помощью Pika? Спасибо!