Connector

StockSharp.Algo

与交易系统建立联系的阶级.

继承自: BaseLogReceiver

实现: IConnector, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, IMarketDataProvider, ITransactionProvider, ISecurityProvider, ISecurityMessageProvider, ISubscriptionProvider, ITimeProvider, IPortfolioProvider, IPositionProvider

构造函数

Connector
public Connector()
connector = Connector()

初始化了 & ##Connector+#的新实例.

Connector
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)

初始化了 & ##Connector+#的新实例.

securityStorage
金融工具元信息存储。
positionStorage
位置存储 。
exchangeInfoProvider
交易所和交易委员会供应商。
storageRegistry
市场数据的存储.
snapshotRegistry
即时shot存储注册.
buffer
存储缓冲器.
initAdapter
初始化篮子适配器.
initChannels
初始化频道.

属性

Adapter
public BasketMessageAdapter Adapter { get; protected set; }
value = connector.Adapter
connector.Adapter = value

消息适应器.

BasketSecurityProcessorProvider
public IBasketSecurityProcessorProvider BasketSecurityProcessorProvider { get; set; }
value = connector.BasketSecurityProcessorProvider
connector.BasketSecurityProcessorProvider = value

篮子金融工具处理商供应商.

BoardLookup
public Subscription BoardLookup { get; }
value = connector.BoardLookup

获取全球订阅的 ExchangeBoard 搜索。 有可能 。

Buffer
public IStorageBuffer Buffer { get; }
value = connector.Buffer

存储缓冲器.

CanConnect
public bool CanConnect { get; }
value = connector.CanConnect

确定此 connector 已准备好建立连接 。

CheckSteps
public bool CheckSteps { get; set; }
value = connector.CheckSteps
connector.CheckSteps = value

检查价格和量 它们是相乘而上。

CommissionManager
public ICommissionManager CommissionManager { get; set; }
value = connector.CommissionManager
connector.CommissionManager = value

佣金计算经理。

ConnectionState
public ConnectionStates ConnectionState { get; private set; }
value = connector.ConnectionState
connector.ConnectionState = value

连接状态 。

DataTypeLookup
public Subscription DataTypeLookup { get; }
value = connector.DataTypeLookup

获取全球订阅的 DataTypeInfoMessage 搜索。 有可能 。

ErrorCount
public int ErrorCount { get; private set; }
value = connector.ErrorCount
connector.ErrorCount = value

错误事件传递到的出错次数 。

ExchangeBoards
public IEnumerable<ExchangeBoard> ExchangeBoards { get; }
value = connector.ExchangeBoards

股票董事会名单.

ExchangeInfoProvider
public IExchangeInfoProvider ExchangeInfoProvider { get; }
value = connector.ExchangeInfoProvider

交易所和交易委员会供应商。

InMessageChannel
public IMessageChannel InMessageChannel { get; protected set; }
value = connector.InMessageChannel
connector.InMessageChannel = value

输入消息频道.

InnerAdapter
public IMessageAdapterWrapper InnerAdapter { get; set; }
value = connector.InnerAdapter
connector.InnerAdapter = value

内相信息适配器.

IsAutoUnSubscribeOnDisconnect
public bool IsAutoUnSubscribeOnDisconnect { get; set; }
value = connector.IsAutoUnSubscribeOnDisconnect
connector.IsAutoUnSubscribeOnDisconnect = value

解开断开命令时发送未订阅的 。

IsRestoreSubscriptionOnNormalReconnect
public bool IsRestoreSubscriptionOnNormalReconnect { get; set; }
value = connector.IsRestoreSubscriptionOnNormalReconnect
connector.IsRestoreSubscriptionOnNormalReconnect = value

重新连接时恢复订阅 。

LatencyManager
public ILatencyManager LatencyManager { get; set; }
value = connector.LatencyManager
connector.LatencyManager = value

命令注册延迟计算管理器.

LookupMessagesOnConnect
public ISet<MessageTypes> LookupMessagesOnConnect { get; }
value = connector.LookupMessagesOnConnect
MarketDataAdapter
public IMessageAdapter MarketDataAdapter { get; private set; }
value = connector.MarketDataAdapter
connector.MarketDataAdapter = value

市场数据适配器.

MarketTimeChangedInterval
public virtual TimeSpan MarketTimeChangedInterval { get; set; }
value = connector.MarketTimeChangedInterval
connector.MarketTimeChangedInterval = value

TimeMessage 消息生成Interval。 默认为 10 毫秒 。

OrderLookup
public Subscription OrderLookup { get; }
value = connector.OrderLookup

获取全球订阅的秩序查询。 可能是 。

OrdersKeepCount
public int OrdersKeepCount { get; set; }
value = connector.OrdersKeepCount
connector.OrdersKeepCount = value

存储命令数。 默认为 1000。 如果将值设定为 MaxValue, 则命令将不会被删除。 如果将值设定为 0, 则命令将不会被保存 。

OutMessageChannel
public IMessageChannel OutMessageChannel { get; protected set; }
value = connector.OutMessageChannel
connector.OutMessageChannel = value

正在发送消息频道 。

OverrideSecurityData
public bool OverrideSecurityData { get; set; }
value = connector.OverrideSecurityData
connector.OverrideSecurityData = value

以新值取代先前的金融工具数据。

PnLManager
public IPnLManager PnLManager { get; set; }
value = connector.PnLManager
connector.PnLManager = value

损益经理.

PortfolioLookup
public Subscription PortfolioLookup { get; }
value = connector.PortfolioLookup

获取全球订阅的组合搜索。 可能吧 。

Portfolios
public virtual IEnumerable<Portfolio> Portfolios { get; }
value = connector.Portfolios

组合列表.

Positions
public IEnumerable<Position> Positions { get; }
value = connector.Positions

职位列表.

PositionStorage
public IPositionStorage PositionStorage { get; }
value = connector.PositionStorage

位置存储 。

RiskManager
public virtual IRiskManager RiskManager { get; set; }
value = connector.RiskManager
connector.RiskManager = value

风险控制经理

Securities
public IEnumerable<Security> Securities { get; }
value = connector.Securities

乐器列表.

SecurityIdGenerator
public SecurityIdGenerator SecurityIdGenerator { get; set; }
value = connector.SecurityIdGenerator
connector.SecurityIdGenerator = value

仪器识别器生成器 Id.

SecurityLookup
public Subscription SecurityLookup { get; }
value = connector.SecurityLookup

获取全球订阅的金融工具搜索。 可能是 。

SecurityStorage
public ISecurityStorage SecurityStorage { get; }
value = connector.SecurityStorage

金融工具元信息存储。

SlippageManager
public ISlippageManager SlippageManager { get; set; }
value = connector.SlippageManager
connector.SlippageManager = value

滑页管理器.

SnapshotRegistry
public ISnapshotRegistry SnapshotRegistry { get; private set; }
value = connector.SnapshotRegistry
connector.SnapshotRegistry = value

即时shot存储注册.

StorageAdapter
public StorageMetaInfoMessageAdapter StorageAdapter { get; private set; }
value = connector.StorageAdapter
connector.StorageAdapter = value

存储适配器.

StorageRegistry
public IStorageRegistry StorageRegistry { get; }
value = connector.StorageRegistry

市场数据的存储.

Subscriptions
public IEnumerable<Subscription> Subscriptions { get; }
value = connector.Subscriptions

订阅列表.

SubscriptionsOnConnect
public ISet<Subscription> SubscriptionsOnConnect { get; }
value = connector.SubscriptionsOnConnect

连接时发送订阅 。

SupportAssociatedSecurity
public bool SupportAssociatedSecurity { get; set; }
value = connector.SupportAssociatedSecurity
connector.SupportAssociatedSecurity = value

Use AssociatedSecurityAdapter.

SupportBasketSecurities
public bool SupportBasketSecurities { get; set; }
value = connector.SupportBasketSecurities
connector.SupportBasketSecurities = value

Use BasketSecurityMessageAdapter.

SupportFilteredMarketDepth
public bool SupportFilteredMarketDepth { get; set; }
value = connector.SupportFilteredMarketDepth
connector.SupportFilteredMarketDepth = value

Use FilteredMarketDepthAdapter.

SupportLevel1DepthBuilder
public bool SupportLevel1DepthBuilder { get; set; }
value = connector.SupportLevel1DepthBuilder
connector.SupportLevel1DepthBuilder = value

Use Level1DepthBuilderAdapter.

SupportSnapshots
public virtual bool SupportSnapshots { get; set; }
value = connector.SupportSnapshots
connector.SupportSnapshots = value

Use SnapshotHolderMessageAdapter.

TimeChange
public bool TimeChange { get; set; }
value = connector.TimeChange
connector.TimeChange = value

定期增加MarketTimeChangedInterval值为CurrentTime。

TransactionAdapter
public IMessageAdapter TransactionAdapter { get; private set; }
value = connector.TransactionAdapter
connector.TransactionAdapter = value

交易适配器.

TransactionIdGenerator
public IdGenerator TransactionIdGenerator { get; set; }
value = connector.TransactionIdGenerator
connector.TransactionIdGenerator = value

用于内部儿童订阅路由的 dication 生成器。 必须与 父适配器 的生成器同步 。

UnsubscribeOnDisconnect
public virtual bool UnsubscribeOnDisconnect { get; }
value = connector.UnsubscribeOnDisconnect

断开时发送未订阅的 。

UpdatePortfolioByChange
public bool UpdatePortfolioByChange { get; set; }
value = connector.UpdatePortfolioByChange
connector.UpdatePortfolioByChange = value

用于在 PositionChangeMessage 消息出现时更新组合字段。 默认情况下启用了 。

UpdateSecurityByDefinition
public bool UpdateSecurityByDefinition { get; set; }
value = connector.UpdateSecurityByDefinition
connector.UpdateSecurityByDefinition = value

用于在 SecurityMessage 消息出现时更新金融工具字段。默认启用了 。

UpdateSecurityByLevel1
public bool UpdateSecurityByLevel1 { get; set; }
value = connector.UpdateSecurityByLevel1
connector.UpdateSecurityByLevel1 = value

用于在 Level1ChangeMessage 消息出现时更新金融工具字段。默认启用了 。

UpdateSecurityLastQuotes
public bool UpdateSecurityLastQuotes { get; set; }
value = connector.UpdateSecurityLastQuotes
connector.UpdateSecurityLastQuotes = value

在每次更新订单簿和/或交易时更新 LastTick 、 BestBid 、 BestAsk 。默认情况下启用了 。

方法

CancelOrder
public void CancelOrder(Order order)
connector.CancelOrder(order)

取消订单 。

order
取消的顺序 。
CancelOrderAsync
public ValueTask CancelOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.CancelOrderAsync(order, cancellationToken)

同步取消订单 。

order
令取而去之.
cancellationToken
CancellationToken
CancelOrders
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)

通过过滤器取消订单 。

isStopOrder
如果只取消停机令 如果正常的 命令 两者
portfolio
组合。 如果值等于 , 那么组合与命令不符 。
direction
排序侧。如果值是 ,则方向不使用 。
board
交易板。 如果值等于 , 则董事会将取消过滤器。
security
仪器。如果值等于 ,那么仪器与命令不符,可以取消过滤器。
securityType
金融工具类型。如果值是 ,则该类型不使用。
transactionId
命令取消交易编号。
CancelOrdersAsync
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)

同步通过过滤取消订单 。

isStopOrder
如果只取消停机令 如果正常的 命令 两者
portfolio
组合。 如果值等于 , 那么组合与命令不符 。
direction
排序侧。如果值是 ,则方向不使用 。
board
交易板。 如果值等于 , 则董事会将取消过滤器。
security
仪器。如果值等于 ,那么仪器与命令不符,可以取消过滤器。
securityType
金融工具类型。如果值是 ,则该类型不使用。
transactionId
命令取消交易编号。
cancellationToken
CancellationToken
ChangePasswordAsync
public ValueTask ChangePasswordAsync(SecureString newPassword, CancellationToken cancellationToken)
result = connector.ChangePasswordAsync(newPassword, cancellationToken)

更改密码 。

newPassword
新的密码 。
cancellationToken
CancellationToken
ClearCacheAsync
public virtual ValueTask ClearCacheAsync(CancellationToken cancellationToken)
result = connector.ClearCacheAsync(cancellationToken)

清除缓存 。

Connect
public void Connect()
connector.Connect()

连接到交易系统.

CreateSecurityId
protected string CreateSecurityId(string secCode, string boardCode)
result = connector.CreateSecurityId(secCode, boardCode)

生成Id金融工具.

secCode
SecurityCode.
boardCode
BoardCode.

返回值: ID 金融工具。

Disconnect
public void Disconnect()
connector.Disconnect()

与交易系统断开联系.

DisposeManaged
protected override void DisposeManaged()
connector.DisposeManaged()

释放分配的资源,尤其是通过Disconnect与交易系统断开联系。

EditOrder
public void EditOrder(Order order, Order changes)
connector.EditOrder(order, changes)

编辑命令。

order
肃静
changes
秩序有变化。
EditOrderAsync
public ValueTask EditOrderAsync(Order order, Order changes, CancellationToken cancellationToken)
result = connector.EditOrderAsync(order, changes, cancellationToken)

同步编辑命令 。

order
顺序编辑.
changes
以新值更改的顺序 。
cancellationToken
CancellationToken
GetLevel1Fields
public IEnumerable<Level1Fields> GetLevel1Fields(Security security)
result = connector.GetLevel1Fields(security)

获取一组可用的字段 第1级字段,该字段有该仪器的市场数据.

security
金融工具。

返回值: 可能的田园.

GetPortfolio
public Portfolio GetPortfolio(string name)
result = connector.GetPortfolio(name)

以代号来获取组合 。

name
组合代码名.

返回值: 获得的组合。 如果没有特定标准设定组合, 则返回 。

GetPosition
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)

以组合和工具获得职位。

portfolio
职位应依据的组合。
security
确定这一立场所依据的文书。
strategyId
战略识别
side
边.
clientCode
客户端代码.
depoName
存储存储的物理名称。 默认情况下, 空字符串会传递, 也就是说所有存储器的总位置 。
limitType
Limit type for Т+ market.

返回值: 位置 准备

GetSecurity
public Security GetSecurity(SecurityId securityId)
result = connector.GetSecurity(securityId)

以识别码方式获取金融工具。

securityId
金融工具标识。

返回值: 金融工具。

GetSecurityAsync
private ValueTask<Security> GetSecurityAsync(SecurityId id, Func<Security, bool> changeSecurity, CancellationToken cancellationToken)
result = connector.GetSecurityAsync(id, changeSecurity, cancellationToken)

以取出仪相通相.

id
金融工具标识。
changeSecurity
更改仪器的处理器。 如果仪器已经更改, 并且 SecurityReceived 应该调用, 它会返回 。
cancellationToken
CancellationToken

返回值: 金融工具。

GetSecurityAsync
public ValueTask<Security> GetSecurityAsync(SecurityId securityId, CancellationToken cancellationToken)
result = connector.GetSecurityAsync(securityId, cancellationToken)

以识别码方式获取金融工具。

securityId
金融工具标识。
cancellationToken
CancellationToken

返回值: 金融工具。

GetSecurityId
public SecurityId GetSecurityId(Security security)
result = connector.GetSecurityId(security)

Get SecurityId.

security
金融工具。

返回值: 金融工具标识。

GetSecurityValue
public object GetSecurityValue(Security security, Level1Fields field)
result = connector.GetSecurityValue(security, field)

以获得该仪器的市场数据值.

security
金融工具。
field
市场数据领域.

返回值: 字段值。 如果没有数据, 将返回 。

InitNewOrderAsync
private ValueTask InitNewOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.InitNewOrderAsync(order, cancellationToken)

初始化注册顺序( Transaction id等) 。

order
新秩序 上场吧
cancellationToken
CancellationToken
IsOrderEditable
public bool? IsOrderEditable(Order order)
result = connector.IsOrderEditable(order)

确定指定的顺序,可以按命令编辑。

order
肃静

返回值: 如果命令可以编辑,则命令不能被更改,意味着没有信息。

IsOrderReplaceable
public bool? IsOrderReplaceable(Order order)
result = connector.IsOrderReplaceable(order)

确定指定的顺序,可以被命令所取代。

order
肃静

返回值: 如果命令可以替换,则命令不能被替换,意味着没有信息。

Load
public override void Load(SettingsStorage storage)
connector.Load(storage)

装入设置 。

storage
设置存储 。
LookupByIdAsync
public ValueTask<Security> LookupByIdAsync(SecurityId id, CancellationToken cancellationToken)
result = connector.LookupByIdAsync(id, cancellationToken)

以能辨识取出器.

id
金融工具标识。
cancellationToken
CancellationToken

返回值: 获得的乐器。 如果没有特定标准, 则返回 。

LookupByPortfolioName
public Portfolio LookupByPortfolioName(string name)
result = connector.LookupByPortfolioName(name)

以代号来获取组合 。

name
组合代码名.

返回值: 获得的组合。 如果没有特定标准设定组合, 则返回 。

OnCancelOrderAsync
protected ValueTask OnCancelOrderAsync(Order order, long transactionId, CancellationToken cancellationToken)
result = connector.OnCancelOrderAsync(order, transactionId, cancellationToken)

取消订单 。

order
令取而去之.
transactionId
命令取消交易编号。
cancellationToken
CancellationToken
OnCancelOrdersAsync
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)

通过过滤器取消订单 。

transactionId
命令取消交易编号。
cancellationToken
取消的代币。
isStopOrder
如果只取消停机令 如果正常的 命令 两者
portfolio
组合。 如果值等于 , 那么组合与命令不符 。
direction
排序侧。如果值是 ,则方向不使用 。
board
交易板。 如果值等于 , 则董事会将取消过滤器。
security
仪器。如果值等于 ,那么仪器与命令不符,可以取消过滤器。
securityType
金融工具类型。如果值是 ,则该类型不使用。
OnConnectAsync
protected virtual ValueTask OnConnectAsync(CancellationToken cancellationToken)
result = connector.OnConnectAsync(cancellationToken)

连接到交易系统.

OnDisconnectAsync
protected virtual ValueTask OnDisconnectAsync(CancellationToken cancellationToken)
result = connector.OnDisconnectAsync(cancellationToken)

与交易系统断开联系.

OnEditOrderAsync
protected ValueTask OnEditOrderAsync(Order order, Order changes, CancellationToken cancellationToken)
result = connector.OnEditOrderAsync(order, changes, cancellationToken)

编辑命令。

order
肃静
changes
秩序有变化。
cancellationToken
CancellationToken
OnProcessMessage
protected virtual ValueTask OnProcessMessage(Message message, CancellationToken cancellationToken)
result = connector.OnProcessMessage(message, cancellationToken)

进程消息 。

message
传言.
cancellationToken
CancellationToken
OnRegisterOrderAsync
protected ValueTask OnRegisterOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.OnRegisterOrderAsync(order, cancellationToken)

登记新秩序。

order
登记细节。
cancellationToken
CancellationToken
OnReRegisterOrderAsync
protected ValueTask OnReRegisterOrderAsync(Order oldOrder, Order newOrder, CancellationToken cancellationToken)
result = connector.OnReRegisterOrderAsync(oldOrder, newOrder, cancellationToken)

重订令.

oldOrder
取消订单 。
newOrder
新订入册.
cancellationToken
CancellationToken
RaiseConnected
private void RaiseConnected()
connector.RaiseConnected()

呼叫连接事件。

RaiseConnectedEx
private void RaiseConnectedEx(IMessageAdapter adapter)
connector.RaiseConnectedEx(adapter)

To call the event ConnectedEx.

adapter
适配器,启动活动.
RaiseConnectionError
private void RaiseConnectionError(Exception exception)
connector.RaiseConnectionError(exception)

To call the event ConnectionError.

exception
错误连接 。
RaiseConnectionErrorEx
private void RaiseConnectionErrorEx(IMessageAdapter adapter, Exception exception)
connector.RaiseConnectionErrorEx(adapter, exception)

To call the event ConnectionErrorEx.

adapter
适配器,启动活动.
exception
错误连接 。
RaiseCurrentTimeChanged
private void RaiseCurrentTimeChanged(TimeSpan diff)
connector.RaiseCurrentTimeChanged(diff)

To call the event CurrentTimeChanged.

diff
自事件最后一次呼叫以来的时间差异,事件第一次通过零值.
RaiseDisconnected
private void RaiseDisconnected()
connector.RaiseDisconnected()

呼叫事件断开连接 。

RaiseDisconnectedEx
private void RaiseDisconnectedEx(IMessageAdapter adapter)
connector.RaiseDisconnectedEx(adapter)

To call the event DisconnectedEx.

adapter
适配器,启动活动.
RaiseError
protected void RaiseError(Exception exception)
connector.RaiseError(exception)

调用事件错误 。

exception
数据处理出错.
RaiseLookupPortfoliosResult
private void RaiseLookupPortfoliosResult(PortfolioLookupMessage message, Exception error, Portfolio[] newPortfolios)
connector.RaiseLookupPortfoliosResult(message, error, newPortfolios)

将活动称为LookupPortfoliosResult。

message
传言.
error
查找操作出错。 如果操作成功, 值将变为 。
newPortfolios
找到投资组合了。
RaiseLookupSecuritiesResult
private void RaiseLookupSecuritiesResult(SecurityLookupMessage message, Exception error, Security[] newSecurities)
connector.RaiseLookupSecuritiesResult(message, error, newSecurities)

将活动称为LookupSecuritiesResult。

message
传言.
error
查找操作出错。 如果操作成功, 值将变为 。
newSecurities
找到乐器了
RaiseSubscriptionFailed
protected virtual void RaiseSubscriptionFailed(Subscription subscription, Exception error, bool isSubscribe)
connector.RaiseSubscriptionFailed(subscription, error, isSubscribe)
RegisterOrder
public void RegisterOrder(Order order)
connector.RegisterOrder(order)

登记新秩序。

order
登记细节。
RegisterOrderAsync
public ValueTask RegisterOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.RegisterOrderAsync(order, cancellationToken)

同步登记新顺序 。

order
登记细节。
cancellationToken
CancellationToken
ReRegisterOrder
public void ReRegisterOrder(Order oldOrder, Order newOrder)
connector.ReRegisterOrder(oldOrder, newOrder)

重订令.

oldOrder
取消订单 。
newOrder
新订入册.
ReRegisterOrderAsync
public ValueTask ReRegisterOrderAsync(Order oldOrder, Order newOrder, CancellationToken cancellationToken)
result = connector.ReRegisterOrderAsync(oldOrder, newOrder, cancellationToken)

同步重订顺序 。

oldOrder
取消订单 。
newOrder
新订入册.
cancellationToken
CancellationToken
Save
public override void Save(SettingsStorage storage)
connector.Save(storage)

保存设置 。

storage
设置存储 。
SendInMessage
public void SendInMessage(Message message)
connector.SendInMessage(message)

从服务器模块中向连接客户端发送消息.

SendInMessageAsync
public ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)
result = connector.SendInMessageAsync(message, cancellationToken)

同步处理一个通用消息。

message
处理的信息。
cancellationToken
CancellationToken
SendOutError
public void SendOutError(Exception error)
connector.SendOutError(error)

发送错误消息 。

error
错误细节 。
SendOutErrorAsync
public ValueTask SendOutErrorAsync(Exception error, CancellationToken cancellationToken)
result = connector.SendOutErrorAsync(error, cancellationToken)

发送错误消息 。

error
错误细节 。
cancellationToken
CancellationToken
SendOutMessage
public void SendOutMessage(Message message)
connector.SendOutMessage(message)

发送发送的消息 。

message
传言.
SendOutMessageAsync
public ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = connector.SendOutMessageAsync(message, cancellationToken)

发送发送的消息(状态更改,顺序等).

message
传言.
cancellationToken
CancellationToken
Subscribe
public void Subscribe(Subscription subscription)
connector.Subscribe(subscription)

订户.

subscription
订阅.
UnSubscribe
public void UnSubscribe(Subscription subscription)
connector.UnSubscribe(subscription)

解订.

subscription
订阅.

事件

BoardReceived
public event Action<Subscription, ExchangeBoard> BoardReceived
connector.BoardReceived += handler

ExchangeBoard received.

CandleReceived
public event Action<Subscription, ICandleMessage> CandleReceived
connector.CandleReceived += handler

ICandleMessage received.

ChangePasswordResult
public event Action<long, Exception> ChangePasswordResult
connector.ChangePasswordResult += handler

更改密码结果 。

Connected
public event Action Connected
connector.Connected += handler

连接了 。

ConnectedEx
public event Action<IMessageAdapter> ConnectedEx
connector.ConnectedEx += handler

连接了 。

ConnectionError
public event Action<Exception> ConnectionError
connector.ConnectionError += handler

连接出错( 例如, 连接被服务器中止) 。

ConnectionErrorEx
public event Action<IMessageAdapter, Exception> ConnectionErrorEx
connector.ConnectionErrorEx += handler

连接出错( 例如, 连接被服务器中止) 。

ConnectionLost
public event Action<IMessageAdapter> ConnectionLost
connector.ConnectionLost += handler

连接丢失 。

ConnectionRestored
public event Action<IMessageAdapter> ConnectionRestored
connector.ConnectionRestored += handler

连接恢复 。

CurrentTimeChanged
public event Action<TimeSpan> CurrentTimeChanged
connector.CurrentTimeChanged += handler

服务器时间更改了 CurrentTime 。 它通过了事件上次通话以来的时差, 事件第一次通过值为零 。

DataTypeReceived
public event Action<Subscription, DataType> DataTypeReceived
connector.DataTypeReceived += handler

DataType received.

Disconnected
public event Action Disconnected
connector.Disconnected += handler

断相相相.

DisconnectedEx
public event Action<IMessageAdapter> DisconnectedEx
connector.DisconnectedEx += handler

断相相相.

Error
public event Action<Exception> Error
connector.Error += handler

数据处理出错 。

Level1Received
public event Action<Subscription, Level1ChangeMessage> Level1Received
connector.Level1Received += handler

Level1ChangeMessage received.

LookupPortfoliosResult
public event Action<PortfolioLookupMessage, IEnumerable<Portfolio>, Exception> LookupPortfoliosResult
connector.LookupPortfoliosResult += handler

查询结果PortfolioLookupMessage收到.

LookupPortfoliosResult2
public event Action<PortfolioLookupMessage, IEnumerable<Portfolio>, IEnumerable<Portfolio>, Exception> LookupPortfoliosResult2
connector.LookupPortfoliosResult2 += handler

查询结果PortfolioLookupMessage收到.

LookupSecuritiesResult
public event Action<SecurityLookupMessage, IEnumerable<Security>, Exception> LookupSecuritiesResult
connector.LookupSecuritiesResult += handler

查询结果SecurityLookupMessage收到.

LookupSecuritiesResult2
public event Action<SecurityLookupMessage, IEnumerable<Security>, IEnumerable<Security>, Exception> LookupSecuritiesResult2
connector.LookupSecuritiesResult2 += handler

查询结果SecurityLookupMessage收到.

MassOrderCanceled
public event Action<long> MassOrderCanceled
connector.MassOrderCanceled += handler

大众订单取消活动.

MassOrderCanceled2
public event Action<long, DateTime> MassOrderCanceled2
connector.MassOrderCanceled2 += handler

大众订单取消活动.

MassOrderCancelFailed
public event Action<long, Exception> MassOrderCancelFailed
connector.MassOrderCancelFailed += handler

质量订单取消错误事件.

MassOrderCancelFailed2
public event Action<long, Exception, DateTime> MassOrderCancelFailed2
connector.MassOrderCancelFailed2 += handler

质量订单取消错误事件.

NewMessage
public event Action<Message> NewMessage
connector.NewMessage += handler
NewMyTrade
public event Action<MyTrade> NewMyTrade
connector.NewMyTrade += handler

拥有交易权

NewOrder
public event Action<Order> NewOrder
connector.NewOrder += handler

已讫入定.

NewOutMessageAsync
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
connector.NewOutMessageAsync += handler

新消息事件 。

NewPortfolio
public event Action<Portfolio> NewPortfolio
connector.NewPortfolio += handler

收到了新的投资组合。

NewPosition
public event Action<Position> NewPosition
connector.NewPosition += handler

已接到新职位。

NewsReceived
public event Action<Subscription, News> NewsReceived
connector.NewsReceived += handler

消息收到 。

OrderBookReceived
public event Action<Subscription, IOrderBookMessage> OrderBookReceived
connector.OrderBookReceived += handler

IOrderBookMessage received.

OrderCancelFailed
public event Action<OrderFail> OrderCancelFailed
connector.OrderCancelFailed += handler

命令取消错误事件 。

OrderCancelFailReceived
public event Action<Subscription, OrderFail> OrderCancelFailReceived
connector.OrderCancelFailReceived += handler

OrderFail cancellation event.

OrderChanged
public event Action<Order> OrderChanged
connector.OrderChanged += handler

命令已更改( 已取消, 匹配 ) 。

OrderEdited
public event Action<long, Order> OrderEdited
connector.OrderEdited += handler

秩序)成功结果事件.

OrderEditFailed
public event Action<long, OrderFail> OrderEditFailed
connector.OrderEditFailed += handler

顺序)出错结果事件.

OrderEditFailReceived
public event Action<Subscription, OrderFail> OrderEditFailReceived
connector.OrderEditFailReceived += handler

OrderFail edition event.

OrderLogReceived
public event Action<Subscription, IOrderLogMessage> OrderLogReceived
connector.OrderLogReceived += handler

IOrderLogMessage received.

OrderReceived
public event Action<Subscription, Order> OrderReceived
connector.OrderReceived += handler

已讫入定.

OrderRegisterFailed
public event Action<OrderFail> OrderRegisterFailed
connector.OrderRegisterFailed += handler

命令注册错误事件 。

OrderRegisterFailReceived
public event Action<Subscription, OrderFail> OrderRegisterFailReceived
connector.OrderRegisterFailReceived += handler

OrderFail注册活动.

OwnTradeReceived
public event Action<Subscription, MyTrade> OwnTradeReceived
connector.OwnTradeReceived += handler

MyTrade received.

PortfolioChanged
public event Action<Portfolio> PortfolioChanged
connector.PortfolioChanged += handler

组合变了。

PortfolioReceived
public event Action<Subscription, Portfolio> PortfolioReceived
connector.PortfolioReceived += handler

投资组合收到。

PositionChanged
public event Action<Position> PositionChanged
connector.PositionChanged += handler

立场已改变。

PositionReceived
public event Action<Subscription, Position> PositionReceived
connector.PositionReceived += handler

收到立场

SecurityReceived
public event Action<Subscription, Security> SecurityReceived
connector.SecurityReceived += handler

收到的金融工具。

SubscriptionFailed
public event Action<Subscription, Exception, bool> SubscriptionFailed
connector.SubscriptionFailed += handler

订阅失败 。

SubscriptionOnline
public event Action<Subscription> SubscriptionOnline
connector.SubscriptionOnline += handler

订阅内容已在线。

SubscriptionReceived
public event Action<Subscription, object> SubscriptionReceived
connector.SubscriptionReceived += handler

价值已收.

SubscriptionStarted
public event Action<Subscription> SubscriptionStarted
connector.SubscriptionStarted += handler

订阅工作已经开始。

SubscriptionStopped
public event Action<Subscription, Exception> SubscriptionStopped
connector.SubscriptionStopped += handler

订阅停止 。

TickTradeReceived
public event Action<Subscription, ITickTradeMessage> TickTradeReceived
connector.TickTradeReceived += handler

ITickTradeMessage received.

ValuesChanged
public event Action<Security, IEnumerable<KeyValuePair<Level1Fields, object>>, DateTime, DateTime> ValuesChanged
connector.ValuesChanged += handler

金融工具已改变。