RithmicMessageAdapter
The message adapter for Rithmic Protocol (protobuf/WebSocket).
Inherits: MessageAdapter
Constructors
public RithmicMessageAdapter(IdGenerator transactionIdGenerator)
rithmicMessageAdapter = RithmicMessageAdapter(transactionIdGenerator)
Initializes a new instance of the RithmicMessageAdapter.
- transactionIdGenerator
- Transaction id generator.
Properties
public SecureString Password { get; set; }
value = rithmicMessageAdapter.Password
rithmicMessageAdapter.Password = value
User password.
public string ServerAddress { get; set; }
value = rithmicMessageAdapter.ServerAddress
rithmicMessageAdapter.ServerAddress = value
Server address (wss://...).
public string SystemName { get; set; }
value = rithmicMessageAdapter.SystemName
rithmicMessageAdapter.SystemName = value
Rithmic system name.
public string UserName { get; set; }
value = rithmicMessageAdapter.UserName
rithmicMessageAdapter.UserName = value
User login.
Methods
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)
Is for the specified all securities downloading enabled.
- dataType
- Data type info.
Returns: Check result.
public override void Load(SettingsStorage storage)
rithmicMessageAdapter.Load(storage)
Load settings.
- storage
- Settings storage.
protected override ValueTask OnLevel1SubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.OnLevel1SubscriptionAsync(mdMsg, cancellationToken)
Handles subscription request for level1 data. Override to provide implementation for level1 subscription processing. The default implementation throws NotSupported.
- mdMsg
- Market data subscription message.
- cancellationToken
- Cancellation token to cancel the operation.
Returns: A ValueTask representing the asynchronous operation.
protected override ValueTask OnMarketDepthSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.OnMarketDepthSubscriptionAsync(mdMsg, cancellationToken)
Handles subscription request for market depth data. Override to provide implementation for market depth subscription processing. The default implementation throws NotSupported.
- mdMsg
- Market data subscription message.
- cancellationToken
- Cancellation token to cancel the operation.
Returns: A ValueTask representing the asynchronous operation.
protected override ValueTask OnTicksSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.OnTicksSubscriptionAsync(mdMsg, cancellationToken)
Handles subscription request for ticks data. Override to provide implementation for ticks subscription processing. The default implementation throws NotSupported.
- mdMsg
- Market data subscription message.
- cancellationToken
- Cancellation token to cancel the operation.
Returns: A ValueTask representing the asynchronous operation.
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)
Save settings.
- storage
- Settings 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()
Преобразовать к строковому представлению.
Returns: Строковое представление.