@Test
public void testSubprocessReactorPipingBackNonprocessCallable()
	throws Exception {

	List<ProcessLog> processLogs = new ArrayList<>();
	ProcessChannel<Serializable> processChannel =
		_localProcessExecutor.execute(
			_createJPDAProcessConfig(
				_JPDA_OPTIONS1,
				processLog -> {
					if (processLog.getLevel() == ProcessLog.Level.INFO) {
						processLogs.add(processLog);
					}
				}),
			Operations.PIPING_BACK_NONPROCESS_CALLABLE);
	NoticeableFuture<Serializable> noticeableFuture =
		processChannel.getProcessNoticeableFuture();
	noticeableFuture.get();
	Assert.assertEquals(processLogs.toString(), 1, processLogs.size());
	ProcessLog processLog = processLogs.get(0);
	Assert.assertEquals(
		"Received a nonprocess callable piping back string piping back " +
			"object",
		processLog.getMessage());
}