@Override
    public void process(IncomingMessageEnvelope envelope, MessageCollector collector, TaskCoordinator coordinator)
        throws Exception {
      // processing logic here
    }
Test example of a low-level API application (i.e. {@link TaskApplication})
samza-test/src/main/java/org/apache/samza/example/TaskApplicationExample.java