Class: Concord::Thrift::BoltManagerService::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/gen-rb/bolt_manager_service.rb

Instance Method Summary collapse

Instance Method Details

#process_setEnvironmentVar(seqid, iprot, oprot) ⇒ Object



51
52
53
54
55
56
57
58
59
60
# File 'lib/gen-rb/bolt_manager_service.rb', line 51

def process_setEnvironmentVar(seqid, iprot, oprot)
  args = read_args(iprot, SetEnvironmentVar_args)
  result = SetEnvironmentVar_result.new()
  begin
    @handler.setEnvironmentVar(args.name, args.value)
  rescue ::Concord::Thrift::BoltError => e
    result.e = e
  end
  write_result(result, oprot, 'setEnvironmentVar', seqid)
end

#process_signal(seqid, iprot, oprot) ⇒ Object



62
63
64
65
66
67
68
69
70
71
# File 'lib/gen-rb/bolt_manager_service.rb', line 62

def process_signal(seqid, iprot, oprot)
  args = read_args(iprot, Signal_args)
  result = Signal_result.new()
  begin
    @handler.signal(args.topologyId, args.s)
  rescue ::Concord::Thrift::BoltError => e
    result.e = e
  end
  write_result(result, oprot, 'signal', seqid)
end