MessageAdapter
El adaptador base convierte mensajes Mensaje al comando del sistema de comercio y la espalda.
Hereda de: BaseLogReceiver
Implementa: IMessageAdapter, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, ICloneable<IMessageAdapter>, ICloneable, INotifyPropertyChanged
Constructores
protected MessageAdapter(IdGenerator transactionIdGenerator)
messageAdapter = MessageAdapter(transactionIdGenerator)
Inicializar MessageAdapter.
- transactionIdGenerator
- Generador de identificación de transacciones.
Propiedades
public virtual string[] AssociatedBoards { get; }
value = messageAdapter.AssociatedBoards
El adaptador puede procesar la suscripción sólo con instrumentos asociados con la tabla especificada.
public virtual IEnumerable<Level1Fields> CandlesBuildFrom { get; }
value = messageAdapter.CandlesBuildFrom
Opciones posibles para la construcción de velas.
public virtual MessageAdapterCategories Categories { get; }
value = messageAdapter.Categories
Categorías de adaptador de mensajes.
public virtual bool CheckTimeFrameByRequest { get; }
value = messageAdapter.CheckTimeFrameByRequest
Compruebe el posible plazo por solicitud.
public virtual TimeSpan DisconnectTimeout { get; }
value = messageAdapter.DisconnectTimeout
Consigue el tiempo para esperar una desconexión agraciada.
public virtual bool EnqueueSubscriptions { get; set; }
value = messageAdapter.EnqueueSubscriptions
messageAdapter.EnqueueSubscriptions = value
Suscripciones de alquiler.
public virtual bool ExtraSetup { get; }
value = messageAdapter.ExtraSetup
El adaptador requiere una configuración extra.
public TimeSpan FaultDelay { get; set; }
value = messageAdapter.FaultDelay
messageAdapter.FaultDelay = value
Obtiene o establece el retraso aplicado entre las iteraciones defectuadas.
public virtual string FeatureName { get; }
value = messageAdapter.FeatureName
Nombre de la característica.
public IFileSystem FileSystem { get; set; }
value = messageAdapter.FileSystem
messageAdapter.FileSystem = value
IFileSystem
public virtual bool HeartbeatBeforeConnect { get; }
value = messageAdapter.HeartbeatBeforeConnect
Comience a enviar TimeMessage antes de establecer la conexión.
public TimeSpan HeartbeatInterval { get; set; }
value = messageAdapter.HeartbeatInterval
messageAdapter.HeartbeatInterval = value
Intervalo de comprobación de servidor para rastrear la conexión con vida. El valor es Zero apagado el seguimiento.
public virtual bool IsAutoReplyOnTransactonalUnsubscription { get; }
value = messageAdapter.IsAutoReplyOnTransactonalUnsubscription
Enviar respuesta automática para OrderStatusMessage y PortfolioLookupMessageunsubscribes.
public virtual bool IsFullCandlesOnly { get; }
value = messageAdapter.IsFullCandlesOnly
Traduce CandleMessage como solamente completamente llenado.
public virtual bool IsNativeIdentifiers { get; }
value = messageAdapter.IsNativeIdentifiers
Identificar el instrumento financiero en mensajes por identificador nativo Nativo.
public virtual bool IsNativeIdentifiersPersistable { get; }
value = messageAdapter.IsNativeIdentifiersPersistable
Se puede almacenar identificador nativo.
public virtual bool? IsPositionsEmulationRequired { get; }
value = messageAdapter.IsPositionsEmulationRequired
Adaptador necesario emulación PositionChangeMessage.
public virtual bool IsReplaceCommandEditCurrent { get; }
value = messageAdapter.IsReplaceCommandEditCurrent
Es el comando OrderReplaceMessage edita un orden actual.
public virtual bool IsSecurityNewsOnly { get; }
value = messageAdapter.IsSecurityNewsOnly
Adaptador proporciona noticias relacionadas con un instrumento financiero especificado.
public virtual bool IsSupportExecutionsPnL { get; }
value = messageAdapter.IsSupportExecutionsPnL
Adaptador llena PnL.
public virtual bool IsSupportOrderBookIncrements { get; }
value = messageAdapter.IsSupportOrderBookIncrements
Adaptador traduce libros de orden incremental.
public virtual bool IsSupportSubscriptions { get; }
value = messageAdapter.IsSupportSubscriptions
Soporta cualquier suscripción (ticks, libros de pedidos, etc.).
public virtual bool IsSupportTransactionLog { get; }
value = messageAdapter.IsSupportTransactionLog
Adaptador traduce los cambios de pedidos en respuesta de OrderStatusMessage.
public virtual TimeSpan IterationInterval { get; set; }
value = messageAdapter.IterationInterval
messageAdapter.IterationInterval = value
Intervalo entre iteraciones.
public virtual TimeSpan? LookupTimeout { get; }
value = messageAdapter.LookupTimeout
Cuidado con el tiempo.
public int MaxParallelMessages { get; set; }
value = messageAdapter.MaxParallelMessages
messageAdapter.MaxParallelMessages = value
Obtiene o establece el número máximo de mensajes paralelos (no control) que pueden ser procesados. Debe ser mayor o igual a 1.
public override string Name { get; set; }
value = messageAdapter.Name
messageAdapter.Name = value
Nombre.
public virtual IEnumerable<MessageTypes> NotSupportedResultMessages { get; set; }
value = messageAdapter.NotSupportedResultMessages
messageAdapter.NotSupportedResultMessages = value
No soportado por los tipos de mensaje de resultado de adaptador.
public virtual Type OrderConditionType { get; }
value = messageAdapter.OrderConditionType
Tipo de OrderCondition@.
public Platforms Platform { get; protected set; }
value = messageAdapter.Platform
messageAdapter.Platform = value
Proceso de bits, que puede ejecutar el adaptador.
public virtual IEnumerable<MessageTypeInfo> PossibleSupportedMessages { get; set; }
value = messageAdapter.PossibleSupportedMessages
messageAdapter.PossibleSupportedMessages = value
Posibles tipos de mensajes apoyados.
public ReConnectionSettings ReConnectionSettings { get; }
value = messageAdapter.ReConnectionSettings
Ajustes de seguimiento de conexión IMessageAdapter con un servidor.
public virtual IEnumerable<ValueTuple<string, Type>> SecurityExtendedFields { get; }
value = messageAdapter.SecurityExtendedFields
Nombres de los campos de instrumentos financieros ampliados en SecurityMessage.
public virtual string StorageName { get; }
value = messageAdapter.StorageName
Nombre de almacenamiento.
public virtual IEnumerable<MessageTypes> SupportedInMessages { get; set; }
value = messageAdapter.SupportedInMessages
messageAdapter.SupportedInMessages = value
Soportado por tipos de mensaje de adaptador.
internal IEnumerable<DataType> SupportedMarketDataTypes { get; set; }
value = messageAdapter.SupportedMarketDataTypes
messageAdapter.SupportedMarketDataTypes = value
public virtual IEnumerable<int> SupportedOrderBookDepths { get; }
value = messageAdapter.SupportedOrderBookDepths
Opciones disponibles para MaxDepth.
public IdGenerator TransactionIdGenerator { get; set; }
value = messageAdapter.TransactionIdGenerator
messageAdapter.TransactionIdGenerator = value
Generador de id de transacción utilizado para la routa interna de suscripción de niños. Debe mantenerse en sincronía con el generador del adaptador padre.
public virtual bool UseInChannel { get; }
value = messageAdapter.UseInChannel
Utilice canales para mensajes.
public virtual bool UseOutChannel { get; }
value = messageAdapter.UseOutChannel
Usar canales para mensajes fuera.
Métodos
protected virtual ValueTask BoardLookupAsync(BoardLookupMessage lookupMsg, CancellationToken cancellationToken)
result = messageAdapter.BoardLookupAsync(lookupMsg, cancellationToken)
protected virtual ValueTask CancelOrderAsync(OrderCancelMessage cancelMsg, CancellationToken cancellationToken)
result = messageAdapter.CancelOrderAsync(cancelMsg, cancellationToken)
protected virtual ValueTask CancelOrderGroupAsync(OrderGroupCancelMessage cancelMsg, CancellationToken cancellationToken)
result = messageAdapter.CancelOrderGroupAsync(cancelMsg, cancellationToken)
protected virtual ValueTask ChangePasswordAsync(ChangePasswordMessage pwdMsg, CancellationToken cancellationToken)
result = messageAdapter.ChangePasswordAsync(pwdMsg, cancellationToken)
public virtual IMessageAdapter Clone()
result = messageAdapter.Clone()
Crear una copia de MessageAdapter.
Devuelve: Copiado.
protected virtual ValueTask ConnectAsync(ConnectMessage connectMsg, CancellationToken cancellationToken)
result = messageAdapter.ConnectAsync(connectMsg, cancellationToken)
public virtual IOrderLogMarketDepthBuilder CreateOrderLogMarketDepthBuilder(SecurityId securityId)
result = messageAdapter.CreateOrderLogMarketDepthBuilder(securityId)
Crear un constructor de profundidad de mercado.
- securityId
- identificación de instrumentos financieros.
Devuelve: Ordene registro a la construcción de profundidad de mercado.
protected virtual ValueTask DisconnectAsync(DisconnectMessage disconnectMsg, CancellationToken cancellationToken)
result = messageAdapter.DisconnectAsync(disconnectMsg, cancellationToken)
public virtual IAsyncEnumerable<DataType> GetSupportedMarketDataTypesAsync(SecurityId securityId, DateTime? from, DateTime? to)
result = messageAdapter.GetSupportedMarketDataTypesAsync(securityId, from, to)
Consiga soporte por tipos de mensaje de adaptador.
- securityId
- SecurityId
- from
- Fecha de inicio para solicitar. Si , entonces todos los mensajes disponibles serán devueltos.
- to
- Fecha final para solicitar. Si , entonces todos los mensajes disponibles serán devueltos.
Devuelve: Apoyado por tipos de datos del mercado de adaptadores.
private void InitMessageLocalTime(Message message)
messageAdapter.InitMessageLocalTime(message)
Inicializar el mensaje de horario local.
- message
- Mensaje.
public virtual bool IsAllDownloadingSupported(DataType dataType)
result = messageAdapter.IsAllDownloadingSupported(dataType)
Es para los instrumentos financieros especificados que se descargan habilitados.
- dataType
- Datos tipo info.
Devuelve: Resultado de la comprobación.
public virtual bool IsSecurityRequired(DataType dataType)
result = messageAdapter.IsSecurityRequired(dataType)
Suscripciones de filtrado de soporte (subscribe/sin suscripción para un instrumento financiero especificado).
- dataType
- Datos tipo info.
Devuelve: Resultado de la comprobación.
public virtual bool IsSupportCandlesPriceLevels(MarketDataMessage subscription)
result = messageAdapter.IsSupportCandlesPriceLevels(subscription)
Soporta velas PriceLevels.
- subscription
- MarketDataMessage@
Devuelve: Resultado de la comprobación.
public virtual bool IsSupportCandlesUpdates(MarketDataMessage subscription)
result = messageAdapter.IsSupportCandlesUpdates(subscription)
Soporta la suscripción de velas y actualizaciones en vivo.
- subscription
- MarketDataMessage@
Devuelve: Resultado de la comprobación.
public override void Load(SettingsStorage storage)
messageAdapter.Load(storage)
Ajustes de carga.
- storage
- Configuración de almacenamiento.
protected virtual ValueTask MarketDataAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = messageAdapter.MarketDataAsync(mdMsg, cancellationToken)
protected virtual ValueTask OnCandlesSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = messageAdapter.OnCandlesSubscriptionAsync(mdMsg, cancellationToken)
Solicitud de suscripción de manijas para datos de velas. Sobrescribir para proporcionar la implementación para el procesamiento de la suscripción de velas. La implementación predeterminada lanza NotSupported.
- mdMsg
- Mensaje de suscripción de datos de mercado.
- cancellationToken
- Cancelación de token para cancelar la operación.
Devuelve: A ValueTask@ representante de la operación asincrónica.
protected virtual ValueTask OnLevel1SubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = messageAdapter.OnLevel1SubscriptionAsync(mdMsg, cancellationToken)
Solicitud de suscripción de fichas para datos de nivel 1. Sobrescribir para proporcionar la implementación para el procesamiento de suscripción de nivel1. La implementación predeterminada lanza NotSupported.
- mdMsg
- Mensaje de suscripción de datos de mercado.
- cancellationToken
- Cancelación de token para cancelar la operación.
Devuelve: A ValueTask@ representante de la operación asincrónica.
protected virtual ValueTask OnMarketDepthSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = messageAdapter.OnMarketDepthSubscriptionAsync(mdMsg, cancellationToken)
Solicitud de suscripción de mangos para datos de profundidad de mercado. Sobrescribir para proporcionar la implementación para el procesamiento de suscripción a profundidad de mercado. La implementación predeterminada lanza NotSupported.
- mdMsg
- Mensaje de suscripción de datos de mercado.
- cancellationToken
- Cancelación de token para cancelar la operación.
Devuelve: A ValueTask@ representante de la operación asincrónica.
protected virtual ValueTask OnNewsSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = messageAdapter.OnNewsSubscriptionAsync(mdMsg, cancellationToken)
Solicitud de suscripción de mangos para los datos de noticias. Sobrescribir para proporcionar la implementación para el procesamiento de la suscripción de noticias. La implementación predeterminada lanza NotSupported.
- mdMsg
- Mensaje de suscripción de datos de mercado.
- cancellationToken
- Cancelación de token para cancelar la operación.
Devuelve: A ValueTask@ representante de la operación asincrónica.
protected virtual ValueTask OnOrderLogSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = messageAdapter.OnOrderLogSubscriptionAsync(mdMsg, cancellationToken)
Solicitud de suscripción de mangos para datos de registro de pedidos (trades/transacciones). Sobrescribir para proporcionar implementación para procesamiento de suscripción de registro de pedidos. La implementación predeterminada lanza NotSupported.
- mdMsg
- Mensaje de suscripción de datos de mercado.
- cancellationToken
- Cancelación de token para cancelar la operación.
Devuelve: A ValueTask@ representante de la operación asincrónica.
protected void OnPropertyChanged(string propertyName)
messageAdapter.OnPropertyChanged(propertyName)
Raise PropertyChanged event.
- propertyName
- El nombre de la propiedad que cambió.
protected virtual ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = messageAdapter.OnSendInMessageAsync(message, cancellationToken)
Envíe el manejador de mensajes.
- message
- Mensaje
- cancellationToken
- CancellationToken
Devuelve: ValueTask
protected virtual ValueTask OnTFCandlesSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = messageAdapter.OnTFCandlesSubscriptionAsync(mdMsg, cancellationToken)
Solicitud de suscripción de manijas para los datos de velas de marco de tiempo ( velas de FT). Sobrescribir para proporcionar aplicación para el procesamiento de suscripción de velas TF. La implementación predeterminada lanza NotSupported.
- mdMsg
- Mensaje de suscripción de datos de mercado.
- cancellationToken
- Cancelación de token para cancelar la operación.
Devuelve: A ValueTask@ representante de la operación asincrónica.
protected virtual ValueTask OnTicksSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = messageAdapter.OnTicksSubscriptionAsync(mdMsg, cancellationToken)
Solicitud de suscripción de mangos para datos de garrapatas. Sobrescribir para proporcionar la implementación para el procesamiento de la suscripción de garrapatas. La implementación predeterminada lanza NotSupported.
- mdMsg
- Mensaje de suscripción de datos de mercado.
- cancellationToken
- Cancelación de token para cancelar la operación.
Devuelve: A ValueTask@ representante de la operación asincrónica.
protected virtual ValueTask OrderStatusAsync(OrderStatusMessage statusMsg, CancellationToken cancellationToken)
result = messageAdapter.OrderStatusAsync(statusMsg, cancellationToken)
protected virtual ValueTask PortfolioLookupAsync(PortfolioLookupMessage lookupMsg, CancellationToken cancellationToken)
result = messageAdapter.PortfolioLookupAsync(lookupMsg, cancellationToken)
protected virtual ValueTask RegisterOrderAsync(OrderRegisterMessage regMsg, CancellationToken cancellationToken)
result = messageAdapter.RegisterOrderAsync(regMsg, cancellationToken)
protected virtual ValueTask ReplaceOrderAsync(OrderReplaceMessage replaceMsg, CancellationToken cancellationToken)
result = messageAdapter.ReplaceOrderAsync(replaceMsg, cancellationToken)
protected virtual ValueTask ResetAsync(ResetMessage resetMsg, CancellationToken cancellationToken)
result = messageAdapter.ResetAsync(resetMsg, cancellationToken)
public override void Save(SettingsStorage storage)
messageAdapter.Save(storage)
Guardar configuración.
- storage
- Configuración de almacenamiento.
protected virtual ValueTask SecurityLookupAsync(SecurityLookupMessage lookupMsg, CancellationToken cancellationToken)
result = messageAdapter.SecurityLookupAsync(lookupMsg, cancellationToken)
public virtual ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)
result = messageAdapter.SendInMessageAsync(message, cancellationToken)
Procesa un mensaje genérico asincrónicamente.
- message
- El mensaje para procesar.
- cancellationToken
- CancellationToken
protected ValueTask SendOutConnectionStateAsync(ConnectionStates state, CancellationToken cancellationToken)
result = messageAdapter.SendOutConnectionStateAsync(state, cancellationToken)
Enviar a CancellationToken@) mensaje de conexión.
- state
- ConnectionStates
- cancellationToken
- Cancelación token.
protected ValueTask SendOutDisconnectMessageAsync(bool expected, CancellationToken cancellationToken)
result = messageAdapter.SendOutDisconnectMessageAsync(expected, cancellationToken)
Enviar a CancellationToken@) mensaje de desconexión.
- expected
- Está desconectado.
- cancellationToken
- Cancelación token.
protected ValueTask SendOutDisconnectMessageAsync(Exception error, CancellationToken cancellationToken)
result = messageAdapter.SendOutDisconnectMessageAsync(error, cancellationToken)
Enviar a CancellationToken@) mensaje de desconexión.
- error
- Información de error. Puede ser .
- cancellationToken
- Cancelación token.
protected ValueTask SendOutErrorAsync(string description, CancellationToken cancellationToken)
result = messageAdapter.SendOutErrorAsync(description, cancellationToken)
Inicia un nuevo mensaje ErrorMessage y pasalo al método CancellationToken.
- description
- Detalles del error.
- cancellationToken
- Cancelación token.
protected ValueTask SendOutErrorAsync(Exception error, CancellationToken cancellationToken)
result = messageAdapter.SendOutErrorAsync(error, cancellationToken)
Inicia un nuevo mensaje ErrorMessage y pasalo al método CancellationToken.
- error
- Detalles del error.
- cancellationToken
- Cancelación token.
public virtual ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = messageAdapter.SendOutMessageAsync(message, cancellationToken)
Enviar mensaje saliente (cambio de estado, orden, etc.).
- message
- Mensaje.
- cancellationToken
- CancellationToken
protected ValueTask SendSubscriptionFinishedAsync(long originalTransactionId, CancellationToken cancellationToken, DateTime? nextFrom)
result = messageAdapter.SendSubscriptionFinishedAsync(originalTransactionId, cancellationToken, nextFrom)
Inicia un nuevo mensaje SubscriptionFinishedMessage y pasalo al método CancellationToken.
- originalTransactionId
- ID del mensaje original para el cual este mensaje es una respuesta.
- cancellationToken
- Cancelación token.
- nextFrom
- NextFrom.
protected ValueTask SendSubscriptionNotSupportedAsync(long originalTransactionId, CancellationToken cancellationToken)
result = messageAdapter.SendSubscriptionNotSupportedAsync(originalTransactionId, cancellationToken)
Inicia un nuevo mensaje SubscriptionResponseMessage y pasalo al método CancellationToken.
- originalTransactionId
- ID del mensaje original para el cual este mensaje es una respuesta.
- cancellationToken
- Cancelación token.
protected ValueTask SendSubscriptionOnlineAsync(long originalTransactionId, CancellationToken cancellationToken)
result = messageAdapter.SendSubscriptionOnlineAsync(originalTransactionId, cancellationToken)
Inicia un nuevo mensaje SubscriptionOnlineMessage y pasalo al método CancellationToken.
- originalTransactionId
- ID del mensaje original para el cual este mensaje es una respuesta.
- cancellationToken
- Cancelación token.
protected ValueTask SendSubscriptionReplyAsync(long originalTransactionId, CancellationToken cancellationToken, Exception error)
result = messageAdapter.SendSubscriptionReplyAsync(originalTransactionId, cancellationToken, error)
Inicia un nuevo mensaje SubscriptionResponseMessage y pasalo al método CancellationToken.
- originalTransactionId
- ID del mensaje original para el cual este mensaje es una respuesta.
- cancellationToken
- Cancelación token.
- error
- Suscribir o describir información de error. Para ser establecido si la respuesta.
protected ValueTask SendSubscriptionResultAsync(ISubscriptionMessage message, CancellationToken cancellationToken)
result = messageAdapter.SendSubscriptionResultAsync(message, cancellationToken)
Inicia un nuevo mensaje SubscriptionOnlineMessage o SubscriptionFinishedMessage y pasalo al método CancellationToken.
- message
- Suscripción.
- cancellationToken
- Cancelación token.
protected virtual ValueTask TimeAsync(TimeMessage timeMsg, CancellationToken cancellationToken)
result = messageAdapter.TimeAsync(timeMsg, cancellationToken)
protected virtual bool ValidateSecurityId(SecurityId secId)
result = messageAdapter.ValidateSecurityId(secId)
Validar el id de instrumento financiero especificado es compatible con el adaptador y la suscripción se puede hacer.
- secId
- SecurityId.
Devuelve: Resultado de la comprobación.
Eventos
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
messageAdapter.NewOutMessageAsync += handler
Nuevo evento de mensaje.