MessageAdapterWrapper
Базовая реализация IMessageAdapterWrapper.
Наследует: Cloneable<IMessageAdapter>
Реализует: IMessageAdapterWrapper, IMessageAdapter, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, ICloneable<IMessageAdapter>, ICloneable
Конструкторы
protected MessageAdapterWrapper(IMessageAdapter innerAdapter)
messageAdapterWrapper = MessageAdapterWrapper(innerAdapter)
Инициализируйте MessageAdapterWrapper.
- innerAdapter
- Базовый адаптер.
Свойства
public IEnumerable<Level1Fields> CandlesBuildFrom { get; }
value = messageAdapterWrapper.CandlesBuildFrom
Возможные варианты строительства свечей.
public virtual MessageAdapterCategories Categories { get; }
value = messageAdapterWrapper.Categories
Категории адаптеров сообщений.
public bool CheckTimeFrameByRequest { get; }
value = messageAdapterWrapper.CheckTimeFrameByRequest
Проверьте возможные сроки по запросу.
public DateTime CurrentTime { get; }
value = messageAdapterWrapper.CurrentTime
Текущее время UTC.
public TimeSpan HeartbeatInterval { get; set; }
value = messageAdapterWrapper.HeartbeatInterval
messageAdapterWrapper.HeartbeatInterval = value
Проверочный интервал сервера для отслеживания соединения живым. Значение Zero выключено отслеживанием.
public IMessageAdapter InnerAdapter { get; set; }
value = messageAdapterWrapper.InnerAdapter
messageAdapterWrapper.InnerAdapter = value
Базовый адаптер.
public virtual bool IsFullCandlesOnly { get; }
value = messageAdapterWrapper.IsFullCandlesOnly
Перевод CandleMessage как полностью заполненный.
public virtual bool IsNativeIdentifiers { get; }
value = messageAdapterWrapper.IsNativeIdentifiers
Идентифицировать финансовый инструмент в сообщениях по нативному идентификатору Native.
public virtual bool IsNativeIdentifiersPersistable { get; }
value = messageAdapterWrapper.IsNativeIdentifiersPersistable
Нативный идентификатор может быть сохранен.
public virtual bool? IsPositionsEmulationRequired { get; }
value = messageAdapterWrapper.IsPositionsEmulationRequired
Адаптер требовал эмуляции PositionChangeMessage.
public virtual bool IsSecurityNewsOnly { get; }
value = messageAdapterWrapper.IsSecurityNewsOnly
Адаптер предоставляет новости, связанные с определенным финансовым инструментом.
public virtual bool IsSupportExecutionsPnL { get; }
value = messageAdapterWrapper.IsSupportExecutionsPnL
Адаптер заполняет PnL.
public virtual bool IsSupportOrderBookIncrements { get; }
value = messageAdapterWrapper.IsSupportOrderBookIncrements
Адаптер переводит книги с дополнительными заказами.
public virtual bool IsSupportSubscriptions { get; }
value = messageAdapterWrapper.IsSupportSubscriptions
Поддерживать любые подписки (тиксы, книги заказов и т.д.).
public virtual bool IsSupportTransactionLog { get; }
value = messageAdapterWrapper.IsSupportTransactionLog
Адаптер переводит изменения заказов на ответ OrderStatusMessage.
public virtual IEnumerable<MessageTypes> NotSupportedResultMessages { get; }
value = messageAdapterWrapper.NotSupportedResultMessages
Не поддерживается адаптерными типами сообщений результатов.
public bool OwnInnerAdapter { get; set; }
value = messageAdapterWrapper.OwnInnerAdapter
messageAdapterWrapper.OwnInnerAdapter = value
Контроль InnerAdapter life.
public virtual ILogSource Parent { get; set; }
value = messageAdapterWrapper.Parent
messageAdapterWrapper.Parent = value
Родитель.
public virtual IEnumerable<MessageTypeInfo> PossibleSupportedMessages { get; }
value = messageAdapterWrapper.PossibleSupportedMessages
Возможные типы поддерживаемых сообщений.
public ReConnectionSettings ReConnectionSettings { get; }
value = messageAdapterWrapper.ReConnectionSettings
Настройки отслеживания соединения IMessageAdapter с сервером.
protected virtual bool SendInBackFurther { get; }
value = messageAdapterWrapper.SendInBackFurther
Автоотправляйте сообщения BackMode на InnerAdapter.
public string StorageName { get; }
value = messageAdapterWrapper.StorageName
Имя хранилища.
public virtual IEnumerable<MessageTypes> SupportedInMessages { get; set; }
value = messageAdapterWrapper.SupportedInMessages
messageAdapterWrapper.SupportedInMessages = value
Поддерживается типами сообщений адаптера.
public virtual IEnumerable<int> SupportedOrderBookDepths { get; }
value = messageAdapterWrapper.SupportedOrderBookDepths
Доступные варианты для MaxDepth.
public IdGenerator TransactionIdGenerator { get; }
value = messageAdapterWrapper.TransactionIdGenerator
Генератор идентификаторов транзакций, используемый для внутренней маршрутизации подписки на ребенка, должен быть синхронизирован с генератором родительского адаптера.
Методы
public virtual void Dispose()
messageAdapterWrapper.Dispose()
Удаляет элементы в пуле, реализующие IDisposable.
public virtual IAsyncEnumerable<DataType> GetSupportedMarketDataTypesAsync(SecurityId securityId, DateTime? from, DateTime? to)
result = messageAdapterWrapper.GetSupportedMarketDataTypesAsync(securityId, from, to)
Получите поддержку от типов сообщений адаптера.
- securityId
- SecurityId
- from
- Дата начала запроса. Если , то будут возвращены все доступные сообщения.
- to
- Дата окончания запроса. Если , то будут возвращены все доступные сообщения.
Возвращает: Поддерживается типами рыночных данных адаптера.
protected virtual ValueTask InnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = messageAdapterWrapper.InnerAdapterNewOutMessageAsync(message, cancellationToken)
Обработать выходное сообщение InnerAdapter.
- message
- Сообщение.
- cancellationToken
- Токен отмены.
public virtual bool IsAllDownloadingSupported(DataType dataType)
result = messageAdapterWrapper.IsAllDownloadingSupported(dataType)
Включена ли для указанного загрузка всех финансовых инструментов.
- dataType
- Информация о типе данных.
Возвращает: Проверьте результат.
public virtual bool IsSecurityRequired(DataType dataType)
result = messageAdapterWrapper.IsSecurityRequired(dataType)
Поддержка фильтрации подписок (подписка/отмена подписки на определенный финансовый инструмент).
- dataType
- Информация о типе данных.
Возвращает: Проверьте результат.
public virtual bool IsSupportCandlesPriceLevels(MarketDataMessage subscription)
result = messageAdapterWrapper.IsSupportCandlesPriceLevels(subscription)
Свечи поддержки PriceLevels.
- subscription
- MarketDataMessage
Возвращает: Проверьте результат.
public virtual bool IsSupportCandlesUpdates(MarketDataMessage subscription)
result = messageAdapterWrapper.IsSupportCandlesUpdates(subscription)
Поддержка подписки на свечи и живых обновлений.
- subscription
- MarketDataMessage
Возвращает: Проверьте результат.
public virtual void Load(SettingsStorage storage)
messageAdapterWrapper.Load(storage)
Загрузить настройки.
- storage
- Хранилище настроек.
public void LogDebug(string message, object[] args)
messageAdapterWrapper.LogDebug(message, args)
public void LogError(string message, object[] args)
messageAdapterWrapper.LogError(message, args)
public void LogInfo(string message, object[] args)
messageAdapterWrapper.LogInfo(message, args)
public void LogVerbose(string message, object[] args)
messageAdapterWrapper.LogVerbose(message, args)
public void LogWarning(string message, object[] args)
messageAdapterWrapper.LogWarning(message, args)
protected virtual ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = messageAdapterWrapper.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)
Обработать выходное сообщение InnerAdapter.
- message
- Сообщение.
- cancellationToken
- Токен отмены.
protected virtual ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = messageAdapterWrapper.OnSendInMessageAsync(message, cancellationToken)
Отправить сообщение.
- message
- Сообщение.
- cancellationToken
- CancellationToken
protected ValueTask RaiseNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = messageAdapterWrapper.RaiseNewOutMessageAsync(message, cancellationToken)
Чтобы вызвать событие NewOutMessageAsync.
- message
- Сообщение.
- cancellationToken
- Токен отмены.
public virtual void Save(SettingsStorage storage)
messageAdapterWrapper.Save(storage)
Сохраните настройки.
- storage
- Хранилище настроек.
public virtual ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)
result = messageAdapterWrapper.SendInMessageAsync(message, cancellationToken)
Обрабатывает общее сообщение асинхронно.
- message
- Сообщение для обработки.
- cancellationToken
- CancellationToken
public override string ToString()
result = messageAdapterWrapper.ToString()
Преобразовать к строковому представлению.
Возвращает: Строковое представление.
События
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
messageAdapterWrapper.NewOutMessageAsync += handler
Новое событие сообщения.
public event Action<ILogSource> ParentRemoved
messageAdapterWrapper.ParentRemoved += handler