成功使用pidbox.Mailbox？

Question

有人用过pidbox.Mailbox吗？

我试图做一些类似于这个例子的事情，但是这个文档已经过时了。我已经成功地获得了一些东西，可以将消息发布到django传输中，但是从那里它们从未被成功地接收过。

我希望有人知道如何使用它，并向我展示一个如何成功调用/转换的示例。

下面是我所拥有的(虚拟节点实际上什么也不做，只做打印或列表)：

    #node/server
    mailbox = pidbox.Mailbox("test", type="direct")
    connection  = BrokerConnection(transport="django")

    bound = mailbox(connection)

    state = {"node": DummyNode(),
                "connection": connection
        }

    node = bound.Node(state = state)

    @node.handler
    def list( state, **kwargs):
        print 'list called'
        return state["node"].list()
    @node.handler
    def connection_info(state, **kwargs):
        return {"connection": state["connection"].info()}
    @node.handler
    def print_msg(state, **kwargs):
        print 'Node handler!'
        state["node"].print_msg(kwargs)


    consumer = node.listen(channel = connection.channel())
    try:
        while not self.killed:
            print 'Consumer Waiting'
            connection.drain_events()
    finally:
        consumer.cancel()

和一个简单的客户。

#client:    

mailbox = pidbox.Mailbox("test", type="direct")
connection  = BrokerConnection(transport="django")
bound = mailbox(connection)

bound.cast(["localhost"], "print_msg", {'msg' : 'Message for you'})
info = bound.call(["test_application"],"list", callback=callback)

Answer 1

答案显然是否定的。如果你看到这篇文章，我强烈建议你自己写。对于pidbox来说，文档太少了，其中的文档已经过时了。