Fehlermeldung "unbekannter Lieferzeit-tag" tritt auf, wenn ich versuche ack-Nachrichten zu RabbitMQ mit pika (python)

Möchte ich die Verarbeitung von Nachrichten in paar threads aber ich bin immer ein Fehler während der Ausführung dieses Codes:

from __future__ import with_statement
import pika
import sys
from pika.adapters.blocking_connection import BlockingConnection
from pika import connection, credentials
import time
import threading
import random
from pika.adapters.select_connection import SelectConnection
from pika.connection import Connection
import traceback


def doWork(body, args, channel):


    r = random.random()
    time.sleep(r * 10)
    try:        
        channel.basic_ack(delivery_tag=args.delivery_tag)

    except :
        traceback.print_exc()


auth = credentials.PlainCredentials(username="guest", password="guest")
params = connection.ConnectionParameters(host="localhost", credentials=auth)
conn = BlockingConnection(params)
channel = conn.channel()


while True:

    time.sleep(0.03)    
    try:

        method_frame, header_frame, body = channel.basic_get(queue="test_queue")
        if method_frame.NAME == 'Basic.GetEmpty':
            continue        

        t = threading.Thread(target=doWork, args=[body, method_frame, channel])
        t.setDaemon(True)
        t.start()

    except Exception, e:
        traceback.print_exc()
        continue

Fehler desctiption:

Traceback (most recent call last): 
Datei "C:\work\projects\mq\start.py", line 43, in 
method_frame, header_frame, Körper = Kanal.basic_get(queue="test_queue") 
Datei "C:\work\projects\mq\libs\pika\adapters\blocking_connection.py" Linie 318, in basic_get 
selbst.basic_get_(self, self._on_basic_get, Tickets, queue, no_ack) 
Datei "C:\work\projects\mq\libs\pika\channel.py", line 469, in basic_get 
no_ack=no_ack)) 
Datei "C:\work\projects\mq\libs\pika\adapters\blocking_connection.py", line 244, in send_method 
selbst.- Verbindung.process_data_events() 
Datei "C:\work\projects\mq\libs\pika\adapters\blocking_connection.py", line 94, in process_data_events 
selbst._handle_read() 
Datei "C:\work\projects\mq\libs\pika\adapters\base_connection.py", line 162, in _handle_read 
selbst._on_data_available(Daten) 
Datei "C:\work\projects\mq\libs\pika\connection.py", line 589, in _on_data_available 
frame) # Args 
Datei "C:\work\projects\mq\libs\pika\callback.py", line 124, in Prozess 
callback(*args, **keywords) 
Datei "C:\work\projects\mq\libs\pika\adapters\blocking_connection.py", line 269, in _on_remote_close 
frame.Methode.reply_text) 
AMQPChannelError: (406, 'PRECONDITION_FAILED - unbekannt-Lieferung-tag 204') 

Versionen: pika 0.9.5, rabbitMQ 2.6.1

InformationsquelleAutor der Frage solo117 | 2012-02-22

Schreibe einen Kommentar