使用 CBE 和 JAXB 集成实现对 WebSphere Application Server 上应用程序的业务数据监控

核心提示： 清单 6. 发送 CBEjavax.naming.InitialContextinitContext=newjavax.naming.InitialContext();//通过JNDI查询事件队列连接工厂javax.jms.ConnectionFactoryconnectionFactory=(

清单 6. 发送 CBE
　javax.naming.InitialContext　initContext　=　
　new　javax.naming.InitialContext();　
　//　通过　JNDI　查询事件队列连接工厂　
　javax.jms.ConnectionFactory　connectionFactory　=　
　(javax.jms.ConnectionFactory)　initContext.lookup(　
　"jms/cei/EventQueueConnectionFactory");　
　javax.jms.Destination　destination　=　(javax.jms.Destination)　
　
　//　通过　JNDI　查询事件队列　
　initContext.lookup("jms/cei/EventQueue");　
　initContext.close();　
　
　//　创建连接　
　javax.jms.Connection　connection　=　
　(javax.jms.Connection)　connectionFactory.createConnection();　
　javax.jms.Session　session　=　connection.createSession(　
　true,javax.jms.Session.SESSION_TRANSACTED);　
　
　//　设置　JMS　消息内容　
　javax.jms.MessageProducer　sender　=　session.createProducer(destination);　
　javax.jms.TextMessage　message　=　session.createTextMessage();　
　
　//　加载　CBE　
　message.setText(eventXMLString);　
　message.setJMSType("CREATE_EVENTS_NOTIFICATION_V2_0");　
　message.setStringProperty("eventName",　operationName);　
　sender.send(message);　
　
　//　释放连接　
　sender.close();　
　session.close();　
　connection.close();　

在 Websphere Application Server 上查看 EJB3 应用程序的 CBE 事件