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();
            }
        }
    }
  • 相关阅读:
    js获取盒子scrollTop
    获取浏览器宽度,自适应屏幕
    js切割字符串
    有向图的欧拉路径POJ2337
    欧拉回路和欧拉路径
    HDU 4462(暴力枚举)
    HDU 4455(dp)
    鸽巢原理入门
    HDU 4819 Mosaic(二维线段树)
    POJ 1330 Nearest Common Ancestors(LCA模板)
  • 原文地址:https://www.cnblogs.com/windows/p/2701617.html
Copyright © 2011-2022 走看看