欧美性猛交XXXX免费看蜜桃,成人网18免费韩国,亚洲国产成人精品区综合,欧美日韩一区二区三区高清不卡,亚洲综合一区二区精品久久

java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory# Use the following property to configure the default connectorjava.naming.provider.url = tcp://192.168.2.140:61616# Use the following property to specify the JNDI name the connection factory# should appear as.connectionFactoryNames = ConnectionFactory, queueConnectionFactory, topicConnectionFactry# Register some queues in JNDI using the form:#   queue.[jndiName] = [physicalName]queue.MyQueue = example.MyQueue# Register some topics in JNDI using the form:#   topic.[jndiName] = [physicalName]topic.MyTopic = example.MyTopic

package com.ckl.activemq;/** * The SimpleQueueSender class consists only of a main method, * which sends several messages to a queue. * * Run this program in conjunction with SimpleQueueReceiver. * Specify a queue name on the command line when you run the * program.  By default, the program sends one message.  Specify * a number after the queue name to send that number of messages. */import org.slf4j.Logger;import org.slf4j.LoggerFactory;import javax.jms.*;import javax.naming.Context;import javax.naming.InitialContext;import javax.naming.NamingException;/** * A simple polymorphic JMS producer which can work with Queues or Topics which * uses JNDI to lookup the JMS connection factory and destination. */public class SimpleProducer {    private static final Logger LOG = LoggerFactory.getLogger(SimpleProducer.class);    private SimpleProducer() {}    /**     * @param args the destination name to send to and optionally, the number of     *                messages to send     */    public static void main(String[] args) {        Context jndiContext = null;        ConnectionFactory connectionFactory = null;        Connection connection = null;        Session session = null;        Destination destination = null;        MessageProducer producer = null;        String destinationName = null;        final int numMsgs;
　　　　//這邊被我手動(dòng)修改了，比較不喜歡每次運行時(shí)還要修改Run configuration，麻煩。        args = new String[2];        args[0] = "MyTopic";        args[1] = "3";        if ((args.length < 1) || (args.length > 2)) {            LOG.info("Usage: java SimpleProducer <destination-name> [<number-of-messages>]");            System.exit(1);        }        destinationName = args[0];        LOG.info("Destination name is " + destinationName);        if (args.length == 2) {            numMsgs = (new Integer(args[1])).intValue();        }        else {            numMsgs = 1;        }                 /*         * Create a JNDI API InitialContext object         */        try {            jndiContext = new InitialContext();        }        catch (NamingException e) {            LOG.info("Could not create JNDI API context: " + e.toString());            System.exit(1);        }         /*         * Look up connection factory and destination.         */        try {            connectionFactory = (ConnectionFactory)jndiContext.lookup("ConnectionFactory");            destination = (Destination)jndiContext.lookup(destinationName);        }        catch (NamingException e) {            LOG.info("JNDI API lookup failed: " + e);            System.exit(1);        }         /*         * Create connection. Create session from connection; false means         * session is not transacted. Create sender and text message. Send         * messages, varying text slightly. Send end-of-messages message.         * Finally, close the connection.         */        try {            connection = connectionFactory.createConnection();            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);            producer = session.createProducer(destination);            TextMessage message = session.createTextMessage();            for (int i = 0; i < numMsgs; i++) {                message.setText("This is message " + (i + 1));                LOG.info("Sending message: " + message.getText());                producer.send(message);            }             /*             * Send a non-text control message indicating end of messages.             */            producer.send(session.createMessage());        }        catch (JMSException e) {            LOG.info("Exception occurred: " + e);        }        finally {
　　　　　　　//睡眠是我手動(dòng)加的，主要為了觀(guān)察效果            try {                Thread.sleep(100000L);            } catch (InterruptedException e) {                e.printStackTrace();            }            if (connection != null) {                try {                    connection.close();                }                catch (JMSException ignored) {}            }        }    }}

如果，您認為閱讀這篇博客讓您有些收獲，不妨點(diǎn)擊一下右下角的【推薦】。

如果，您希望更容易地發(fā)現我的新博客，不妨點(diǎn)擊一下，【關(guān)注我】

博文是自己對學(xué)習成果的總結,學(xué)習總結知識-》分析問(wèn)題-》解決問(wèn)題。

文中存在的觀(guān)點(diǎn)/描述不正確的地方，歡迎指正。

感謝您的閱讀，如果您對我的博客所講述的內容有興趣，請繼續關(guān)注我的后續博客，我是逐日，qq：914000408。