zoukankan      html  css  js  c++  java
  • WebSphere MQ编程实例JMS

    import java.util.Hashtable;
    import javax.jms.*;
    import javax.naming.*;
    import javax.naming.directory.*;
    
    public class sample {
        protected QueueConnectionFactory factory=null;
        protected QueueConnection connection;
        protected QueueSession queueSession;
        protected TextMessage outMessage;
        protected QueueSender queueSender;
        protected QueueReceiver queueReceiver;
    
        public static final String qcfLookup="QCFC";
        public static final String qLookup="Q1";
        public static final String icf = "com.sun.jndi.fscontext.RefFSContextFactory";
        public String url ="file:/d:/testmq/ctx/";
    
        public void sampleInit() throws Exception {
            Hashtable environment = new Hashtable();
            environment.put(Context.INITIAL_CONTEXT_FACTORY, icf);
            environment.put(Context.PROVIDER_URL, url);
            environment.put(Context.REFERRAL, "throw");
            Context ctx=new InitialDirContext(environment);
            factory = (QueueConnectionFactory)ctx.lookup(qcfLookup);
    
            Queue q1=null;
            q1=(Queue)ctx.lookup(qLookup);
            connection = factory.createQueueConnection();
            queueSession = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
    
            queueSender = queueSession.createSender(q1);
            queueSender.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
            outMessage = queueSession.createTextMessage();
            queueReceiver = queueSession.createReceiver(q1);
            connection.start();
        }
        public void sendMessageOut(String message) throws JMSException {
            outMessage.setText(message);
            queueSender.send(outMessage);
        }
        public String receiveMessage() throws Exception{
            return ((TextMessage)queueReceiver.receive()).getText();
        }
        public void sampleClose() throws JMSException {
            queueSession.close();
            connection.close();
        }
    
        public static void main(String[] args){
            String rec;
            sample sp = new sample();
            try {
                sp.sampleInit();
                sp.sendMessageOut("This is a test!");
                java.lang.Thread.sleep(4000);
                rec=sp.receiveMessage();
                System.out.println("Receive text is : "+rec);
                sp.sampleClose();
            }catch(Exception e) {
                e.printStackTrace();
            }
        }
    }
  • 相关阅读:
    [洛谷P4513][题解]小白逛公园
    [洛谷P2564][题解][SCOI2009]生日礼物
    [洛谷P3384][题解]轻重链剖分
    [洛谷P2607][题解][ZJOI2008]骑士
    第一次个人编程作业
    第一次博客作业
    第一次个人编程作业
    第一次博客作业
    1.初识数据库系统
    1.计算机发展历程
  • 原文地址:https://www.cnblogs.com/windows/p/2701617.html
Copyright © 2011-2022 走看看