OfflineMessageAdapter
StockSharp.Algo
O adaptador de mensagens mantém a mensagem até que a conexão seja feita.
Herda de: MessageAdapterWrapper
Construtores
OfflineMessageAdapter
public OfflineMessageAdapter(IMessageAdapter innerAdapter)
offlineMessageAdapter = OfflineMessageAdapter(innerAdapter)
Inicializa uma nova instância do OfflineMessageAdapter.
- innerAdapter
- Adaptador subjacente.
OfflineMessageAdapter
public OfflineMessageAdapter(IMessageAdapter innerAdapter, IOfflineManager manager)
offlineMessageAdapter = OfflineMessageAdapter(innerAdapter, manager)
Inicializa uma nova instância do OfflineMessageAdapter com um gerenciador personalizado.
- innerAdapter
- Adaptador subjacente.
- manager
- Gerente desligado.
Propriedades
MaxMessageCount
public int MaxMessageCount { get; set; }
value = offlineMessageAdapter.MaxMessageCount
offlineMessageAdapter.MaxMessageCount = value
Número máximo de filas de mensagens. O valor padrão é 10000.
SendInBackFurther
protected override bool SendInBackFurther { get; }
value = offlineMessageAdapter.SendInBackFurther
Enviar automaticamente BackMode mensagens para InnerAdapter.
Métodos
Clone
public override IMessageAdapter Clone()
result = offlineMessageAdapter.Clone()
Criar uma cópia de OfflineMessageAdapter.
Retorna: Entendido.
OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = offlineMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)
Processo InnerAdapter output message.
- message
- A mensagem.
- cancellationToken
- Inscrição de cancelamento.
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = offlineMessageAdapter.OnSendInMessageAsync(message, cancellationToken)
Enviar mensagem.
- message
- Message.
- cancellationToken
- CancellationToken