| 共 16 篇文章 |
|
如果在一个Connection上创建了两个Session，则一个Session创建的TemporaryQueue或TemporaryTopic也可以被另一个Session访问。那如果这两个Session是由不同的Connection创建，则一个Session创建的TemporaryQueue不可以被另一个Session访问。在下面的例子中，先创建一个Connection，然后创建两个Session，其中一个Session创建了一个TemporaryQueu... 阅16 转0 评0 公众公开 13-11-27 00:00 |
深入掌握JMS（十）：JMSCorrelationID与Selector深入掌握JMS（十）：JMSCorrelationID与Selector.public class JMSCorrelationIDTest {private Queue queue;运行结果为：ConsumerA get:Message from ProducerAProducerA get reply:Reply from ConsumerAConsumerB get:Message from ProducerBProducerB get reply:Reply from ConsumerBConsumerC... 阅23 转0 评0 公众公开 13-11-26 23:59 |
import javax.jms.结果如下：ConsumerA get Message0, receiver:AConsumerB get Message1, receiver:BConsumerB get Message2, receiver:BConsumerA get Message3, receiver:AConsumerB get Message4, receiver:BConsumerB get Message5, receiver:BConsumerA get Message6, receiver:AConsumerB get Message7, receiver:BConsumerB get Messag... 阅59 转0 评0 公众公开 13-11-26 23:59 |
//消息回复到这个QueueQueue replyQueue = new ActiveMQQueue("replyQueue");final Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);//创建一个消息，并设置它的JMSReplyTo为replyQueue。}首先消息生产者发送一个消息，内容为“Andy”，然后消费者收到这个消息之后根据消息的JMSReplyTo，回复一个消息... 阅17 转0 评0 公众公开 13-11-26 23:58 |
深入掌握JMS（七）：DeliveryMode例子。在下面的例子中，分别发送一个Persistent和nonpersistent的消息，然后关闭退出JMS。import javax.jms.import org.apache.activemq.Session session = connection.createSession(false,Session.producer.send(session.createTextMessage("A persistentMessage"));producer.setDeliveryMode(Deli... 阅17 转0 评0 公众公开 13-11-26 23:57 |
深入掌握JMS（六）：消息头。一个消息对象分为三部分：消息头(Headers)，属性（Properties）和消息体（Payload）。前者表示消息在被消费之前，如果JMS提供者DOWN了，重新启动后消息仍然存在。JMSType表示消息体的结构，和JMS提供者有关。因为有时消费者没有确认他已经收到消息或者JMS提供者不确定消费者是否已经收到。这些属性可以是应用自定义... 阅26 转0 评0 公众公开 13-11-26 23:57 |
深入掌握JMS（五）：实战Topic.import javax.jms.//创建一个TopicTopic topic= new ActiveMQTopic("testTopic");Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);//注册消费者1MessageConsumer comsumer1 = session.createConsumer(topic);comsumer1.setMessageListener(new MessageListener(){public ... 阅14 转0 评0 公众公开 13-11-26 23:56 |
深入掌握JMS（四）：实战Queue.import javax.jms.//创建一个QueueQueue queue = new ActiveMQQueue("testQueue");//创建一个SessionSession session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);//注册消费者1MessageConsumer comsumer1 = session.createConsumer(queue);comsumer1.setMessageListener(new Message... 阅13 转0 评0 公众公开 13-11-26 23:55 |
深入掌握JMS（三）：MessageListener.消息的消费者接收消息可以采用两种方式：1、consumer.receive() 或 consumer.receive(int timeout)；2、注册一个MessageListener。下面举例说明：MessageConsumer comsumer = session.createConsumer(queue);comsumer.setMessageListener(new MessageListener(){@Overridepublic void onMessage(Message m)... 阅22 转0 评0 公众公开 13-11-26 23:54 |
深入掌握JMS（二）：一个JMS例子。下面是全部源码 ：import javax.jms.Connection;import javax.jms.Message;import javax.jms.MessageConsumer;import javax.jms.MessageProducer;import javax.jms.Queue;import javax.jms.Session;import javax.jms.TextMessage; 阅9 转0 评0 公众公开 13-11-26 23:53 |
