zoukankan      html  css  js  c++  java
  • mq put 消息到远程队列

    [mqm@yyjk sbin]$ cat put_mq_message.pl 
      use MQSeries qw(:functions);
      use MQSeries::QueueManager;
      use MQSeries::Queue;
      use MQSeries::Message;
      use MQSeries::Command;
      use Data::Dumper;
    use MQSeries qw(:functions);
    use MQSeries::QueueManager;
    use Encode;
    
      #
      #  # Simplest, trivial usage
      #    #
      my $qmgr = MQSeries::QueueManager->
          new(QueueManager => 'QM_PICP_313345010019_01',
              ClientConn   => { 'ChannelName'    => "SVRCONN",
                           'TransportType'  => 'TCP', # Default
                           'ConnectionName' => "1.3.240.1(9090)",
                           'MaxMsgLength'   => 100 * 1024 * 1024,
                         }, ) ||
          die("Unable to connect to queue manager
    ");
    my $msg_date='<?xml version="1.0" encoding="GBK"?><CFX><HEAD><VER>1.0</VER><SRC>313345010019</SRC><DES>100000000000</DES><APP>PICP</APP><MsgNo>0001</MsgNo><MsgID>20190419051819232640</MsgID><MsgRef>20190419051819232640</MsgRef><WorkDate>20190419</WorkDate><Reserve></Reserve></HEAD><MSG><SingleCheckBusinessHead0001><BankCode>313345010019</BankCode><EntrustDate>20190419011923264</EntrustDate><BusinessCode>05</BusinessCode><UserCode>DSFZF</UserCode></SingleCheckBusinessHead0001><SingleCheckRequestMessage0001><ID>330825199101312919</ID><Name>郭存储</Name></SingleCheckRequestMessage0001></MSG></CFX>';
    #my $msg_date=encode("gb2312",decode("utf8",$msg_date));
    my $msg_date = MQSeries::Message->new(Data => $msg_date);
      $qmgr->Put1(Message => $msg_date,
                  Queue   => 'PBC.EXT.ONLINE.IN',
                 );
    print Dumper($qmgr);
  • 相关阅读:
    ubuntu 查看进程,查看服务
    ubuntu16.04下配置静态ip
    php监听客户端连接状态
    Excel有用的宏
    openfire插件开发1
    linux ps命令
    转:linux下面/usr/local和opt目录有何区别
    linux 开机自启动软件(包含xampp方法)
    转:java两个jre目录和三个lib目录
    linux PATH环境变量
  • 原文地址:https://www.cnblogs.com/hzcya1995/p/13348791.html
Copyright © 2011-2022 走看看