FixServer

FixServer

public FixServer(IAuthorization authorization, ITransactionIdStorage transactionIdStorage, string licenseFeatureId, Type componentType)

fixServer = FixServer(authorization, transactionIdStorage, licenseFeatureId, componentType)

Inicializa uma nova instância do FixServer.

authorization

A autenticação do cliente.

transactionIdStorage

Armazenamento de identificadores de transação e de solicitação.

licenseFeatureId

LicenseFeatureId

componentType

ComponentTimestamp

FixServer

public FixServer(IAuthorization authorization, ITransactionIdStorage transactionIdStorage, string licenseFeatureId, DateTime componentTimestamp, IMessageConverter converter)

fixServer = FixServer(authorization, transactionIdStorage, licenseFeatureId, componentTimestamp, converter)

Inicializa uma nova instância do FixServer.

authorization

A autenticação do cliente.

transactionIdStorage

Armazenamento de identificadores de transação e de solicitação.

licenseFeatureId

LicenseFeatureId

componentTimestamp

ComponentTimestamp

converter

Conversor de mensagens.

Authorization

public IAuthorization Authorization { get; }

value = fixServer.Authorization

A autenticação do cliente.

ComponentTimestamp

public DateTime ComponentTimestamp { get; }

value = fixServer.ComponentTimestamp

Hora do componente.

Converter

public IMessageConverter Converter { get; }

value = fixServer.Converter

Conversor de mensagens para FIX ↔ StockSharp message conversion.

LicenseFeatureId

public string LicenseFeatureId { get; }

value = fixServer.LicenseFeatureId

ID do recurso de licença a ser enviado como resposta do Logon.

SendOutHeartbeats

public bool SendOutHeartbeats { get; set; }

value = fixServer.SendOutHeartbeats
fixServer.SendOutHeartbeats = value

Enviar batimentos cardíacos através do canal de mensagens enviadas.

TransactionIdStorage

public ITransactionIdStorage TransactionIdStorage { get; }

value = fixServer.TransactionIdStorage

CreateCondition

protected virtual OrderCondition CreateCondition()

result = fixServer.CreateCondition()

Para criar a condição de ordem.

Retorna: A condição de ordem.

CreateSubscription

protected override FixServerSubscription CreateSubscription(ClientFixSession session, string requestId, ServerSubscription subscription, MessageTypes type)

result = fixServer.CreateSubscription(session, requestId, subscription, type)

CreateTransactionId

private long CreateTransactionId(ClientFixSession session, string requestId)

result = fixServer.CreateTransactionId(session, requestId)

Gerar um novo identificador de requisição.

session

Sessão.

requestId

Pedido identificador.

Retorna: ID da transação.

GetSessionKey

protected override string GetSessionKey(ClientFixSession session)

result = fixServer.GetSessionKey(session)

IsStubSubscription

protected override bool IsStubSubscription(FixServerSubscription subscription)

result = fixServer.IsStubSubscription(subscription)

Load

public override void Load(SettingsStorage storage)

fixServer.Load(storage)

Carregar as configurações.

storage

Configuração do armazenamento.

OnClearListenerState

protected override void OnClearListenerState()

fixServer.OnClearListenerState()

Limpar o estado de ouvinte específico do protocolo (stop outleners, etc.).

OnProcess

protected virtual IAsyncEnumerable<Message> OnProcess(FixSession session, string msgType, IFixReader reader, CancellationToken cancellationToken)

result = fixServer.OnProcess(session, msgType, reader, cancellationToken)

O método é chamado quando a mensagem recebida é processamento.

OnStartListeners

protected override void OnStartListeners(CancellationToken cancellationToken)

fixServer.OnStartListeners(cancellationToken)

Iniciar ouvintes específicos do protocolo (TCP, etc.). Adicionar tarefas a _backgroundTasks.

PostInitCondition

protected virtual void PostInitCondition(char ordType, OrderCondition condition)

fixServer.PostInitCondition(ordType, condition)

A inicialização final da condição de ordem.

ordType

Tipo de ordem.

condition

A condição de ordem.

ProcessInMessage

protected override void ProcessInMessage(Message message, CancellationToken cancellationToken)

fixServer.ProcessInMessage(message, cancellationToken)

Processe uma mensagem recebida e route para clientes subscritos.

ProcessLogout

protected override void ProcessLogout(ClientFixSession session)

fixServer.ProcessLogout(session)

ReadOrderConditionAsync

protected virtual ValueTask<bool> ReadOrderConditionAsync(IFixServerSerializer serializer, FixTags tag, Func<OrderCondition> getCondition, CancellationToken cancellationToken)

result = fixServer.ReadOrderConditionAsync(serializer, tag, getCondition, cancellationToken)

Para ler a condição de ordem OrderCondition.

serializer

IFixServerSerializer

tag

Marca.

getCondition

A função retornando a condição de ordem.

cancellationToken

CancellationToken

Retorna: Se os dados foram processados com sucesso.

Save

public override void Save(SettingsStorage storage)

fixServer.Save(storage)

Gravar as definições.

storage

Configuração do armazenamento.

ScheduleSessionWork

protected override void ScheduleSessionWork(ClientFixSession session, ServerSubscription subscription, string requestId, Func<ClientFixSession, string, CancellationToken, ValueTask<bool>> handler)

fixServer.ScheduleSessionWork(session, subscription, requestId, handler)

TryGetRequestId

private static string TryGetRequestId(ClientFixSession session, long transactionId)

result = FixServer.TryGetRequestId(session, transactionId)

Obtenha o identificador de solicitação.

session

A sessão.

transactionId

ID da transação.

Retorna: Pedido identificador.

TryResolveTransactionId

internal static bool TryResolveTransactionId(ISessionTransactionIdStorage storage, string requestId, long transactionId)

result = FixServer.TryResolveTransactionId(storage, requestId, transactionId)

Resolver um ID de solicitação de cliente para um ID de transação do servidor.

storage

O armazenamento do ID da transação de sessão.

requestId

O identificador do pedido.

transactionId

O ID da transação resolvido.

Retorna: se o ID da transação foi resolvido; caso contrário, .

WriterFixOrderConditionAsync

protected virtual ValueTask WriterFixOrderConditionAsync(IFixServerSerializer serializer, OrderCondition condition, CancellationToken cancellationToken)

result = fixServer.WriterFixOrderConditionAsync(serializer, condition, cancellationToken)

Para gravar dados pela condição de ordem (versão assync).

serializer

IFixServerSerializer

condition

Condições de ordem (e.g., parâmetros de ordem de paragem e algo).

cancellationToken

Inscrição de cancelamento.