python获取报文参考代码
2024-09-23 02:57:11
# -*- coding:utf-8 -*- import sys
import stomp
import logging
import time class MyListener(object):
def on_error(self, headers, message):
print '%s:received an error:\n%s' % (time.strftime('%Y-%m-%d %X', time.localtime(time.time())), message) def on_message(self, headers, message):
print '%s:received a message:\n%s' % (time.strftime('%Y-%m-%d %X', time.localtime(time.time())), message) #机票信息
dest1 = '/topic/topic.testtour2.rss.packageBasic.update'
#航班和起降信息
dest2 = '/topic/topic.testtour2.rss.flightAndTakeOff.update'
#加价规则
dest3 = '/topic/topic.testtour2.rss.packageDatePrice.update'
#采购规则
dest4 = '/topic/topic.testtour2.rss.packagePurchase.update'
#库存信息
dest5 = '/topic/topic.menpiao.stk.diyPackageRound.update'
#全量机票
dest6='/topic/topic.testtour2.rss.packageResIds.update'
logging.basicConfig() conn = stomp.Connection([('IP地址', 61613)])
conn.set_listener('', MyListener())
conn.start()
conn.connect(wait = True) num=4
#机票信息=1,航班和起降信息=2,加价规则=3,采购规则=4,库存信息=5,全量机票n if num==1:
dest=dest1
elif num==2:
dest=dest2
elif num==3:
dest=dest3
elif num==4:
dest=dest4
elif num==5:
dest=dest5
else:
dest=dest6
conn.subscribe(destination = dest, id = 1, ack = 'auto')
while True:
try:
time.sleep(1)
except:
break
最新文章
- Android开发之应用程序的安装
- React.js入门笔记(续):用React的方式来思考
- StringBuilder类型
- 直接代码POST数据调用WebService
- 关于js预编译以及js文件执行顺序的几个问题。
- linux基础-第十四单元 Linux网络原理及基础设置
- oralce中exists not exists in not in对于NULL的处理
- 犯罪团伙 codevs 3554
- discuz二次开发笔记(二)------跳转函数运用
- 如何在XML 加入特殊字符内容 如<; >;
- 1104--DNA排序
- Cs Round#54 D Spanning Trees
- HTTP面试题都在这里
- Node.js 部署免费/自动续订 HTTPS
- ButterKnife 牛油刀使用
- PC网站转换成手机版
- Go基础系列:import导包和初始化阶段
- 关于 TypeReference 的解释
- sql的存储过程实例--循环动态创建表
- angularjs animation
热门文章
- MeterSphere中dubbo接口测试分享
- (app笔记)Memory Fill内存填充
- mysql创建存储过程造数据
- mysql报错This function has none of DETERMINISTIC. NO SOL or READS SOL DATA...
- 转载--文章(感谢米粒儿博主分享) 关于 Json.net序列化时间问题
- containerd容器存储探究
- Delphi 移除窗口最大化按钮
- 创建一个httpserver、httpclient
- 12组-Beta冲刺-3/5
- uni-app --vue3--TypeScript 微信小程序开发