anchor.diff:    TAsyncInvokeThread.Create(Self, AName, Args, Callback, ASettings);
   end;
   
  -{$IFDEF SUPPORTS_GENERICS}
  +{$IFDEF SUPPORTS_ANONYMOUS_METHOD}
   
   procedure THproseClient.VarToT(Info: PTypeInfo; const Src: Variant; out Dst);
   var
  
positive.code:       const ASettings: IInvokeSettings); overload;
    end;
  
  { TOnewayThread }
  
  procedure TOnewayThread.Execute;
  
negative.code:     property Retried: Integer read FRetried write FRetried;
    end;
  
    { TClientTopic }
  
    TClientTopic = class(TThread)
    private
      FClient: THproseClient;
      FName: string;
      FId: string;
      FCallback: THproseCallback1;
      FSettings: IInvokeSettings;
    protected
      procedure Execute; override;
    public
      constructor Create(Client: THproseClient; const AName, AId: string;
        Callback: THproseCallback1; const ASettings: IInvokeSettings);
    end;
  
    { TTopicManager }
  
    TTopicManager = class
    private
      FAllTopics: IMap;
      function GetTopic(const Topic, Id: string): TClientTopic;
      procedure CreateTopic(const Topic: string);
      procedure DeleteTopic(const Topic, Id: string);
    public
      constructor Create;
      function IsSubscribed(const Topic: string): Boolean;
      function SubscribedList(): TStringArray;
    end;
  
    { THproseClient }
  
  