protected void broadcastData(List<String> data) {
		for (String d : data) {
			processor.onNext(Buffer.wrap(d));
		}
	}
Base integration support for using local protocol listener.

@author Janne Valkealahti
extensions/spring-xd-extension-gpfdist/src/test/java/org/springframework/xd/greenplum/AbstractLoadTests.java