Assertion ошибка с snakemq питон 3.2.1

Question

Я работаю через учебник здесь: http://www.snakemq.net/doc/tutorial.html

Вот мой код:

import snakemq.link 
import snakemq.packeter 
import snakemq.messaging 
import snakemq.message 

#Build Stack 

my_link = snakemq.link.Link() 
my_packeter = snakemq.packeter.Packeter(my_link) 
my_messaging = snakemq.messaging.Message("tyler", "", my_packeter) 

#Tyler 

my_link.add_listener(("", 4000)) 
my_link.add_connector(("localhost", 4001)) 

#Sally 

my_link.add_connector(("localhost", 4000)) 
my_link.add_connector(("localhost", 4001)) 

#Paul 

my_link.add_connector(("localhost", 4000)) 
my_link.add_listener(("", 4001)) 

#Run link loop (it drives the whole stack) 

my_link.loop() 

#Tyler wants to send a message to Sally 
#drop after 30 seconds if the message can't be delivered 

message = snakemq.message.Message(b"Hello", ttl = 600) 
my_messaging.send_message("Sally", message) 

#receiving callback 

def on_recv(conn, ident, message): 
    print(ident, message) 

my_messaging.on_message_recv.add(on_recv) 

Я получаю сообщение об ошибке:

Traceback (most recent call last):
File "C:/Users/Owner/Desktop/snakemq tutorial/test.py", line 10, in my_messaging = snakemq.messaging.Message("tyler", "", my_packeter)
File "C:\Python32\lib\site-packages\snakemq-1.2-py3.2.egg\snakem\message.py",
line 30, in init assert type(data) == bytes
AssertionError

Answer 1

Похоже, что вы неправильно строите Message.

Согласно документу, http://www.snakemq.net/doc/api/messaging.html#message, конструктор является

class snakemq.message.Message(data, ttl=0, flags=0, uuid=None) 

Но в этой линии,

my_messaging = snakemq.messaging.Message("tyler", "", my_packeter) 

вы передаете "tyler", "" и my_packeter, которые не соответствуют определению функции.

Вы должны попробовать это

my_messaging = snakemq.messaging.Message(b"tyler")