public void terminate() {
		stop = true;

		try {
			socket.close();
			in.interrupt();
			out.interrupt();
		} catch (final IOException ioe) {
			// Ignore
		}

		logger.debug("Terminated peer exchange with " + peer + "...");
	}