package com.java.NetTalk;

import java.io.IOException;
import java.net.InetAddress;
import java.nio.ByteBuffer;

public class NetTalkRoom implements Runnable {
	public NetTalkRoom(String serverAddress, int port,String endTag)throws IOException,ProtNetException{
		this.endTag	  = endTag;
		++NetTalkRoom.PersonCount;
		netServer     = new NetTalkServer(port,endTag);
		netTalkClient = new NetTalkClient(serverAddress,port);
	}
	
	public NetTalkRoom(InetAddress address, int port,String endTag)throws IOException,ProtNetException{
		this.endTag	  = endTag;
		netServer     = new NetTalkServer(port,endTag);
		netTalkClient = new NetTalkClient(address,port);
	}
	
	
	public boolean SendMessage(ByteBuffer message) throws IOException,NotOpenNetException{
		return netTalkClient.SendMessage(message);
	}
	
	public long getPersonCount(){
		return NetTalkRoom.PersonCount;
	}
	
	public void run(){
			while(bIsRun){
				if(!netServer.isAlive()){
					netServer.start();
				}
			}
	}

	private String		  endTag;
	private NetTalkServer netServer;
	private NetTalkClient netTalkClient;
	private boolean 	  bIsRun = true;
	private static long   PersonCount = 0;	  
}