package test.sematest;

import java.io.IOException;

import rep.REP;
import rep.REPCommand;
import rep.channel.REPSocketChannel;

public class JoinTester extends Tester {

	public JoinTester(String name, String _host, int _port) {
		super(name, _host, _port);
	}

	@Override
	public void sendCommand(REPSocketChannel<REPCommand> channel)throws IOException {
		REPCommand command = new REPCommand();
		command.setCMD(REP.SMCMD_JOIN);
		command.setString("join test");
		channel.write(command);
		
		channel.read();
	}
	
	public static void main(String[] args){
		Thread tester = new JoinTester("JoinTester", "localhost", 8766);
		tester.start();
	}

}