Class ReliableSubscriptionBase

Inheritance
System.Object
ReliableSubscriptionBase
Implements
System.IDisposable
Namespace: Reaqtor.Reliable
Assembly: Reaqtor.Reliable.dll
Syntax
public abstract class ReliableSubscriptionBase : Object, IReliableSubscription, ISubscription, IDisposable, IOperator

Constructors

ReliableSubscriptionBase()

Declaration
protected ReliableSubscriptionBase()

Properties

Inputs

Declaration
public virtual IEnumerable<ISubscription> Inputs { get; }
Property Value
Type Description
System.Collections.Generic.IEnumerable<ISubscription>

ResubscribeUri

Declaration
public abstract Uri ResubscribeUri { get; }
Property Value
Type Description
System.Uri

Methods

Accept(ISubscriptionVisitor)

Declaration
public void Accept(ISubscriptionVisitor visitor)
Parameters
Type Name Description
ISubscriptionVisitor visitor

AcknowledgeRange(Int64)

Declaration
public abstract void AcknowledgeRange(long sequenceId)
Parameters
Type Name Description
System.Int64 sequenceId

Dispose()

Declaration
public void Dispose()

Dispose(Boolean)

Declaration
protected virtual void Dispose(bool disposing)
Parameters
Type Name Description
System.Boolean disposing

DisposeCore()

Declaration
public abstract void DisposeCore()

SetContext(IOperatorContext)

Declaration
public virtual void SetContext(IOperatorContext context)
Parameters
Type Name Description
IOperatorContext context

Start()

Declaration
public void Start()

Start(Int64)

Declaration
public abstract void Start(long sequenceId)
Parameters
Type Name Description
System.Int64 sequenceId

Stop()

Declaration
protected virtual void Stop()

Subscribe()

Declaration
public virtual void Subscribe()

Explicit Interface Implementations

IReliableSubscription.AcknowledgeRange(Int64)

Declaration
void IReliableSubscription.AcknowledgeRange(long sequenceId)
Parameters
Type Name Description
System.Int64 sequenceId

IReliableSubscription.Start(Int64)

Declaration
void IReliableSubscription.Start(long sequenceId)
Parameters
Type Name Description
System.Int64 sequenceId

Implements

System.IDisposable