没有合适的资源?快使用搜索试试~ 我知道了~
温馨提示
试读
3页
本 帮助主题 展示了使用Zato发送AMQP消息 所 需的内容. Zato 基于Python 的 为 SOA 、 云 集成 和 后端 服务 的 企业服务总线(ESB) 。 代码演示 下面是一些需要的代码: from zato.server.service import Service class MyService(Service): def handle(self): msg = ‘My message’ conn_name = ‘My CRM connection’ exchange_name = ‘My exchange’
资源详情
资源评论
资源推荐
使用使用Python的的Zato发送发送AMQP消息的教程消息的教程
本 帮助主题 展示了使用Zato发送AMQP消息 所 需的内容. Zato 基于Python 的 为 SOA 、 云 集成 和 后端 服务 的 企业服务总
线(ESB) 。
代码演示
下面是一些需要的代码:
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代理的所需要的详细信息的模板-代理的网
络地址,虚拟主机名,用户名/密码以及类似的东西。每个连接定义可以用来创建一个或者多个处理要发送消息的细节-消息优
先权,分发模式以及其他这个消息信息的连接。
这两种对象类型可以使用Zato的图形界面创建,也可以通过其它方法如enmasse或者API创建
图形界面图形界面
首先创建一个连接定义,然后用它来创建一个对外连接,就像下图所示:
weixin_38689191
- 粉丝: 5
- 资源: 956
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功
评论0