in SampleConsumer/SampleConsumer.cs [158:168]
public static void Main(string[] args)
{
try
{
KclProcess.Create(new SampleRecordProcessor()).Run();
}
catch (Exception e)
{
Console.Error.WriteLine("ERROR: " + e);
}
}