Class InMemoryMessageChannel

Namespace

StockSharp.Messages

Assembly

StockSharp.Messages.dll

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

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

Inheritance

object

InMemoryMessageChannel

Implements

IMessageChannel

IDisposable

ICloneable<IMessageChannel>

ICloneable

Inherited Members

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

MaxMessageCount

Max message queue count.

public int MaxMessageCount { get; set; }

Property Value

int

Remarks

The default value is -1, which corresponds to the size without limitations.

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

Create a copy of InMemoryMessageChannel.

public virtual IMessageChannel Clone()

Returns

IMessageChannel

Copy.

Close()

Close channel.

public void Close()

Open()

Open channel.

public void Open()

SendInMessage(Message)

Send message.

public bool SendInMessage(Message message)

Parameters

message Message

Message.

Returns

bool

true if the specified message was processed successfully, otherwise, false.

Events

NewOutMessage

New message event.

public event Action<Message> NewOutMessage

Event Type

Action<Message>

StateChanged

State change event.

public event Action StateChanged

Event Type

Action