package test.sematest;

import java.io.IOException;

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

public class PutTester extends Tester {

	public PutTester(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_PUT);
		command.setString("put test");
		channel.write(command);
		
		channel.read();

	}
	
	public static void main(String[] args){
		Thread tester = new PutTester("PutTester", "localhost", 8766);
		tester.start();
	}

}