Class MessageProducerSupportEndpoint

Namespace

Steeltoe.Integration.Endpoint

Assembly

Steeltoe.Integration.IntegrationBase.dll

public abstract class MessageProducerSupportEndpoint : AbstractEndpoint, ISmartLifecycle, ILifecycle, IPhased, IServiceNameAware, IMessageProducer

Inheritance

object

AbstractEndpoint

MessageProducerSupportEndpoint

Implements

ISmartLifecycle

ILifecycle

IPhased

IServiceNameAware

IMessageProducer

Derived

RabbitInboundChannelAdapter

Inherited Members

AbstractEndpoint.IntegrationServices

AbstractEndpoint.ApplicationContext

AbstractEndpoint.ComponentType

AbstractEndpoint.ServiceName

AbstractEndpoint.ComponentName

AbstractEndpoint.IsAutoStartup

AbstractEndpoint.IsRunning

AbstractEndpoint.Phase

AbstractEndpoint.Start()

AbstractEndpoint.Stop(Action)

AbstractEndpoint.Stop()

AbstractEndpoint.DoStop(Action)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

MessageProducerSupportEndpoint(IApplicationContext, ILogger)

protected MessageProducerSupportEndpoint(IApplicationContext context, ILogger logger = null)

Parameters

context IApplicationContext

logger ILogger

Fields

_lock

protected object _lock

Field Value

object

Properties

ErrorChannel

public virtual IMessageChannel ErrorChannel { get; set; }

Property Value

IMessageChannel

ErrorChannelName

public virtual string ErrorChannelName { get; set; }

Property Value

string

ErrorMessageStrategy

public virtual IErrorMessageStrategy ErrorMessageStrategy { get; set; }

Property Value

IErrorMessageStrategy

MessagingTemplate

protected virtual MessagingTemplate MessagingTemplate { get; }

Property Value

MessagingTemplate

OutputChannel

Gets or sets the output channel the producer uses

public virtual IMessageChannel OutputChannel { get; set; }

Property Value

IMessageChannel

OutputChannelName

Gets or sets the output channel name the producer uses

public virtual string OutputChannelName { get; set; }

Property Value

string

SendTimeout

public virtual int SendTimeout { get; set; }

Property Value

int

Methods

BuildErrorMessage(IMessage, Exception)

protected ErrorMessage BuildErrorMessage(IMessage message, Exception exception)

Parameters

message IMessage

exception Exception

Returns

ErrorMessage

DoStart()

protected override Task DoStart()

Returns

Task

DoStop()

protected override Task DoStop()

Returns

Task

GetErrorMessageAttributes(IMessage)

protected virtual IAttributeAccessor GetErrorMessageAttributes(IMessage message)

Parameters

message IMessage

Returns

IAttributeAccessor

SendErrorMessageIfNecessary(IMessage, Exception)

protected bool SendErrorMessageIfNecessary(IMessage message, Exception exception)

Parameters

message IMessage

exception Exception

Returns

bool

SendMessage(IMessage)

protected virtual void SendMessage(IMessage messageArg)

Parameters

messageArg IMessage