翻译于 2013/08/06 08:44
下面是一些需要的代码:
from zato.server.service import Service class MyService(Service): def handle(self): msg = 'My message' conn_name = 'My CRM connection' exchange_name = 'My exchange' routing_key = '' self.outgoing.amqp.send(msg, conn_name, exchange_name, routing_key)
以下是文章内容.
在发送第一个消息之前,你必须让Zato知道要把消息发送到哪儿,因为默认情况下Zato支持分离生成消息的服务和消息送达的实际的目的地。
在你的代码里,你只是调用了单个.send方法,不需要真正地指定特定的URL或者凭证,消息过期时间,内容类型等等。你可以指定这些,不过你不需要。
这一切都通过连接定义和真正的连接来实现的。连接定义是一个说明连接到AMQP代理的所需要的详细信息的模板-代理的网络地址,虚拟主机名,用户名/密码以及类似的东西。每个连接定义可以用来创建一个或者多个处理要发送消息的细节-消息优先权,分发模式以及其他这个消息信息的连接。
评论删除后,数据将无法恢复
评论(2)