Connector
La clase para crear conexiones con los sistemas de comercio.
Hereda de: BaseLogReceiver
Implementa: IConnector, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, IMarketDataProvider, ITransactionProvider, ISecurityProvider, ISecurityMessageProvider, ISubscriptionProvider, ITimeProvider, IPortfolioProvider, IPositionProvider
Constructores
public Connector(ISecurityStorage securityStorage, IPositionStorage positionStorage, IExchangeInfoProvider exchangeInfoProvider, IStorageRegistry storageRegistry, ISnapshotRegistry snapshotRegistry, IStorageBuffer buffer, bool initAdapter, bool initChannels)
connector = Connector(securityStorage, positionStorage, exchangeInfoProvider, storageRegistry, snapshotRegistry, buffer, initAdapter, initChannels)
Inicia una nueva instancia de la Connector.
- securityStorage
- instrumentos financieros meta almacenamiento de información.
- positionStorage
- Almacenamiento de posición.
- exchangeInfoProvider
- Intercambios y proveedores de juntas comerciales.
- storageRegistry
- El almacenamiento de datos del mercado.
- snapshotRegistry
- Registro de almacenamiento de instantáneas.
- buffer
- Buffer de almacenamiento.
- initAdapter
- Inicializar el adaptador de cesta.
- initChannels
- Inicia los canales.
Propiedades
public BasketMessageAdapter Adapter { get; protected set; }
value = connector.Adapter
connector.Adapter = value
Adaptador de mensajes.
public IBasketSecurityProcessorProvider BasketSecurityProcessorProvider { get; set; }
value = connector.BasketSecurityProcessorProvider
connector.BasketSecurityProcessorProvider = value
Proveedor de procesadores de instrumentos financieros de la cesta.
public Subscription BoardLookup { get; }
value = connector.BoardLookup
Obtener la suscripción global en ExchangeBoardnovedad. Puede ser .
public bool CanConnect { get; }
value = connector.CanConnect
Determina este connector@ está listo para establecer la conexión.
public bool CheckSteps { get; set; }
value = connector.CheckSteps
connector.CheckSteps = value
Compruebe Precio y volumen se multiplican a paso.
public ICommissionManager CommissionManager { get; set; }
value = connector.CommissionManager
connector.CommissionManager = value
La comisión calculando el gerente.
public ConnectionStates ConnectionState { get; private set; }
value = connector.ConnectionState
connector.ConnectionState = value
Estado de conexión.
public Subscription DataTypeLookup { get; }
value = connector.DataTypeLookup
Obtener la suscripción global en DataTypeInfoMessagenovedad. Puede ser .
public int ErrorCount { get; private set; }
value = connector.ErrorCount
connector.ErrorCount = value
El número de errores pasó a través del evento Error.
public IEnumerable<ExchangeBoard> ExchangeBoards { get; }
value = connector.ExchangeBoards
La lista de tablas de stock.
public IExchangeInfoProvider ExchangeInfoProvider { get; }
value = connector.ExchangeInfoProvider
Intercambios y proveedores de juntas comerciales.
public IMessageChannel InMessageChannel { get; protected set; }
value = connector.InMessageChannel
connector.InMessageChannel = value
Canal de mensaje de entrada.
public IMessageAdapterWrapper InnerAdapter { get; set; }
value = connector.InnerAdapter
connector.InnerAdapter = value
Adaptador interno de mensajes.
public bool IsAutoUnSubscribeOnDisconnect { get; set; }
value = connector.IsAutoUnSubscribeOnDisconnect
connector.IsAutoUnSubscribeOnDisconnect = value
Enviar unsubscribe al comando de desconexión.
public bool IsRestoreSubscriptionOnNormalReconnect { get; set; }
value = connector.IsRestoreSubscriptionOnNormalReconnect
connector.IsRestoreSubscriptionOnNormalReconnect = value
Restaurar la suscripción en la reconexión.
public ILatencyManager LatencyManager { get; set; }
value = connector.LatencyManager
connector.LatencyManager = value
Ordena el administrador de cálculo de demoras de registro.
public ISet<MessageTypes> LookupMessagesOnConnect { get; }
value = connector.LookupMessagesOnConnect
public IMessageAdapter MarketDataAdapter { get; private set; }
value = connector.MarketDataAdapter
connector.MarketDataAdapter = value
Adaptador de datos de mercado.
public virtual TimeSpan MarketTimeChangedInterval { get; set; }
value = connector.MarketTimeChangedInterval
connector.MarketTimeChangedInterval = value
El mensaje TimeMessage generando Interval. El valor predeterminado es de 10 milisegundos.
public Subscription OrderLookup { get; }
value = connector.OrderLookup
Obtener suscripción global en la búsqueda de la orden. Puede ser .
public int OrdersKeepCount { get; set; }
value = connector.OrdersKeepCount
connector.OrdersKeepCount = value
El número de pedidos de almacenamiento. El valor predeterminado es 1000. Si el valor se establece a MaxValue, entonces los pedidos no serán eliminados. Si el valor se establece a 0, entonces los pedidos no serán almacenados.
public IMessageChannel OutMessageChannel { get; protected set; }
value = connector.OutMessageChannel
connector.OutMessageChannel = value
Canal de mensaje saliente.
public bool OverrideSecurityData { get; set; }
value = connector.OverrideSecurityData
connector.OverrideSecurityData = value
Superar los datos anteriores de instrumentos financieros por nuevos valores.
public IPnLManager PnLManager { get; set; }
value = connector.PnLManager
connector.PnLManager = value
El gerente de pérdidas de ganancias.
public Subscription PortfolioLookup { get; }
value = connector.PortfolioLookup
Consigue suscripción global en Portfolio Lookup. Puede ser .
public virtual IEnumerable<Portfolio> Portfolios { get; }
value = connector.Portfolios
La lista de carteras.
public IEnumerable<Position> Positions { get; }
value = connector.Positions
La lista de posiciones.
public IPositionStorage PositionStorage { get; }
value = connector.PositionStorage
Almacenamiento de posición.
public virtual IRiskManager RiskManager { get; set; }
value = connector.RiskManager
connector.RiskManager = value
Gerente de control de riesgos.
public IEnumerable<Security> Securities { get; }
value = connector.Securities
La lista de instrumentos.
public SecurityIdGenerator SecurityIdGenerator { get; set; }
value = connector.SecurityIdGenerator
connector.SecurityIdGenerator = value
El generador de identificadores de instrumentos Id.
public Subscription SecurityLookup { get; }
value = connector.SecurityLookup
Obtener suscripción global en la búsqueda de instrumentos financieros. Puede ser .
public ISecurityStorage SecurityStorage { get; }
value = connector.SecurityStorage
instrumentos financieros meta almacenamiento de información.
public ISlippageManager SlippageManager { get; set; }
value = connector.SlippageManager
connector.SlippageManager = value
Gerente de deslizamiento.
public ISnapshotRegistry SnapshotRegistry { get; private set; }
value = connector.SnapshotRegistry
connector.SnapshotRegistry = value
Registro de almacenamiento de instantáneas.
public StorageMetaInfoMessageAdapter StorageAdapter { get; private set; }
value = connector.StorageAdapter
connector.StorageAdapter = value
Adaptador de almacenamiento.
public IStorageRegistry StorageRegistry { get; }
value = connector.StorageRegistry
El almacenamiento de datos del mercado.
public IEnumerable<Subscription> Subscriptions { get; }
value = connector.Subscriptions
La lista de suscripciones.
public ISet<Subscription> SubscriptionsOnConnect { get; }
value = connector.SubscriptionsOnConnect
Envía suscripciones en conexión.
public bool SupportAssociatedSecurity { get; set; }
value = connector.SupportAssociatedSecurity
connector.SupportAssociatedSecurity = value
Utilice AssociatedSecurityAdapter@.
public bool SupportBasketSecurities { get; set; }
value = connector.SupportBasketSecurities
connector.SupportBasketSecurities = value
Utilice BasketSecurityMessageAdapter@.
public bool SupportFilteredMarketDepth { get; set; }
value = connector.SupportFilteredMarketDepth
connector.SupportFilteredMarketDepth = value
Utilice FilteredMarketDepthAdapter@.
public bool SupportLevel1DepthBuilder { get; set; }
value = connector.SupportLevel1DepthBuilder
connector.SupportLevel1DepthBuilder = value
Utilice Level1DepthBuilderAdapter@.
public virtual bool SupportSnapshots { get; set; }
value = connector.SupportSnapshots
connector.SupportSnapshots = value
Utilice SnapshotHolderMessageAdapter@.
public bool TimeChange { get; set; }
value = connector.TimeChange
connector.TimeChange = value
Incremento periódicamente MarketTimeChangedIntervalvalor @CurrentTime.
public IMessageAdapter TransactionAdapter { get; private set; }
value = connector.TransactionAdapter
connector.TransactionAdapter = value
Adaptador transacional.
public IdGenerator TransactionIdGenerator { get; set; }
value = connector.TransactionIdGenerator
connector.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 UnsubscribeOnDisconnect { get; }
value = connector.UnsubscribeOnDisconnect
Envía su suscripción a desconectar.
public bool UpdatePortfolioByChange { get; set; }
value = connector.UpdatePortfolioByChange
connector.UpdatePortfolioByChange = value
Para actualizar los campos de Portfolio cuando aparece el mensaje PositionChangeMessage. Por defecto está habilitado.
public bool UpdateSecurityByDefinition { get; set; }
value = connector.UpdateSecurityByDefinition
connector.UpdateSecurityByDefinition = value
Para actualizar los campos de instrumentos financieros cuando aparezca el mensaje SecurityMessage. Por defecto está habilitado.
public bool UpdateSecurityByLevel1 { get; set; }
value = connector.UpdateSecurityByLevel1
connector.UpdateSecurityByLevel1 = value
Para actualizar los campos de instrumentos financieros cuando aparezca el mensaje Level1ChangeMessage. Por defecto está habilitado.
public bool UpdateSecurityLastQuotes { get; set; }
value = connector.UpdateSecurityLastQuotes
connector.UpdateSecurityLastQuotes = value
Para actualizar LastTick, BestBid, BestAsk en cada actualización de libro de pedidos y/o oficios. Por defecto está habilitado.
Métodos
public void CancelOrder(Order order)
connector.CancelOrder(order)
Cancela la orden.
- order
- El pedido que debe ser cancelado.
public ValueTask CancelOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.CancelOrderAsync(order, cancellationToken)
Cancela el pedido sincronía.
- order
- Orden de cancelar.
- cancellationToken
- CancellationToken
public void CancelOrders(bool? isStopOrder, Portfolio portfolio, Sides? direction, ExchangeBoard board, Security security, SecurityTypes? securityType, long? transactionId)
connector.CancelOrders(isStopOrder, portfolio, direction, board, security, securityType, transactionId)
Cancela órdenes por filtro.
- isStopOrder
- Si cancelas solo una orden de parada, si ordenes regulares, ambas.
- portfolio
- Portafolio. Si el valor es igual a , entonces la cartera no coincide con los pedidos de cancelación de filtro.
- direction
- Orden lado. Si el valor es , la dirección no utiliza.
- board
- Tabla de tracción. Si el valor es igual a , entonces la junta no coincide con los pedidos de cancelación de filtro.
- security
- Instrumento. Si el valor es igual a , entonces el instrumento no coincide con los pedidos de cancelación de filtro.
- securityType
- tipo de instrumento financiero. Si el valor es , el tipo no utiliza.
- transactionId
- Operaciones de cancelación de pedidos id.
public ValueTask CancelOrdersAsync(bool? isStopOrder, Portfolio portfolio, Sides? direction, ExchangeBoard board, Security security, SecurityTypes? securityType, long? transactionId, CancellationToken cancellationToken)
result = connector.CancelOrdersAsync(isStopOrder, portfolio, direction, board, security, securityType, transactionId, cancellationToken)
Cancela órdenes por filtro asincrónicamente.
- isStopOrder
- Si cancelas solo una orden de parada, si ordenes regulares, ambas.
- portfolio
- Portafolio. Si el valor es igual a , entonces la cartera no coincide con los pedidos de cancelación de filtro.
- direction
- Orden lado. Si el valor es , la dirección no utiliza.
- board
- Tabla de tracción. Si el valor es igual a , entonces la junta no coincide con los pedidos de cancelación de filtro.
- security
- Instrumento. Si el valor es igual a , entonces el instrumento no coincide con los pedidos de cancelación de filtro.
- securityType
- tipo de instrumento financiero. Si el valor es , el tipo no utiliza.
- transactionId
- Operaciones de cancelación de pedidos id.
- cancellationToken
- CancellationToken
public ValueTask ChangePasswordAsync(SecureString newPassword, CancellationToken cancellationToken)
result = connector.ChangePasswordAsync(newPassword, cancellationToken)
Cambiar contraseña.
- newPassword
- Nueva contraseña.
- cancellationToken
- CancellationToken
public virtual ValueTask ClearCacheAsync(CancellationToken cancellationToken)
result = connector.ClearCacheAsync(cancellationToken)
Un caché claro.
protected string CreateSecurityId(string secCode, string boardCode)
result = connector.CreateSecurityId(secCode, boardCode)
Generar instrumento financiero Id.
- secCode
- SecurityCode.
- boardCode
- BoardCode.
Devuelve: Instrumento financiero de Id.
protected override void DisposeManaged()
connector.DisposeManaged()
Liberar recursos asignados, en particular, para desconectar del sistema comercial a través de la desconexión.
public void EditOrder(Order order, Order changes)
connector.EditOrder(order, changes)
Edita la orden.
- order
- Orden.
- changes
- Cambios en el orden.
public ValueTask EditOrderAsync(Order order, Order changes, CancellationToken cancellationToken)
result = connector.EditOrderAsync(order, changes, cancellationToken)
Edita el orden de forma asincrónica.
- order
- Orden de editar.
- changes
- Orden de cambiar con nuevos valores.
- cancellationToken
- CancellationToken
public IEnumerable<Level1Fields> GetLevel1Fields(Security security)
result = connector.GetLevel1Fields(security)
Para obtener un conjunto de campos disponibles Level1Fields, para los cuales hay un mercado de datos para el instrumento.
- security
- instrumento financiero.
Devuelve: Posibles campos.
public Portfolio GetPortfolio(string name)
result = connector.GetPortfolio(name)
Para obtener la cartera por el nombre de código.
- name
- Nombre del código de cartera.
Devuelve: El portafolio obtenido. Si no hay cartera por criterios dados, se devuelve.
public Position GetPosition(Portfolio portfolio, Security security, string strategyId, Sides? side, string clientCode, string depoName, TPlusLimits? limitType)
result = connector.GetPosition(portfolio, security, strategyId, side, clientCode, depoName, limitType)
Para conseguir la posición por cartera e instrumento.
- portfolio
- La cartera en la que se debe encontrar la posición.
- security
- El instrumento sobre el que debe encontrarse la posición.
- strategyId
- ID de estrategia.
- side
- El lado.
- clientCode
- El código del cliente.
- depoName
- El nombre depositario donde se encuentra el stock físicamente. Por defecto, se pasa una cadena vacía, lo que significa la posición total por todos los depósitos.
- limitType
- Limit type for Т+ market.
Devuelve: Posición.
public Security GetSecurity(SecurityId securityId)
result = connector.GetSecurity(securityId)
Consigue un instrumento financiero por identificador.
- securityId
- identificación de instrumentos financieros.
Devuelve: instrumento financiero.
private ValueTask<Security> GetSecurityAsync(SecurityId id, Func<Security, bool> changeSecurity, CancellationToken cancellationToken)
result = connector.GetSecurityAsync(id, changeSecurity, cancellationToken)
Para conseguir el instrumento por el código.
- id
- identificación de instrumentos financieros.
- changeSecurity
- El manipulador cambia el instrumento. Regresa si el instrumento ha sido cambiado y se debe llamar a SecurityReceived@.
- cancellationToken
- CancellationToken
Devuelve: instrumento financiero.
public ValueTask<Security> GetSecurityAsync(SecurityId securityId, CancellationToken cancellationToken)
result = connector.GetSecurityAsync(securityId, cancellationToken)
Consigue un instrumento financiero por identificador.
- securityId
- identificación de instrumentos financieros.
- cancellationToken
- CancellationToken
Devuelve: instrumento financiero.
public SecurityId GetSecurityId(Security security)
result = connector.GetSecurityId(security)
Consigue SecurityId.
- security
- instrumento financiero.
Devuelve: identificación de instrumentos financieros.
public object GetSecurityValue(Security security, Level1Fields field)
result = connector.GetSecurityValue(security, field)
Para obtener el valor de los datos de mercado para el instrumento.
- security
- instrumento financiero.
- field
- Campo de datos de mercado.
Devuelve: El valor de campo. Si no hay datos, el será devuelto.
private ValueTask InitNewOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.InitNewOrderAsync(order, cancellationToken)
Inicializar orden de registro (transacción id, etc.).
- order
- Nuevo orden.
- cancellationToken
- CancellationToken
public bool? IsOrderEditable(Order order)
result = connector.IsOrderEditable(order)
Determina la orden especificada puede ser editada por Orden).
- order
- Orden.
Devuelve: si el pedido es editable, el orden no puede ser cambiado, significa que no hay información.
public bool? IsOrderReplaceable(Order order)
result = connector.IsOrderReplaceable(order)
Determina la orden especificada puede ser reemplazada por Orden).
- order
- Orden.
Devuelve: si el pedido es reemplazable, el orden no puede ser reemplazado, significa que no hay información.
public override void Load(SettingsStorage storage)
connector.Load(storage)
Ajustes de carga.
- storage
- Configuración de almacenamiento.
public ValueTask<Security> LookupByIdAsync(SecurityId id, CancellationToken cancellationToken)
result = connector.LookupByIdAsync(id, cancellationToken)
Para conseguir el instrumento por el identificador.
- id
- identificación de instrumentos financieros.
- cancellationToken
- CancellationToken
Devuelve: El instrumento obtenido. Si no hay instrumento por criterios dados, se devuelve.
public Portfolio LookupByPortfolioName(string name)
result = connector.LookupByPortfolioName(name)
Para obtener la cartera por el nombre de código.
- name
- Nombre del código de cartera.
Devuelve: El portafolio obtenido. Si no hay cartera por criterios dados, se devuelve.
protected ValueTask OnCancelOrderAsync(Order order, long transactionId, CancellationToken cancellationToken)
result = connector.OnCancelOrderAsync(order, transactionId, cancellationToken)
Cancela la orden.
- order
- Orden de cancelar.
- transactionId
- Operaciones de cancelación de pedidos id.
- cancellationToken
- CancellationToken
protected ValueTask OnCancelOrdersAsync(long transactionId, CancellationToken cancellationToken, bool? isStopOrder, Portfolio portfolio, Sides? direction, ExchangeBoard board, Security security, SecurityTypes? securityType)
result = connector.OnCancelOrdersAsync(transactionId, cancellationToken, isStopOrder, portfolio, direction, board, security, securityType)
Cancela órdenes por filtro.
- transactionId
- Operaciones de cancelación de pedidos id.
- cancellationToken
- Cancelación token.
- isStopOrder
- Si cancelas solo una orden de parada, si ordenes regulares, ambas.
- portfolio
- Portafolio. Si el valor es igual a , entonces la cartera no coincide con los pedidos de cancelación de filtro.
- direction
- Orden lado. Si el valor es , la dirección no utiliza.
- board
- Tabla de tracción. Si el valor es igual a , entonces la junta no coincide con los pedidos de cancelación de filtro.
- security
- Instrumento. Si el valor es igual a , entonces el instrumento no coincide con los pedidos de cancelación de filtro.
- securityType
- tipo de instrumento financiero. Si el valor es , el tipo no utiliza.
protected virtual ValueTask OnConnectAsync(CancellationToken cancellationToken)
result = connector.OnConnectAsync(cancellationToken)
Conectar al sistema de comercio.
protected virtual ValueTask OnDisconnectAsync(CancellationToken cancellationToken)
result = connector.OnDisconnectAsync(cancellationToken)
Desconectarse del sistema comercial.
protected ValueTask OnEditOrderAsync(Order order, Order changes, CancellationToken cancellationToken)
result = connector.OnEditOrderAsync(order, changes, cancellationToken)
Edita la orden.
- order
- Orden.
- changes
- Cambios en el orden.
- cancellationToken
- CancellationToken
protected virtual ValueTask OnProcessMessage(Message message, CancellationToken cancellationToken)
result = connector.OnProcessMessage(message, cancellationToken)
Mensaje de proceso.
- message
- Mensaje.
- cancellationToken
- CancellationToken
protected ValueTask OnRegisterOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.OnRegisterOrderAsync(order, cancellationToken)
Registre nuevo orden.
- order
- Detalles de registro.
- cancellationToken
- CancellationToken
protected ValueTask OnReRegisterOrderAsync(Order oldOrder, Order newOrder, CancellationToken cancellationToken)
result = connector.OnReRegisterOrderAsync(oldOrder, newOrder, cancellationToken)
Reinscribir la orden.
- oldOrder
- Orden de cancelación.
- newOrder
- Nuevo orden de registro.
- cancellationToken
- CancellationToken
private void RaiseConnected()
connector.RaiseConnected()
Para llamar al evento Conectado.
private void RaiseConnectedEx(IMessageAdapter adapter)
connector.RaiseConnectedEx(adapter)
Para llamar al evento ConnectedEx.
- adapter
- Adaptador, evento iniciado.
private void RaiseConnectionError(Exception exception)
connector.RaiseConnectionError(exception)
Para llamar al evento ConnectionError.
- exception
- Conexión de error.
private void RaiseConnectionErrorEx(IMessageAdapter adapter, Exception exception)
connector.RaiseConnectionErrorEx(adapter, exception)
Para llamar al evento ConnectionErrorEx.
- adapter
- Adaptador, evento iniciado.
- exception
- Conexión de error.
private void RaiseCurrentTimeChanged(TimeSpan diff)
connector.RaiseCurrentTimeChanged(diff)
Para llamar al evento CurrentTimeChanged.
- diff
- La diferencia en el tiempo desde la última llamada del evento. La primera vez que el evento pasa el valor Cero.
private void RaiseDisconnected()
connector.RaiseDisconnected()
Para llamar al evento desconectado.
private void RaiseDisconnectedEx(IMessageAdapter adapter)
connector.RaiseDisconnectedEx(adapter)
Para llamar al evento DisconnectedEx.
- adapter
- Adaptador, evento iniciado.
protected void RaiseError(Exception exception)
connector.RaiseError(exception)
Para llamar al error del evento.
- exception
- Error de procesamiento de datos.
private void RaiseLookupPortfoliosResult(PortfolioLookupMessage message, Exception error, Portfolio[] newPortfolios)
connector.RaiseLookupPortfoliosResult(message, error, newPortfolios)
Para llamar al evento LookupPortfoliosResult.
- message
- Mensaje.
- error
- Un error de operación de búsqueda. El valor será si la operación completa con éxito.
- newPortfolios
- Encontré carteras.
private void RaiseLookupSecuritiesResult(SecurityLookupMessage message, Exception error, Security[] newSecurities)
connector.RaiseLookupSecuritiesResult(message, error, newSecurities)
Para llamar al evento LookupSecuritiesResult.
- message
- Mensaje.
- error
- Un error de operación de búsqueda. El valor será si la operación completa con éxito.
- newSecurities
- Encontramos instrumentos.
protected virtual void RaiseSubscriptionFailed(Subscription subscription, Exception error, bool isSubscribe)
connector.RaiseSubscriptionFailed(subscription, error, isSubscribe)
public void RegisterOrder(Order order)
connector.RegisterOrder(order)
Registre nuevo orden.
- order
- Detalles de registro.
public ValueTask RegisterOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.RegisterOrderAsync(order, cancellationToken)
Registrar un nuevo orden asincrónicamente.
- order
- Detalles de registro.
- cancellationToken
- CancellationToken
public void ReRegisterOrder(Order oldOrder, Order newOrder)
connector.ReRegisterOrder(oldOrder, newOrder)
Reinscribir la orden.
- oldOrder
- Orden de cancelación.
- newOrder
- Nuevo orden de registro.
public ValueTask ReRegisterOrderAsync(Order oldOrder, Order newOrder, CancellationToken cancellationToken)
result = connector.ReRegisterOrderAsync(oldOrder, newOrder, cancellationToken)
Reinscribir el orden de manera asincrónica.
- oldOrder
- Orden de cancelación.
- newOrder
- Nuevo orden de registro.
- cancellationToken
- CancellationToken
public override void Save(SettingsStorage storage)
connector.Save(storage)
Guardar configuración.
- storage
- Configuración de almacenamiento.
public void SendInMessage(Message message)
connector.SendInMessage(message)
Enviar un mensaje desde el módulo servidor a clientes conectados.
public ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)
result = connector.SendInMessageAsync(message, cancellationToken)
Procesa un mensaje genérico asincrónicamente.
- message
- El mensaje para procesar.
- cancellationToken
- CancellationToken
public void SendOutError(Exception error)
connector.SendOutError(error)
Envía mensaje de error.
- error
- Detalles del error.
public ValueTask SendOutErrorAsync(Exception error, CancellationToken cancellationToken)
result = connector.SendOutErrorAsync(error, cancellationToken)
Envía mensaje de error.
- error
- Detalles del error.
- cancellationToken
- CancellationToken
public void SendOutMessage(Message message)
connector.SendOutMessage(message)
Envía un mensaje saliente.
- message
- Mensaje.
public ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = connector.SendOutMessageAsync(message, cancellationToken)
Enviar mensaje saliente (cambio de estado, orden, etc.).
- message
- Mensaje.
- cancellationToken
- CancellationToken
public void Subscribe(Subscription subscription)
connector.Subscribe(subscription)
Suscribete.
- subscription
- Suscripción.
public void UnSubscribe(Subscription subscription)
connector.UnSubscribe(subscription)
Descríbete.
- subscription
- Suscripción.
Eventos
public event Action<Subscription, ExchangeBoard> BoardReceived
connector.BoardReceived += handler
ExchangeBoard recibido.
public event Action<Subscription, ICandleMessage> CandleReceived
connector.CandleReceived += handler
ICandleMessage recibido.
public event Action<long, Exception> ChangePasswordResult
connector.ChangePasswordResult += handler
Cambiar el resultado de contraseña.
public event Action<IMessageAdapter> ConnectedEx
connector.ConnectedEx += handler
Conectado.
public event Action<Exception> ConnectionError
connector.ConnectionError += handler
Error de conexión (por ejemplo, la conexión fue abortada por servidor).
public event Action<IMessageAdapter, Exception> ConnectionErrorEx
connector.ConnectionErrorEx += handler
Error de conexión (por ejemplo, la conexión fue abortada por servidor).
public event Action<IMessageAdapter> ConnectionLost
connector.ConnectionLost += handler
Conexión perdida.
public event Action<IMessageAdapter> ConnectionRestored
connector.ConnectionRestored += handler
Conexión restaurada.
public event Action<TimeSpan> CurrentTimeChanged
connector.CurrentTimeChanged += handler
El tiempo del servidor cambió CurrentTime@. Pasó la diferencia de tiempo desde la última llamada del evento. La primera vez que el evento pasa el valor Zero.
public event Action<Subscription, DataType> DataTypeReceived
connector.DataTypeReceived += handler
DataType recibido.
public event Action<IMessageAdapter> DisconnectedEx
connector.DisconnectedEx += handler
Desconectado.
public event Action<Subscription, Level1ChangeMessage> Level1Received
connector.Level1Received += handler
Level1ChangeMessage recibido.
public event Action<PortfolioLookupMessage, IEnumerable<Portfolio>, Exception> LookupPortfoliosResult
connector.LookupPortfoliosResult += handler
Resultado de la búsqueda PortfolioLookupMessage recibido.
public event Action<PortfolioLookupMessage, IEnumerable<Portfolio>, IEnumerable<Portfolio>, Exception> LookupPortfoliosResult2
connector.LookupPortfoliosResult2 += handler
Resultado de la búsqueda PortfolioLookupMessage recibido.
public event Action<SecurityLookupMessage, IEnumerable<Security>, Exception> LookupSecuritiesResult
connector.LookupSecuritiesResult += handler
Resultado de la búsqueda SecurityLookupMessage recibido.
public event Action<SecurityLookupMessage, IEnumerable<Security>, IEnumerable<Security>, Exception> LookupSecuritiesResult2
connector.LookupSecuritiesResult2 += handler
Resultado de la búsqueda SecurityLookupMessage recibido.
public event Action<long> MassOrderCanceled
connector.MassOrderCanceled += handler
Evento de cancelación de pedidos masivos.
public event Action<long, DateTime> MassOrderCanceled2
connector.MassOrderCanceled2 += handler
Evento de cancelación de pedidos masivos.
public event Action<long, Exception> MassOrderCancelFailed
connector.MassOrderCancelFailed += handler
Evento de cancelación de pedidos masivos.
public event Action<long, Exception, DateTime> MassOrderCancelFailed2
connector.MassOrderCancelFailed2 += handler
Evento de cancelación de pedidos masivos.
public event Action<MyTrade> NewMyTrade
connector.NewMyTrade += handler
El comercio propio recibido.
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
connector.NewOutMessageAsync += handler
Nuevo evento de mensaje.
public event Action<Portfolio> NewPortfolio
connector.NewPortfolio += handler
Se recibió nueva cartera.
public event Action<Position> NewPosition
connector.NewPosition += handler
Nueva posición recibida.
public event Action<Subscription, News> NewsReceived
connector.NewsReceived += handler
Noticias recibidas.
public event Action<Subscription, IOrderBookMessage> OrderBookReceived
connector.OrderBookReceived += handler
IOrderBookMessage recibido.
public event Action<OrderFail> OrderCancelFailed
connector.OrderCancelFailed += handler
Orden de cancelación de error evento.
public event Action<Subscription, OrderFail> OrderCancelFailReceived
connector.OrderCancelFailReceived += handler
OrderFail evento de cancelación.
public event Action<Order> OrderChanged
connector.OrderChanged += handler
Orden cambiado (cancelada, emparejada).
public event Action<long, Order> OrderEdited
connector.OrderEdited += handler
Orden) evento de éxito de resultados.
public event Action<long, OrderFail> OrderEditFailed
connector.OrderEditFailed += handler
Orden) evento de resultado de error.
public event Action<Subscription, OrderFail> OrderEditFailReceived
connector.OrderEditFailReceived += handler
OrderFail@ edición evento.
public event Action<Subscription, IOrderLogMessage> OrderLogReceived
connector.OrderLogReceived += handler
IOrderLogMessage recibido.
public event Action<Subscription, Order> OrderReceived
connector.OrderReceived += handler
Orden recibida.
public event Action<OrderFail> OrderRegisterFailed
connector.OrderRegisterFailed += handler
Orden de registro de errores evento.
public event Action<Subscription, OrderFail> OrderRegisterFailReceived
connector.OrderRegisterFailReceived += handler
OrderFail@s.
public event Action<Subscription, MyTrade> OwnTradeReceived
connector.OwnTradeReceived += handler
MyTrade recibido.
public event Action<Portfolio> PortfolioChanged
connector.PortfolioChanged += handler
Cartero cambió.
public event Action<Subscription, Portfolio> PortfolioReceived
connector.PortfolioReceived += handler
Cartera recibida.
public event Action<Position> PositionChanged
connector.PositionChanged += handler
La posición cambió.
public event Action<Subscription, Position> PositionReceived
connector.PositionReceived += handler
Posición recibida.
public event Action<Subscription, Security> SecurityReceived
connector.SecurityReceived += handler
instrumento financiero recibido.
public event Action<Subscription, Exception, bool> SubscriptionFailed
connector.SubscriptionFailed += handler
La suscripción no está.
public event Action<Subscription> SubscriptionOnline
connector.SubscriptionOnline += handler
La suscripción está en línea.
public event Action<Subscription, object> SubscriptionReceived
connector.SubscriptionReceived += handler
Valor recibido.
public event Action<Subscription> SubscriptionStarted
connector.SubscriptionStarted += handler
La suscripción se inicia.
public event Action<Subscription, Exception> SubscriptionStopped
connector.SubscriptionStopped += handler
La suscripción se detiene.
public event Action<Subscription, ITickTradeMessage> TickTradeReceived
connector.TickTradeReceived += handler
ITickTradeMessage recibido.
public event Action<Security, IEnumerable<KeyValuePair<Level1Fields, object>>, DateTime, DateTime> ValuesChanged
connector.ValuesChanged += handler
cambio de instrumento financiero.