Class ChannelMessageAdapter

Namespace

StockSharp.Messages

Assembly

StockSharp.Messages.dll

Message adapter, forward messages through a transport channel IMessageChannel.

public class ChannelMessageAdapter : MessageAdapterWrapper, IMessageAdapterWrapper, IMessageAdapter, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, ICloneable<IMessageAdapter>, ICloneable

Inheritance

object

Cloneable<IMessageAdapter>

MessageAdapterWrapper

ChannelMessageAdapter

Implements

IMessageAdapterWrapper

IMessageAdapter

IMessageTransport

IPersistable

ILogReceiver

ILogSource

IDisposable

ICloneable<IMessageAdapter>

ICloneable

Inherited Members

MessageAdapterWrapper.InnerAdapterNewOutMessageAsync(Message, CancellationToken)

MessageAdapterWrapper.RaiseNewOutMessageAsync(Message, CancellationToken)

MessageAdapterWrapper.SendInMessageAsync(Message, CancellationToken)

MessageAdapterWrapper.Load(SettingsStorage)

MessageAdapterWrapper.Save(SettingsStorage)

MessageAdapterWrapper.GetSupportedMarketDataTypesAsync(SecurityId, DateTime?, DateTime?)

MessageAdapterWrapper.IsSupportCandlesUpdates(MarketDataMessage)

MessageAdapterWrapper.IsSupportCandlesPriceLevels(MarketDataMessage)

MessageAdapterWrapper.IsAllDownloadingSupported(DataType)

MessageAdapterWrapper.IsSecurityRequired(DataType)

MessageAdapterWrapper.ToString()

MessageAdapterWrapper.LogVerbose(string, params object[])

MessageAdapterWrapper.LogDebug(string, params object[])

MessageAdapterWrapper.LogInfo(string, params object[])

MessageAdapterWrapper.LogWarning(string, params object[])

MessageAdapterWrapper.LogError(string, params object[])

MessageAdapterWrapper.InnerAdapter

MessageAdapterWrapper.OwnInnerAdapter

MessageAdapterWrapper.SendInBackFurther

MessageAdapterWrapper.Parent

MessageAdapterWrapper.CurrentTime

MessageAdapterWrapper.CheckTimeFrameByRequest

MessageAdapterWrapper.ReConnectionSettings

MessageAdapterWrapper.TransactionIdGenerator

MessageAdapterWrapper.PossibleSupportedMessages

MessageAdapterWrapper.SupportedInMessages

MessageAdapterWrapper.NotSupportedResultMessages

MessageAdapterWrapper.HeartbeatInterval

MessageAdapterWrapper.StorageName

MessageAdapterWrapper.IsNativeIdentifiersPersistable

MessageAdapterWrapper.IsNativeIdentifiers

MessageAdapterWrapper.IsFullCandlesOnly

MessageAdapterWrapper.IsSupportSubscriptions

MessageAdapterWrapper.Categories

MessageAdapterWrapper.SupportedOrderBookDepths

MessageAdapterWrapper.IsSupportOrderBookIncrements

MessageAdapterWrapper.IsSupportExecutionsPnL

MessageAdapterWrapper.IsSecurityNewsOnly

MessageAdapterWrapper.CandlesBuildFrom

MessageAdapterWrapper.IsSupportTransactionLog

MessageAdapterWrapper.IsPositionsEmulationRequired

MessageAdapterWrapper.NewOutMessageAsync

MessageAdapterWrapper.ParentRemoved

object.GetType()

object.MemberwiseClone()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

AsyncHelper.FromResult<TValue>(TValue)

AsyncHelper.ToCompleteSource<TValue>(TValue)

CompareHelper.IsDefault<T>(T)

CompareHelper.IsRuntimeDefault<T>(T)

Converter.TypedTo<TFrom, TTo>(TFrom)

DelegateHelper.AddDelegate<TDelegate>(TDelegate, TDelegate)

DelegateHelper.GetInvocationList<TDelegate>(TDelegate)

DelegateHelper.RemoveAllDelegates<TDelegate>(TDelegate)

DelegateHelper.RemoveDelegate<TDelegate>(TDelegate, TDelegate)

DisposableHelper.MakeDisposable<T>(T, Action<T>)

Enumerator.IsDefined<T>(T)

Enumerator.SplitMask<T>(T)

NullableHelper.Convert<T, TResult>(T, Func<T, TResult>, Func<TResult>)

NullableHelper.IsNull<T>(T)

NullableHelper.IsNull<T>(T, bool)

TupleHelper.ToValues<T>(T)

TypeHelper.CheckOnNull<T>(T, string)

TypeHelper.DoDispose<TSource>(TSource)

TypeHelper.ToScope<T>(T, bool)

NetworkHelper.Format<T>(T, bool)

PersistableHelper.TrySerialize<T>(T, out SettingsStorage)

XamlHelper.CopyToClipboard<T>(T)

Paths.SerializeToString<T>(T, bool)

Paths.Serialize<T>(T, bool)

Paths.Serialize<T>(T, string, bool)

Extensions.ChangeSupported(IMessageAdapter, bool, bool)

Extensions.CreateOrderCondition(IMessageAdapter)

Extensions.CreatePortfolioChangeMessage(IMessageAdapter, string)

Extensions.CreatePositionChangeMessage(IMessageAdapter, string, SecurityId, string)

Extensions.FindAdapter<TAdapter>(IMessageAdapter)

Extensions.GetDefaultHistoryStepSize(IMessageAdapter, SecurityId, DataType, out TimeSpan)

Extensions.GetTimeFrames(IMessageAdapter, SecurityId, DateTime?, DateTime?)

Extensions.GetTimeFramesAsync(IMessageAdapter, SecurityId, DateTime?, DateTime?)

Extensions.IsCandlesSupportedAsync(IMessageAdapter, MarketDataMessage, CancellationToken)

Extensions.IsMarketData(IMessageAdapter)

Extensions.IsMarketDataTypeSupportedAsync(IMessageAdapter, DataType, CancellationToken)

Extensions.IsMessageSupported(IMessageAdapter, MessageTypes)

Extensions.IsResultMessageNotSupported(IMessageAdapter, MessageTypes)

Extensions.IsSupportSecuritiesLookupAll(IMessageAdapter)

Extensions.IsSupportStopLoss(IMessageAdapter)

Extensions.IsSupportTakeProfit(IMessageAdapter)

Extensions.IsSupportWithdraw(IMessageAdapter)

Extensions.IsTransactional(IMessageAdapter)

Extensions.NearestSupportedDepth(IMessageAdapter, int)

Extensions.TryRemoveWrapper<TAdapter>(IMessageAdapter)

Extensions.UseChannels(IMessageAdapter)

IMessageAdapterAsyncExtensions.ConnectAndDownloadAsync<T>(IMessageAdapter, ISubscriptionMessage)

IMessageAdapterAsyncExtensions.ConnectAsync(IMessageAdapter, CancellationToken)

IMessageAdapterAsyncExtensions.DisconnectAsync(IMessageAdapter, CancellationToken)

IMessageAdapterAsyncExtensions.RegisterOrderAsync(IMessageAdapter, OrderRegisterMessage)

IMessageAdapterAsyncExtensions.SubscribeAsync(IMessageAdapter, ISubscriptionMessage, CancellationToken)

IMessageAdapterAsyncExtensions.SubscribeAsync<T>(IMessageAdapter, ISubscriptionMessage)

Extensions.FindAdapter<TAdapter>(IMessageAdapterWrapper)

CompareHelper.Compare(object, object)

Converter.To(object, Type)

Converter.To<T>(object)

Enumerator.GetAttributeOfType<TAttribute>(object)

Enumerator.IsEnumBrowsable(object)

Enumerator.SplitMask2(object)

TypeHelper.HasProperty(object, string)

EntityPropertyHelper.GetPropValue(object, string, Func<object, string, object>, IDictionary<string, object>)

Extensions.GetBasicProperties(object, int)

Extensions.GetDisplayName(object)

Extensions.GetFieldDescription(object)

Extensions.GetFieldDisplayName(object)

Extensions.GetFieldIcon(object)

JsonHelper.ToJson(object, bool)

JsonHelper.ToJson(object, bool, JsonSerializerSettings)

PersistableHelper.ToStorage(object, bool)

EditorExtensions.ToItemsSource(object, Type, bool?, ListSortDirection?, Func<IItemsSourceItem, bool>, Func<object, string>, Func<object, string>)

XamlHelper.EnsureUIThread(object)

XamlHelper.ShowModel<TWindow>(object, DependencyObject)

XamlHelper.WpfCast<T>(object)

VirtualPropertyRegistry.TryGetVirtualValue(object, string, out object)

Constructors

ChannelMessageAdapter(IMessageAdapter, IMessageChannel, IMessageChannel)

Initializes a new instance of the ChannelMessageAdapter.

public ChannelMessageAdapter(IMessageAdapter innerAdapter, IMessageChannel inputChannel, IMessageChannel outputChannel)

Parameters

innerAdapter IMessageAdapter

Underlying adapter.

inputChannel IMessageChannel

Incoming messages channel.

outputChannel IMessageChannel

Outgoing message channel.

Properties

InputChannel

Adapter.

public IMessageChannel InputChannel { get; }

Property Value

IMessageChannel

OutputChannel

Adapter.

public IMessageChannel OutputChannel { get; }

Property Value

IMessageChannel

OwnInputChannel

Control the lifetime of the incoming messages channel.

public bool OwnInputChannel { get; set; }

Property Value

bool

OwnOutputChannel

Control the lifetime of the outgoing messages channel.

public bool OwnOutputChannel { get; set; }

Property Value

bool

Methods

Clone()

Create a copy of ChannelMessageAdapter.

public override IMessageAdapter Clone()

Returns

IMessageAdapter

Copy.

Dispose()

public override void Dispose()

OnInnerAdapterNewOutMessageAsync(Message, CancellationToken)

Process InnerAdapter output message.

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

Parameters

message Message

The message.

cancellationToken CancellationToken

Cancellation token.

Returns

ValueTask

OnSendInMessageAsync(Message, CancellationToken)

Send message.

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

Parameters

message Message

Message.

cancellationToken CancellationToken

CancellationToken

Returns

ValueTask