SubscriptionManager
StockSharp.Algo
Subscription message processing implementation.
Implements: ISubscriptionManager
Constructors
SubscriptionManager
public SubscriptionManager(ILogReceiver logReceiver, IdGenerator transactionIdGenerator, Func<Message> createProcessSuspendedMessage, ISubscriptionManagerState state)subscriptionManager = SubscriptionManager(logReceiver, transactionIdGenerator, createProcessSuspendedMessage, state)Subscription message processing implementation.
- logReceiver
- Log receiver.
- transactionIdGenerator
- Transaction id generator.
- createProcessSuspendedMessage
- Create a message that resumes processing after remapped subscriptions are enqueued.
- state
- State storage.
Properties
State
public ISubscriptionManagerState State { get; }value = subscriptionManager.StateState storage.
Methods
ProcessInMessage
public ValueTuple<Message[], Message[]> ProcessInMessage(Message message)result = subscriptionManager.ProcessInMessage(message)Process a message going into the inner adapter.
- message
- Incoming message.
Returns: Processing result.
ProcessOutMessage
public ValueTuple<Message, Message[]> ProcessOutMessage(Message message)result = subscriptionManager.ProcessOutMessage(message)Process a message coming from the inner adapter.
- message
- Outgoing message.
Returns: Processing result.