JMS(十二):MDBを深く把握する
詳細
EJB 3では、1つのMDB(メッセージ駆動Bean)がMessageListenerインタフェースを実現したPOJOであり、以下に簡単なMDBである.
@MessageDrivenとしてマークアップする必要があります.これは、Destinationがマークアップ属性によって注入されることを監視しています.
メッセージを送信するStatelessBeanを次に示します.
このEJBには1つの方法しかありません.
次はクライアントです.
JNDIで上のEJBを検索し、sengMessageを呼び出します.
記事の出典:http://www.cnblogs.com/guthing/archive/2010/06/12/1757189.html
EJB 3では、1つのMDB(メッセージ駆動Bean)がMessageListenerインタフェースを実現したPOJOであり、以下に簡単なMDBである.
@MessageDriven(activationConfig={@ActivationConfigProperty(propertyName="destinationType", propertyValue="javax.jms.Queue"), @ActivationConfigProperty(propertyName="destination", propertyValue="queue/testQueue")})
public class SimpleMDB implements MessageListener {
public void onMessage(Message message) {
try {
System.out.println("Receive Message : " + ((TextMessage)message).getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
}
@MessageDrivenとしてマークアップする必要があります.これは、Destinationがマークアップ属性によって注入されることを監視しています.
メッセージを送信するStatelessBeanを次に示します.
@Remote
public interface IMessageSender {
public void sendMessage(String content) throws Exception;
}
@Stateless
@Remote
public class MessageSender implements IMessageSender {
@Resource(mappedName="ConnectionFactory")
private ConnectionFactory factory;
@Resource(mappedName="queue/testQueue")
private Queue queue;
public void sendMessage(String content) throws Exception {
Connection cn = factory.createConnection();
Session session = cn.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = session.createProducer(queue);
producer.send(session.createTextMessage(content));
}
}
このEJBには1つの方法しかありません.
次はクライアントです.
public class MessageSenderClient {
public static void main(String[] args) throws Exception {
Properties props = new Properties();
props.setProperty(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
props.setProperty(Context.PROVIDER_URL, "localhost:2099");
Context context = new InitialContext(props);
IMessageSender messageSender = (IMessageSender) context.lookup("MessageSender/remote");
messageSender.sendMessage("Hello");
}
}
JNDIで上のEJBを検索し、sengMessageを呼び出します.
記事の出典:http://www.cnblogs.com/guthing/archive/2010/06/12/1757189.html