Class: Thrift::MultiplexedProcessor
- Inherits:
-
Object
- Object
- Thrift::MultiplexedProcessor
- Defined in:
- lib/thrift/processor.rb
Instance Method Summary collapse
-
#initialize ⇒ MultiplexedProcessor
constructor
A new instance of MultiplexedProcessor.
- #process(iprot, oprot) ⇒ Object
- #register(service_name, processor) ⇒ Object
Constructor Details
#initialize ⇒ MultiplexedProcessor
Returns a new instance of MultiplexedProcessor.
63 64 65 |
# File 'lib/thrift/processor.rb', line 63 def initialize @actual_processors = Hash.new end |
Instance Method Details
#process(iprot, oprot) ⇒ Object
72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 |
# File 'lib/thrift/processor.rb', line 72 def process(iprot, oprot) name, type, seqid = iprot. service_name, method = name.split(':') actual_processor = @actual_processors[service_name] if actual_processor.respond_to?("process_#{method}") actual_processor.send("process_#{method}", seqid, iprot, oprot) true else iprot.skip(Types::STRUCT) iprot. x = ApplicationException.new(ApplicationException::UNKNOWN_METHOD, 'Unknown function ' + name) oprot.(name, MessageTypes::EXCEPTION, seqid) x.write(oprot) oprot. oprot.trans.flush false end end |
#register(service_name, processor) ⇒ Object
67 68 69 70 |
# File 'lib/thrift/processor.rb', line 67 def register(service_name, processor) processor.instance_variable_set(:@service_name, service_name) @actual_processors[service_name] = processor end |