*/
public class ConsoleAcceptor implements Acceptor {
- private class ConsoleReceiver implements Receiver<String> {
+ private class ConsoleTransmitter implements Transmitter<String> {
private Scanner scanner;
private boolean isActive;
- ConsoleReceiver(InputStream input) {
+ ConsoleTransmitter(InputStream input) {
scanner = new Scanner(input);
isActive = true;
}
}
@Override
- public String receiveCommand() {
+ public String transmitCommand() {
return scanner.nextLine();
}
@Override
+ public void addCommand(String command) {
+ // not supported for console acceptor
+ }
+
+ @Override
public void stop() {
isActive = false;
}
}
}
- private ConsoleReceiver receiver;
+ private ConsoleTransmitter transmitter;
private PrintWriter writer;
ConsoleAcceptor(InputStream input, OutputStream output) {
- receiver = new ConsoleReceiver(input);
+ transmitter = new ConsoleTransmitter(input);
writer = new PrintWriter(output, true);
}
- public Receiver<String> receiver() {
- return receiver;
+ public Transmitter<String> transmitter() {
+ return transmitter;
}
@Override
@Override
public void terminate(String params) {
- receiver.stop();
+ transmitter.stop();
}
private void console(String name, String params) {