xmessenger.java

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

/**
 * ChatMessager.java Created on 2003-12-7
 *
 */
package com.liuyang.xmessenger.impl;

import com.liuyang.xmessenger.Listener;
import com.liuyang.xmessenger.Message;
import com.liuyang.xmessenger.Status;
import com.liuyang.xmessenger.Transporter;

/**
 * @author liuyang
 *
 */
public class XMessenger extends UserMessenger {
	public void sendMessage(Message message) {
		transporter.sendMessage(message);
	}
	private Listener listener = null; 
	private Status status = new Status();
	
	Transporter transporter = null; 
	public Listener connect(Transporter trans) {
		transporter = trans;
		listener = transporter.connect(getURL());
		status.start();
		return listener;
	}
	private String channel = "chatroom";
	public void setURL(String url) {
		channel = url;
	}
	public String getURL() {
		return channel;
	}
	protected boolean isOnline(){
		return status.isStarted();
	}
	public void disconnect() {
		transporter.disconnect();
		this.setAuthenticated(false);
	}	
}