class Concord::Thrift::BoltPipeService::Processor
Public Instance Methods
process_dispatchRecords(seqid, iprot, oprot)
click to toggle source
# File lib/gen-rb/bolt_pipe_service.rb, line 36 def process_dispatchRecords(seqid, iprot, oprot) args = read_args(iprot, DispatchRecords_args) result = DispatchRecords_result.new() begin @handler.dispatchRecords(args.records) rescue ::Concord::Thrift::BoltError => e result.e = e end write_result(result, oprot, 'dispatchRecords', seqid) end