JMS(十二):MDBを深く把握する

2493 ワード

詳細
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