Spring整合Weblogicjms实例详解

<&＃63;xml version="1.0" encoding="UTF-8"&＃63;>


  
    
      
        weblogic.jndi.WLInitialContextFactory
        t3://10.39.196.10:7001
        weblogic
        weblogic1
      
    
  
  
    
    
    
  
  
    
    
  
  
    
    
  
  
    
  

  
  
  
    
  
  
  
  
    
    
    
    
  

package com.inspur.demo.jms;

import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

public class Sender {
  protected static Logger logger = LoggerFactory.getLogger(Sender.class);
  
  //发送消息的队列
  @Autowired
  @Qualifier("testQueueSend")
  private Destination destination;
  
  @Autowired
  private JmsTemplate jmsTemplate;
  
  public void hello() {
    String message = System.currentTimeMillis() + "-hello";
    logger.info("Message Send:{}", message);
    jmsTemplate.send(destination, new MessageCreator() {
      @Override
      public Message createMessage(Session session) throws JMSException {
        return session.createTextMessage(message);
      }
    });
  }
}

package com.inspur.demo.jms;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class Receiver implements MessageListener {
  protected static Logger logger = LoggerFactory.getLogger(Receiver.class);
  
  @Override
  public void onMessage(Message message) {
    try {
      String text = "";  
      if (message instanceof TextMessage) {  
        text = ((TextMessage) message).getText();  
      } 
      logger.info("Message received:{}", text);
    } catch (JMSException e) {
      e.printStackTrace();
    }
  }
}