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