@Before
	public void setup() throws Exception {
		Environment.initializeIfEmpty().assignErrorJournal();
		processor = RingBufferProcessor.create(false);
		server = new GPFDistServer(processor, 8080, 1, 1, 1, 10);
		server.start();
		context = new AnnotationConfigApplicationContext();
	}
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