InMemoryMessageChannel

InMemoryMessageChannel

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

inMemoryMessageChannel = InMemoryMessageChannel(queue, name, errorHandler)

Initializes a new instance of the InMemoryMessageChannel.

queue

Message queue.

name

Channel name.

errorHandler

Error handler.

Disabled

public bool Disabled { get; set; }

value = inMemoryMessageChannel.Disabled
inMemoryMessageChannel.Disabled = value

The channel cannot be opened.

MessageCount

public int MessageCount { get; }

value = inMemoryMessageChannel.MessageCount

Message queue count.

Name

public string Name { get; }

value = inMemoryMessageChannel.Name

Handler name.

State

public ChannelStates State { get; private set; }

value = inMemoryMessageChannel.State
inMemoryMessageChannel.State = value

State.

Clone

public virtual IMessageChannel Clone()

result = inMemoryMessageChannel.Clone()

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

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

Close

public void Close()

inMemoryMessageChannel.Close()

Close channel.

DisposeManaged

protected override void DisposeManaged()

inMemoryMessageChannel.DisposeManaged()

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

Open

public void Open()

inMemoryMessageChannel.Open()

Open channel.

NewOutMessageAsync

public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync

inMemoryMessageChannel.NewOutMessageAsync += handler

New message event.

StateChanged

public event Action StateChanged

inMemoryMessageChannel.StateChanged += handler

State change event.