chatmdb.java

精通Jboss——Ejb和Web Services开发精解的随书源代码

/**
 * ChatMDB.java Created on 2003-12-8
 *
 */
package com.liuyang.xmessenger.mdb;

import java.util.Date;

import javax.ejb.EJBException;
import javax.ejb.MessageDrivenBean;
import javax.ejb.MessageDrivenContext;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.rmi.PortableRemoteObject;

import com.liuyang.ejb.cmp.node.NodeLocalHome;

/**
 * @author liuyang
 * 
 * @ejb.bean	name="ChatMDB"
 *     			acknowledge-mode="Auto-acknowledge"
 *     			destination-type="javax.jms.Topic"
 *     			subscription-durability="NonDurable"
 *     			transaction-type="Container"
 * 
 * @jboss.destination-jndi-name	name="topic/chatroom"	
 * 
 *  
 */
public class ChatMDB implements MessageDrivenBean, MessageListener{

	/**
	 * @ejb.create-method
	 */
	public void ejbCreate(){
	}
	public void ejbRemove() {
	}	
	public void setMessageDrivenContext(MessageDrivenContext arg0)
		throws EJBException {
	}
	NodeLocalHome home = null;
	public void onMessage(Message message) {
		try {
			if(home==null){
				Context iniCtx = new InitialContext();
				Object objRef = iniCtx.lookup("cmp/nodelocal");
				home = (NodeLocalHome)PortableRemoteObject.narrow(objRef, NodeLocalHome.class);
			}
			if(message instanceof TextMessage){
				TextMessage msg = (TextMessage) message;
				String text = msg.getText();
				if(text!=null){
					System.out.print("msg : "+text);
					Date date = new Date();
					home.create("即时通讯 : "+date,text,date);					
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}		
	}
}