@Override
  public void process(IncomingMessageEnvelope envelope, MessageCollector collector, TaskCoordinator coordinator) throws Exception {

  }
Test implementation class for {@link StreamTask}
samza-core/src/test/java/org/apache/samza/task/MockStreamTask.java