空间站

北极心空

  BlogJava :: 首页 :: 联系 :: 聚合  :: 管理
  15 Posts :: 393 Stories :: 160 Comments :: 0 Trackbacks

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



Trackback: http://tb.blog.csdn.net/TrackBack.aspx?PostId=626691


posted on 2006-12-15 20:16 芦苇 阅读(1047) 评论(0)  编辑  收藏 所属分类: JAVA其他

只有注册用户登录后才能发表评论。


网站导航: