Class AsyncMessageAdapter
- Namespace
- StockSharp.Messages
- Assembly
- StockSharp.Messages.dll
Message adapter with async processing support.
public abstract class AsyncMessageAdapter : MessageAdapter, IMessageAdapter, IMessageChannel, ICloneable<IMessageChannel>, ICloneable, IPersistable, ILogReceiver, ILogSource, IDisposable, INotifyPropertyChanged- Inheritance
-
AsyncMessageAdapter
- Implements
-
ICloneable<IMessageChannel>IPersistable
- Derived
- Inherited Members
- Extension Methods
Constructors
AsyncMessageAdapter(IdGenerator)
Initialize AsyncMessageAdapter.
protected AsyncMessageAdapter(IdGenerator transactionIdGenerator)Parameters
transactionIdGeneratorIdGeneratorTransaction id generator.
Properties
DisconnectTimeout
Disconnect timeout.
[Browsable(false)]
public virtual TimeSpan DisconnectTimeout { get; }Property Value
FaultDelay
Delay between faulted iterations.
[Display(ResourceType = typeof(LocalizedStrings), Name = "FaultDelay", Description = "FaultDelayDesc", GroupName = "Adapters", Order = 310)]
public TimeSpan FaultDelay { get; set; }Property Value
IsSupportPartialDownloading
Support partial downloading.
[Browsable(false)]
public override bool IsSupportPartialDownloading { get; }Property Value
MaxParallelMessages
Max number of parallel (non-control) messages processing.
[Display(ResourceType = typeof(LocalizedStrings), Name = "Parallel", Description = "ParallelDesc", GroupName = "Adapters", Order = 310)]
public int MaxParallelMessages { get; set; }Property Value
Methods
BoardLookupAsync(BoardLookupMessage, CancellationToken)
Process BoardLookupMessage.
public virtual ValueTask BoardLookupAsync(BoardLookupMessage lookupMsg, CancellationToken cancellationToken)Parameters
lookupMsgBoardLookupMessagecancellationTokenCancellationToken
Returns
CancelOrderAsync(OrderCancelMessage, CancellationToken)
Process OrderCancelMessage.
public virtual ValueTask CancelOrderAsync(OrderCancelMessage cancelMsg, CancellationToken cancellationToken)Parameters
cancelMsgOrderCancelMessagecancellationTokenCancellationToken
Returns
CancelOrderGroupAsync(OrderGroupCancelMessage, CancellationToken)
Process OrderGroupCancelMessage.
public virtual ValueTask CancelOrderGroupAsync(OrderGroupCancelMessage cancelMsg, CancellationToken cancellationToken)Parameters
cancelMsgOrderGroupCancelMessagecancellationTokenCancellationToken
Returns
ConnectAsync(ConnectMessage, CancellationToken)
Process ConnectMessage.
public virtual ValueTask ConnectAsync(ConnectMessage connectMsg, CancellationToken cancellationToken)Parameters
connectMsgConnectMessagecancellationTokenCancellationToken
Returns
DisconnectAsync(DisconnectMessage, CancellationToken)
Process DisconnectMessage.
public virtual ValueTask DisconnectAsync(DisconnectMessage disconnectMsg, CancellationToken cancellationToken)Parameters
disconnectMsgDisconnectMessagecancellationTokenCancellationToken
Returns
DisposeManaged()
protected override void DisposeManaged()GetHistoryStepSize(SecurityId, DataType, out TimeSpan)
Get maximum size step allowed for historical download.
public override TimeSpan GetHistoryStepSize(SecurityId securityId, DataType dataType, out TimeSpan iterationInterval)Parameters
securityIdSecurityIddataTypeDataTypeData type info.
iterationIntervalTimeSpanInterval between iterations.
Returns
- TimeSpan
Step.
Load(SettingsStorage)
Load settings.
public override void Load(SettingsStorage storage)Parameters
storageSettingsStorageSettings storage.
MarketDataAsync(MarketDataMessage, CancellationToken)
Process MarketDataMessage.
public virtual ValueTask MarketDataAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)Parameters
mdMsgMarketDataMessagecancellationTokenCancellationToken
Returns
OnCandlesSubscriptionAsync(MarketDataMessage, CancellationToken)
protected virtual ValueTask OnCandlesSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)Parameters
mdMsgMarketDataMessagecancellationTokenCancellationToken
Returns
OnLevel1SubscriptionAsync(MarketDataMessage, CancellationToken)
protected virtual ValueTask OnLevel1SubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)Parameters
mdMsgMarketDataMessagecancellationTokenCancellationToken
Returns
OnMarketDepthSubscriptionAsync(MarketDataMessage, CancellationToken)
protected virtual ValueTask OnMarketDepthSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)Parameters
mdMsgMarketDataMessagecancellationTokenCancellationToken
Returns
OnNewsSubscriptionAsync(MarketDataMessage, CancellationToken)
protected virtual ValueTask OnNewsSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)Parameters
mdMsgMarketDataMessagecancellationTokenCancellationToken
Returns
OnOrderLogSubscriptionAsync(MarketDataMessage, CancellationToken)
protected virtual ValueTask OnOrderLogSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)Parameters
mdMsgMarketDataMessagecancellationTokenCancellationToken
Returns
OnSendInMessage(Message)
Send message.
protected override bool OnSendInMessage(Message message)Parameters
messageMessageMessage.
Returns
OnTFCandlesSubscriptionAsync(MarketDataMessage, CancellationToken)
protected virtual ValueTask OnTFCandlesSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)Parameters
mdMsgMarketDataMessagecancellationTokenCancellationToken
Returns
OnTicksSubscriptionAsync(MarketDataMessage, CancellationToken)
protected virtual ValueTask OnTicksSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)Parameters
mdMsgMarketDataMessagecancellationTokenCancellationToken
Returns
OrderStatusAsync(OrderStatusMessage, CancellationToken)
Process OrderStatusMessage.
public virtual ValueTask OrderStatusAsync(OrderStatusMessage statusMsg, CancellationToken cancellationToken)Parameters
statusMsgOrderStatusMessagecancellationTokenCancellationToken
Returns
PortfolioLookupAsync(PortfolioLookupMessage, CancellationToken)
Process PortfolioLookupMessage.
public virtual ValueTask PortfolioLookupAsync(PortfolioLookupMessage lookupMsg, CancellationToken cancellationToken)Parameters
lookupMsgPortfolioLookupMessagecancellationTokenCancellationToken
Returns
ProcessMessageAsync(Message, CancellationToken)
Process Message.
public virtual ValueTask ProcessMessageAsync(Message msg, CancellationToken cancellationToken)Parameters
msgMessagecancellationTokenCancellationToken
Returns
RegisterOrderAsync(OrderRegisterMessage, CancellationToken)
Process OrderRegisterMessage.
public virtual ValueTask RegisterOrderAsync(OrderRegisterMessage regMsg, CancellationToken cancellationToken)Parameters
regMsgOrderRegisterMessagecancellationTokenCancellationToken
Returns
ReplaceOrderAsync(OrderReplaceMessage, CancellationToken)
Process OrderReplaceMessage.
public virtual ValueTask ReplaceOrderAsync(OrderReplaceMessage replaceMsg, CancellationToken cancellationToken)Parameters
replaceMsgOrderReplaceMessagecancellationTokenCancellationToken
Returns
ResetAsync(ResetMessage, CancellationToken)
Process ResetMessage.
public virtual ValueTask ResetAsync(ResetMessage resetMsg, CancellationToken cancellationToken)Parameters
resetMsgResetMessagecancellationTokenCancellationToken
Returns
Remarks
Must NOT throw.
Save(SettingsStorage)
Save settings.
public override void Save(SettingsStorage storage)Parameters
storageSettingsStorageSettings storage.
SecurityLookupAsync(SecurityLookupMessage, CancellationToken)
Process SecurityLookupMessage.
public virtual ValueTask SecurityLookupAsync(SecurityLookupMessage lookupMsg, CancellationToken cancellationToken)Parameters
lookupMsgSecurityLookupMessagecancellationTokenCancellationToken
Returns
TimeAsync(TimeMessage, CancellationToken)
Process TimeMessage.
public virtual ValueTask TimeAsync(TimeMessage timeMsg, CancellationToken cancellationToken)Parameters
timeMsgTimeMessagecancellationTokenCancellationToken