全面研读 EJB 2.0

public class ShoppingCartBean implements SessionBean {
   // 订单详细信息是一个可序列化的对象，它包含全部订单信息。
   public OrderDetail orderDetail;
    public void processOrder(){
          // 处理订单的逻辑从此处开始
....
          // ... 处理订单以后，向其它系统发送有关此订单的一条消息
          InitialContext jndiEnc = new
InitialContext();
          // 使用 JNDI ENC 获取 JMS 工厂和主题标识符
          TopicConnectionFactory factory =
          jndiEnc.lookup("java:comp/env/jms/topicfactory");
          Topic orderTopic =
jndiEnc.lookup("java:comp/env/jms/ordertopic");
          // 获得一个用来发送消息的发布者
          TopicConnection con =
factory.createTopicConnection();
          TopicSession session =
                   con.createTopicSession(false,
Session.AUTO_ACKNOWLEDGE );
          TopicPublisher publisher =
session.createPublisher(orderTopic);
          // 将一个 ObjectMessage 发送给主题（虚拟通道）
          ObjectMessage message =
session.createObjectMessage();
          message.setObject(orderDetail);
          publisher.publish(message);
          con.close();
    }
    ...
}

public class MarketingBean implements
javax.ejb.MessageDrivenBean {
      public void onMessage(Message message) {
          ObjectMessage orderMessage =
(ObjectMessage)orderMessage:
            OrderDetail orderDetail =
(OrderDetail)orderMessage.getObject();
          Integer customerID =
orderDetail.getCustomerID();
          InitialContext jndiEnc = new
InitialContext();
          CatalogHome catalogHome =
            (CatalogHome)jndiEnc.lookup("java:comp/env/ejb/catalog");
          Iterator productIDs =
orderDetail.getProductsIDs();
          while(productIDs.hasNext()){
            Integer productID =
(Integer)productIDs.next();
            Catalog cat =
CatalogHome.findByProductID(productID);
            cat.addCustomerToMailingList(customerID);
          }
     }
}