Message Driven Bean 学习简要

发送端：
@Stateless
@Local
public class QueueSend implements IQueueSend
{
 
    @Resource(mappedName = "jms/ConnectionFactory")
    private ConnectionFactory connectionFactory;

    @Resource(mappedName = "jms/RequestQueue")
    private Queue requestQueue;


    public void sendNotificationForInline(ReportInstance ri) {        
        Connection connection = null;
        try {
            connection = connectionFactory.createConnection();
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            Destination dest = (Destination) requestQueue;
            MessageProducer messageProducer = session.createProducer(dest);
            MapMessage message = session.createMapMessage();
            message.setLong("reportInstId", ri.getId());
            messageProducer.send(message);
        } catch (Exception ex) {
           
        } finally {
            if (connection != null) {
                try {
                    connection.close();
                } catch (Throwable t) {
                }
            }
        }
    }

}


接收端：
@MessageDriven(mappedName = "jms/RequestQueue")
public class NotificationProcesser implements MessageListener {

     public void onMessage(Message message) {
      if(message instanceof MapMessage)
      {
         //处理message
      }
    }
}


Queue：点对点的消息队列，1个消息产生1个对应 1:1
Topic：采取发布/订阅机制的消息主题，1个消息产生多个对应  1：N