From: Jens Geyer Date: Thu, 19 Dec 2013 21:06:30 +0000 (+0100) Subject: THRIFT-2195 Delphi event handlers - fix for multiplex protocol X-Git-Url: https://source.supwisdom.com/gerrit/gitweb?a=commitdiff_plain;h=d960e6e9662d4a9128dc7a8378ab54ad030e24ec;p=common%2Fthrift.git THRIFT-2195 Delphi event handlers - fix for multiplex protocol --- diff --git a/lib/delphi/src/Thrift.Processor.Multiplex.pas b/lib/delphi/src/Thrift.Processor.Multiplex.pas index 8d6d8b0c..198bed83 100644 --- a/lib/delphi/src/Thrift.Processor.Multiplex.pas +++ b/lib/delphi/src/Thrift.Processor.Multiplex.pas @@ -99,7 +99,7 @@ type An exception is thrown if the message type is not CALL or ONEWAY or if the service is unknown (or not properly registered). } - function Process(const iprot, oprot : IProtocol) : Boolean; + function Process( const iprot, oprot: IProtocol; const events : IProcessorEvents = nil): Boolean; end; @@ -162,7 +162,7 @@ begin end; -function TMultiplexedProcessorImpl.Process(const iprot, oprot : IProtocol) : Boolean; +function TMultiplexedProcessorImpl.Process(const iprot, oprot : IProtocol; const events : IProcessorEvents = nil): Boolean; var msg, newMsg : IMessage; idx : Integer; sService : string; @@ -208,7 +208,7 @@ begin // Dispatch processing to the stored processor protocol := TStoredMessageProtocol.Create( iprot, newMsg); - result := processor.process( protocol, oprot); + result := processor.process( protocol, oprot, events); end;