SingleNodeProcessingChainConsumer chain = chainConsumer(application, "dateToDateTime", processingChainUnderTest);
Object payload = chain.receivePayload(RECEIVE_TIMEOUT);
assertTrue(payload instanceof DateTime);
chain.destroy();
}
/**
* Test a processing chain that provides a sink. Send a payload and set up a tap to verify the result;
*/