1)创建消息队列治理器(create mq manager)
crtmqm -q GW.QUEUE.MANAGER
2)启动消息队列治理器(start mq manager)
strmqm GW.QUEUE.MANAGER
3)运行消息队列脚本命令(run mq shell command)
runmqsc SMS.GW.QUEUE.MANAGER
定义队列 和 通道
DEFINE QL (mysql.LOG.Q) DEFPSIST(YES) MAXDEPTH(100000)
DEFINE CHANNEL(MYSQL.LOG.C) CHLTYPE(SVRCONN) TRPTYPE(TCP)
DEFINE QL (ORACAL.LOG.Q) DEFPSIST(YES) MAXDEPTH(100000)
DEFINE CHANNEL(ORACAL.LOG.C) CHLTYPE(SVRCONN) TRPTYPE(TCP)
end
4)运行消息队列监听器(run mq listener)
runmqlsr -m GW.QUEUE.MANAGER -t TCP -p 1415 &
5)向队列插入一条消息
amqsput MYSQL.LOG.Q
回车,然后输入您要插入的消息内容,回车,再回车。 提示成功。
6)从队列读消息
amqsget MYSQL.LOG.Q