RithmicMessageAdapter
Адаптер сообщений для протокола Rithmic (protobuf/WebSocket).
Наследует: MessageAdapter
Конструкторы
public RithmicMessageAdapter(IdGenerator transactionIdGenerator)
rithmicMessageAdapter = RithmicMessageAdapter(transactionIdGenerator)
Инициализирует новый экземпляр RithmicMessageAdapter.
- transactionIdGenerator
- Генератор идентификаторов транзакций.
Свойства
public SecureString Password { get; set; }
value = rithmicMessageAdapter.Password
rithmicMessageAdapter.Password = value
Пароль пользователя.
public string ServerAddress { get; set; }
value = rithmicMessageAdapter.ServerAddress
rithmicMessageAdapter.ServerAddress = value
Адрес сервера (wss://...).
public string SystemName { get; set; }
value = rithmicMessageAdapter.SystemName
rithmicMessageAdapter.SystemName = value
Имя ритмической системы.
public string UserName { get; set; }
value = rithmicMessageAdapter.UserName
rithmicMessageAdapter.UserName = value
Логин пользователя.
Методы
protected override ValueTask CancelOrderAsync(OrderCancelMessage cancelMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.CancelOrderAsync(cancelMsg, cancellationToken)
protected override ValueTask ConnectAsync(ConnectMessage connectMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.ConnectAsync(connectMsg, cancellationToken)
protected override ValueTask DisconnectAsync(DisconnectMessage msg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.DisconnectAsync(msg, cancellationToken)
public override bool IsAllDownloadingSupported(DataType dataType)
result = rithmicMessageAdapter.IsAllDownloadingSupported(dataType)
Включена ли для указанного загрузка всех финансовых инструментов.
- dataType
- Информация о типе данных.
Возвращает: Проверьте результат.
public override void Load(SettingsStorage storage)
rithmicMessageAdapter.Load(storage)
Загрузить настройки.
- storage
- Хранилище настроек.
protected override ValueTask OnLevel1SubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.OnLevel1SubscriptionAsync(mdMsg, cancellationToken)
Обрабатывает запрос на подписку для данных уровня 1. Переопределить, чтобы обеспечить реализацию обработки подписки уровня 1. Реализация по умолчанию выдает NotSupported.
- mdMsg
- Сообщение о подписке на рыночные данные.
- cancellationToken
- Токен отмены для отмены операции.
Возвращает: ValueTask, представляющий асинхронную операцию.
protected override ValueTask OnMarketDepthSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.OnMarketDepthSubscriptionAsync(mdMsg, cancellationToken)
Обрабатывает запрос на подписку на данные о глубине рынка. Переопределить, чтобы обеспечить реализацию обработки подписки на глубину рынка. Реализация по умолчанию выдает NotSupported.
- mdMsg
- Сообщение о подписке на рыночные данные.
- cancellationToken
- Токен отмены для отмены операции.
Возвращает: ValueTask, представляющий асинхронную операцию.
protected override ValueTask OnTicksSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.OnTicksSubscriptionAsync(mdMsg, cancellationToken)
Обрабатывает запрос подписки на данные тиков. Переопределить, чтобы обеспечить реализацию обработки подписки на тики. Реализация по умолчанию выдает NotSupported.
- mdMsg
- Сообщение о подписке на рыночные данные.
- cancellationToken
- Токен отмены для отмены операции.
Возвращает: ValueTask, представляющий асинхронную операцию.
protected override ValueTask OrderStatusAsync(OrderStatusMessage statusMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.OrderStatusAsync(statusMsg, cancellationToken)
protected override ValueTask PortfolioLookupAsync(PortfolioLookupMessage lookupMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.PortfolioLookupAsync(lookupMsg, cancellationToken)
protected override ValueTask RegisterOrderAsync(OrderRegisterMessage regMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.RegisterOrderAsync(regMsg, cancellationToken)
protected override ValueTask ReplaceOrderAsync(OrderReplaceMessage replaceMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.ReplaceOrderAsync(replaceMsg, cancellationToken)
protected override ValueTask ResetAsync(ResetMessage msg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.ResetAsync(msg, cancellationToken)
public override void Save(SettingsStorage storage)
rithmicMessageAdapter.Save(storage)
Сохраните настройки.
- storage
- Хранилище настроек.
protected override ValueTask SecurityLookupAsync(SecurityLookupMessage lookupMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.SecurityLookupAsync(lookupMsg, cancellationToken)
protected override ValueTask TimeAsync(TimeMessage timeMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.TimeAsync(timeMsg, cancellationToken)
public override string ToString()
result = rithmicMessageAdapter.ToString()
Преобразовать к строковому представлению.
Возвращает: Строковое представление.