@Override
	public void cleanup() {
		try {
			if (clientSocket != null) {
				clientSocket.close();
			}
			if (serverSocket != null) {
				serverSocket.close();
			}
			listenerThread.interrupt();
		}
		catch (IOException e) {
			throw new RuntimeException(e);
		}
	}
Return the bytes received by the sink

@return bytes received by the sink
@throws IOException exception getting bytes from ByteArrayOutputStream
spring-xd-test-fixtures/src/main/java/org/springframework/xd/test/fixtures/TcpSink.java