JMS中的事宜Session

JMS中的事务Session

?? Session?? session = conn.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);?
???第一个参数代表该session是否支持事务,true 表示这个会话是事务性的，需要显式的commit 或者rollback ().
??? 如果没有显示的提交session.commit(),接收端是不能够收到发送方的消息的。

??

 public static void main(String[] args)        throws JMSException    {        String url = "tcp://localhost:61616";        String userName = "system";        String password = "manager";        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(userName,password,url);        Connection connection = connectionFactory.createConnection();                //一定要start        connection.start();                // 通过连接接口创建一个会话接口           Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);        // 会话接口创建有关主题的目标接口        Destination destination = session.createQueue("test_queue");        // 会话接口再根据目标接口来创建一个消息消费者接口        MessageConsumer consumer = session.createConsumer(destination);                // 消息消费者接收消息        consumer.setMessageListener(new MessageListener()        {            @Override            public void onMessage(Message msg)            {                TextMessage message = (TextMessage)msg;                                try                {                    System.out.println("收到消息："+message.getText());                }                catch (JMSException e)                {                    e.printStackTrace();                }                            }        });            }

?