Class AbstractMessageChannel

Inheritance

System.Object

AbstractMessageChannel

AbstractPollableChannel

AbstractSubscribableChannel

Implements

IMessageChannel

IChannelInterceptorAware

Namespace: Steeltoe.Integration.Channel

Assembly: Steeltoe.Integration.IntegrationBase.dll

Syntax

public abstract class AbstractMessageChannel : Channel<IMessage>, IChannelInterceptorAware

Constructors

| Edit this page View Source

AbstractMessageChannel(IApplicationContext, ILogger)

Declaration

protected AbstractMessageChannel(IApplicationContext context, ILogger logger = null)

Parameters

Type	Name	Description
IApplicationContext	context
ILogger	logger

| Edit this page View Source

AbstractMessageChannel(IApplicationContext, String, ILogger)

Declaration

protected AbstractMessageChannel(IApplicationContext context, string name, ILogger logger = null)

Parameters

Type	Name	Description
IApplicationContext	context
System.String	name
ILogger	logger

Fields

| Edit this page View Source

INDEFINITE_TIMEOUT

Declaration

protected const int INDEFINITE_TIMEOUT = null

Field Value

Type	Description
System.Int32

| Edit this page View Source

logger

Declaration

protected ILogger logger

Field Value

Type	Description
ILogger

Properties

| Edit this page View Source

ApplicationContext

Declaration

public IApplicationContext ApplicationContext { get; }

Property Value

Type	Description
IApplicationContext

| Edit this page View Source

ChannelInterceptors

Declaration

public virtual List<IChannelInterceptor> ChannelInterceptors { get; set; }

Property Value

Type	Description
List<IChannelInterceptor>

| Edit this page View Source

ComponentName

Declaration

public virtual string ComponentName { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

ComponentType

Declaration

public virtual string ComponentType { get; }

Property Value

Type	Description
System.String

| Edit this page View Source

DataTypes

Declaration

public virtual List<Type> DataTypes { get; set; }

Property Value

Type	Description
List<Type>

| Edit this page View Source

IntegrationServices

Declaration

public IIntegrationServices IntegrationServices { get; }

Property Value

Type	Description
IIntegrationServices

| Edit this page View Source

MessageConverter

Declaration

public virtual IMessageConverter MessageConverter { get; set; }

Property Value

Type	Description
IMessageConverter

| Edit this page View Source

ServiceName

Declaration

public virtual string ServiceName { get; set; }

Property Value

Type	Description
System.String

Methods

| Edit this page View Source

AddInterceptor(IChannelInterceptor)

Declaration

public virtual void AddInterceptor(IChannelInterceptor interceptor)

Parameters

Type	Name	Description
IChannelInterceptor	interceptor

| Edit this page View Source

AddInterceptor(Int32, IChannelInterceptor)

Declaration

public virtual void AddInterceptor(int index, IChannelInterceptor interceptor)

Parameters

Type	Name	Description
System.Int32	index
IChannelInterceptor	interceptor

| Edit this page View Source

DoSend(IMessage, CancellationToken)

Declaration

protected bool DoSend(IMessage message, CancellationToken cancellationToken)

Parameters

Type	Name	Description
IMessage	message
CancellationToken	cancellationToken

Returns

Type	Description
System.Boolean

| Edit this page View Source

DoSend(IMessage, Int32)

Declaration

protected virtual bool DoSend(IMessage message, int timeout)

Parameters

Type	Name	Description
IMessage	message
System.Int32	timeout

Returns

Type	Description
System.Boolean

| Edit this page View Source

DoSendInternal(IMessage, CancellationToken)

Declaration

protected abstract bool DoSendInternal(IMessage message, CancellationToken cancellationToken)

Parameters

Type	Name	Description
IMessage	message
CancellationToken	cancellationToken

Returns

Type	Description
System.Boolean

| Edit this page View Source

RemoveInterceptor(IChannelInterceptor)

Declaration

public virtual bool RemoveInterceptor(IChannelInterceptor interceptor)

Parameters

Type	Name	Description
IChannelInterceptor	interceptor

Returns

Type	Description
System.Boolean

| Edit this page View Source

RemoveInterceptor(Int32)

Declaration

public virtual IChannelInterceptor RemoveInterceptor(int index)

Parameters

Type	Name	Description
System.Int32	index

Returns

Type	Description
IChannelInterceptor

| Edit this page View Source

Send(IMessage)

Declaration

public virtual bool Send(IMessage message)

Parameters

Type	Name	Description
IMessage	message

Returns

Type	Description
System.Boolean

| Edit this page View Source

Send(IMessage, Int32)

Declaration

public virtual bool Send(IMessage message, int timeout)

Parameters

Type	Name	Description
IMessage	message
System.Int32	timeout

Returns

Type	Description
System.Boolean

| Edit this page View Source

SendAsync(IMessage, CancellationToken)

Declaration

public ValueTask<bool> SendAsync(IMessage message, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
IMessage	message
CancellationToken	cancellationToken

Returns

Type	Description
ValueTask<System.Boolean>

Implements

IMessageChannel

IChannelInterceptorAware