zoukankan      html  css  js  c++  java
  • Python 操作rabbitmq中的confirm模式的错误

    今天使用rabbitmq的confirm模式,书上介绍的是pika版本是0.9.6,但是我用的是别的版本,发现这样的错误

    Traceback (most recent call last):
      File "hello_world_producer1.py", line 27, in <module>
        channel.confirm_delivery(confirm_handler)
    TypeError: confirm_delivery() takes exactly 1 argument (2 given)

    看官网后发现错了,应该改成下面的样式:

    #!/usr/bin/env python #coding:utf-8 import pika,sys

    from pika import spec credentials=pika.PlainCredentials('guest','guest')

    conn_params=pika.ConnectionParameters('localhost',credentials=credentials) conn_broker=pika.BlockingConnection(conn_params) channel=conn_broker.channel()

    channel.confirm_delivery()

    #channel.confirm_delivery()

    msg=sys.argv[1]

    msg_props=pika.BasicProperties()

    msg_props.content_type="text/plain" msg_ids=[]

    if channel.basic_publish(body=msg,       exchange="hello-exchange",       properties=msg_props,       routing_key='hola'):

        print 'Confirm receive!'

    else:  

      print 'Message lost'

    #msg_ids.append(len(msg_ids)+1)

    channel.close()

    ##这里参考https://github.com/rabbitinaction/sourcecode/issues/9

    ##https://pika.readthedocs.io/en/latest/examples/blocking_delivery_confirmations.html

  • 相关阅读:
    沈阳集训day2
    ac自动机
    2018沈阳集训day1
    洛谷P1875 佳佳的魔法药水
    洛谷P1941 飞扬的小鸟
    Noip2016day2
    1123: [POI2008]BLO
    1718: [Usaco2006 Jan] Redundant Paths 分离的路径
    P3119 [USACO15JAN]草鉴定Grass Cownoisseur
    [LeetCode] Clone Graph
  • 原文地址:https://www.cnblogs.com/si-jie/p/5967360.html
Copyright © 2011-2022 走看看