//引入相關(guān)包
import java.util.*;
import javax.ejb.*;
import javax.jms.*;
import java.sql.*;
import java.sql.Connection;
import java.rmi.*;
import javax.sql.*;
import javax.naming.*;
public class MDBean implements MessageDrivenBean, MessageListener 
{
	//實(shí)現(xiàn)MessageDrivenBean接口方法
	private MessageDrivenContext mdc;
	public void ejbCreate() 
	{
	}
	public void ejbRemove() 
	{
	}
	public void setMessageDrivenContext(MessageDrivenContext mdc) 
	{
		this.mdc = mdc;
	}
	//實(shí)現(xiàn)MessageListener接口方法
	public void onMessage(Message message) 
	{
		MapMessage mapmessage = (MapMessage) message;
		try 
		{
      		Enumeration e = mapmessage.getMapNames();
			Hashtable msg = new Hashtable();
			String[] val=new String[2];
			int flag=0;
        	while (e.hasMoreElements()) 
        	{
				String key = (String) e.nextElement();
				val[flag] = mapmessage.getString(key);
				System.out.print(val[flag]+"\t");
				flag++;
			}
            val[0]=new String(val[0].getBytes(),"ISO-8859-1");
            val[1]=new String(val[1].getBytes(),"ISO-8859-1");
            Connection con=this.getConnection();
            Statement st=con.createStatement();
            st.executeUpdate("insert into message values('"+val[0]+"','"+val[1]+"')");
            con.close();
        } 
        catch(Exception e) 
        {
           	e.printStackTrace();
        }
	}
}