MQ03

キューに送ってみる

●キュー送ってみる
プログラムを作成。
※コンパイルには
インストールディレクトリ\mq\lib
のimq.jar、jms.jarが要る。

package TestMQ;
import javax.jms.Queue;

import javax.jms.QueueConnection;

import javax.jms.QueueSender;

import javax.jms.QueueSession;

import javax.jms.Session;

import javax.jms.TextMessage;
import com.sun.messaging.ConnectionConfiguration;

import com.sun.messaging.QueueConnectionFactory;
public class TestSendQueue {
    public static void main(String[] args) throws Exception {
        QueueConnectionFactory qcf = new QueueConnectionFactory();

        qcf.setProperty( ConnectionConfiguration.imqAddressList, "localhost:7676" );

        QueueConnection qcon = qcf.createQueueConnection();

        QueueSession qsess = qcon.createQueueSession( false, Session.AUTO_ACKNOWLEDGE );

        Queue qu = qsess.createQueue( "testqueue" );

        QueueSender sender = qsess.createSender( qu );
        //送信

        for(int i = 0; i < 10; ++i){

            TextMessage msg = qsess.createTextMessage();

            msg.setText("TESTあ" + i);

            msg.setStringProperty("numberXX", "" + i );

            sender.send(msg);

        }
        //切断

        qcon.close();
    }
}