Class: Storm::DistributedRPCInvocations::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/storm/thrift/distributed_rpc_invocations.rb

Instance Method Summary collapse

Instance Method Details

#process_failRequest(seqid, iprot, oprot) ⇒ Object 



78
79
80
81
82
83
 
# File 'lib/storm/thrift/distributed_rpc_invocations.rb', line 78

def process_failRequest(seqid, iprot, oprot)
  args = read_args(iprot, FailRequest_args)
  result = FailRequest_result.new()
  @handler.failRequest(args.id)
  write_result(result, oprot, 'failRequest', seqid)
end

#process_fetchRequest(seqid, iprot, oprot) ⇒ Object 



71
72
73
74
75
76
 
# File 'lib/storm/thrift/distributed_rpc_invocations.rb', line 71

def process_fetchRequest(seqid, iprot, oprot)
  args = read_args(iprot, FetchRequest_args)
  result = FetchRequest_result.new()
  result.success = @handler.fetchRequest(args.functionName)
  write_result(result, oprot, 'fetchRequest', seqid)
end

#process_result(seqid, iprot, oprot) ⇒ Object 



64
65
66
67
68
69
 
# File 'lib/storm/thrift/distributed_rpc_invocations.rb', line 64

def process_result(seqid, iprot, oprot)
  args = read_args(iprot, Result_args)
  result = Result_result.new()
  @handler.result(args.id, args.result)
  write_result(result, oprot, 'result', seqid)
end