basemessage.java

这是一个用jsp+Oracle开发的联系人客户关系管理系统！

import net.jxta.pipe.*;
import net.jxta.endpoint.*;

public class BaseMessage
{
	public static String IP = null;					//输入管道的名称
	public static String OP = null;					//输出管道的名称
	public static String CHAT = null;				//消息内容

	public static String FILE_NAME = null;			//文件名
	public static String FILE_MESSAGE_TYPE = null;	//文件类型

	public static String WEB__URL= null;			//网络地址
	public static String WEB_MESSAGE_TYPE = null;	//地址类型



	public Message newChatMessage(String message,String outputPipe,String inputPipe)
	{
		//MessageImpl msg = new MessageImpl();
		Message msg = new Message();
		msg.setString(this.CHAT,message);
		msg.setString(this.OP,outputPipe);
		msg.setString(this.IP,inputPipe);
		return msg;
	}

	public Message newFileMessage(InputStream is,String outputPipe,String inputPipe,String fileType,String fileName)
	{
		MessageImpl msg = new MessageImpl();
		try
		{
			if(is!=null)
			{
				MimeMediaType mmt = new MimeMediaType("text/html");//文件的类型
				MessageElemeltImpl mei = new MessageElementImpl(fileType,mmt,is);
				msg.addElement(mei);
			}

			if(outputPipe!=null)msg.setString(this.OP,outputPipe);
			if(inputPipe!=null)msg.setString(this.IP,inputPipe);
			if(fileName!=null)msg.setString(this.FILE_NAME,fileName);
			msg.setString(this.FILE_MESSAGE_TYPE,fileType);
		}catch(IOException ioe)
		{
			System.out.println("产生文件消息时出现I/O错误!");
			System.exit(-1);
		}
		return msg;
	}

	public Message newFileMessage(InputStream is,String outputPipe,String inputPipe,String WEBType,String url)
	{
		MessageImpl msg = new MessageImpl();
		try
		{
			if(is!=null)
			{
				MimeMediaType mmt = new MimeMediaType("text/html");//文件的类型
				MessageElemeltImpl mei = new MessageElementImpl(WEBType,mmt,is);
				msg.addElement(mei);
			}

			if(outputPipe!=null)msg.setString(this.OP,outputPipe);
			if(inputPipe!=null)msg.setString(this.IP,inputPipe);
			if(url!=null)msg.setString(this.WEB_URL,url);
			msg.setString(this.WEB_MESSAGE_TYPE,WEBType);
		}catch(IOException ioe)
		{
			System.out.println("产生发布网络消息时出现I/O错误!");
			System.exit(-1);
		}
		return msg;
	}
}