EJB : Message-Driven-Bean

SERVER端（相当于消费者）：

@MessageDriven(

activationConfig ={

// javax.jms.Queue (p2p) 或者 javax.jms.Topic

@ActivationConfigProperty(propertyName = "destinationType" , propertyValue = "javax.jms.Queue"),

@ActivationConfigProperty(propertyName = "destination" , propertyValue = "queue/myqueue")

}

)

public class MyQueueMDBBean implements MessageListener {

public void onMessage(Message msg) {

TextMessage tmx = (TextMessage) msg;

System.out.println(tmx.toString());

}

} 

CLIENT端（相当于发布者）：

public class Main {

public static void main(String[] args) throws NamingException, JMSException {

InitialContext context = new InitialContext();

// 获得Destination对象 如果要用Topic把所有的Queue替换成Topic

Queue queue = (Queue)context.lookup("queue/myqueue");

// 获得QueueConnectionFactory对象

QueueConnectionFactory factory = (QueueConnectionFactory) context.lookup("ConnectionFactory");

// 创建QueueConnection对象

QueueConnection connection = factory.createQueueConnection();

// 创建QueueSession对象（agrs1:是否需要事物，agrs2:模型）

QueueSession session = connection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);

// 创建TextMessage并赋值

TextMessage tms = session.createTextMessage();

tms.setText("hello world!");

// 创建发送者，指定发送对象。TopicPublisher

QueueSender qSender = session.createSender(queue);

//发送

qSender.send(tms);

}

}