BaseMessageQueue
StockSharp.Messages
Base implementation of IMessageQueue.
Inherits: BaseOrderedChannel<long, Message, PriorityQueue<long, Message>>
Implements: IMessageQueue, ICloneable<IMessageQueue>, ICloneable
Constructors
BaseMessageQueue
protected BaseMessageQueue()baseMessageQueue = BaseMessageQueue()Base implementation of IMessageQueue.
Methods
Clone
public abstract IMessageQueue Clone()result = baseMessageQueue.Clone()Creates a deep copy of a DataSeries
Enqueue
public abstract ValueTask Enqueue(Message message, CancellationToken cancellationToken)result = baseMessageQueue.Enqueue(message, cancellationToken)Enqueues the specified message.
- message
- The message to enqueue.
- cancellationToken
- Cancellation token.