Class InMemoryMessageChannel

Namespace

StockSharp.Messages

Assembly

StockSharp.Messages.dll

Message channel, based on the queue and operate within a single process.

public class InMemoryMessageChannel : Disposable, IMessageChannel, IMessageTransport, IDisposable, ICloneable<IMessageChannel>, ICloneable

Inheritance

object

Disposable

InMemoryMessageChannel

Implements

IMessageChannel

IMessageTransport

IDisposable

ICloneable<IMessageChannel>

ICloneable

Inherited Members

Disposable.Dispose()

Disposable.DisposeNative()

Disposable.ThrowIfDisposeStarted()

Disposable.ThrowIfDisposed()

Disposable.IsDisposed

Disposable.IsDisposeStarted

Disposable.Disposed

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

Extensions.IsOpened(IMessageChannel)

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)

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

InMemoryMessageChannel(IMessageQueue, string, Action<Exception>)

Initializes a new instance of the InMemoryMessageChannel.

public InMemoryMessageChannel(IMessageQueue queue, string name, Action<Exception> errorHandler)

Parameters

queue IMessageQueue

Message queue.

name string

Channel name.

errorHandler Action<Exception>

Error handler.

Properties

Disabled

The channel cannot be opened.

public bool Disabled { get; set; }

Property Value

bool

MessageCount

Message queue count.

public int MessageCount { get; }

Property Value

int

Name

Handler name.

public string Name { get; }

Property Value

string

State

State.

public ChannelStates State { get; }

Property Value

ChannelStates

Methods

Clone()

Creates a new object that is a deep copy of the current instance.

public virtual IMessageChannel Clone()

Returns

IMessageChannel

A new object that is a deep copy of this instance.

Close()

Close channel.

public void Close()

DisposeManaged()

Disposes the managed resources. Override this method to add custom clean up of managed resources.

protected override void DisposeManaged()

Open()

Open channel.

public void Open()

Events

NewOutMessageAsync

New message event.

public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync

Event Type

Func<Message, CancellationToken, ValueTask>

StateChanged

State change event.

public event Action StateChanged

Event Type

Action