Updated Branches: refs/heads/master bf3a19dc7 -> d960e6e96
THRIFT-2195 Delphi event handlers - fix for multiplex protocol Project: http://git-wip-us.apache.org/repos/asf/thrift/repo Commit: http://git-wip-us.apache.org/repos/asf/thrift/commit/d960e6e9 Tree: http://git-wip-us.apache.org/repos/asf/thrift/tree/d960e6e9 Diff: http://git-wip-us.apache.org/repos/asf/thrift/diff/d960e6e9 Branch: refs/heads/master Commit: d960e6e9662d4a9128dc7a8378ab54ad030e24ec Parents: bf3a19d Author: Jens Geyer <[email protected]> Authored: Thu Dec 19 22:06:30 2013 +0100 Committer: Jens Geyer <[email protected]> Committed: Thu Dec 19 22:06:30 2013 +0100 ---------------------------------------------------------------------- lib/delphi/src/Thrift.Processor.Multiplex.pas | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/thrift/blob/d960e6e9/lib/delphi/src/Thrift.Processor.Multiplex.pas ---------------------------------------------------------------------- diff --git a/lib/delphi/src/Thrift.Processor.Multiplex.pas b/lib/delphi/src/Thrift.Processor.Multiplex.pas index 8d6d8b0..198bed8 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;
