in lib/aws/kclrb/kcl_process.rb [87:97]
def dispatch_to_processor(method, *args)
@processor.send(method, *args)
rescue => processor_error
@io_proxy.write_error(processor_error)
end