Class RabbitInboundChannelAdapter

Namespace

Steeltoe.Integration.Rabbit.Inbound

Assembly

Steeltoe.Integration.RabbitMQ.dll

public class RabbitInboundChannelAdapter : MessageProducerSupportEndpoint, ISmartLifecycle, ILifecycle, IPhased, IServiceNameAware, IMessageProducer

Inheritance

object

AbstractEndpoint

MessageProducerSupportEndpoint

RabbitInboundChannelAdapter

Implements

ISmartLifecycle

ILifecycle

IPhased

IServiceNameAware

IMessageProducer

Inherited Members

MessageProducerSupportEndpoint._lock

MessageProducerSupportEndpoint.OutputChannel

MessageProducerSupportEndpoint.OutputChannelName

MessageProducerSupportEndpoint.ErrorChannel

MessageProducerSupportEndpoint.ErrorChannelName

MessageProducerSupportEndpoint.SendTimeout

MessageProducerSupportEndpoint.ErrorMessageStrategy

MessageProducerSupportEndpoint.SendMessage(IMessage)

MessageProducerSupportEndpoint.MessagingTemplate

MessageProducerSupportEndpoint.SendErrorMessageIfNecessary(IMessage, Exception)

MessageProducerSupportEndpoint.BuildErrorMessage(IMessage, Exception)

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

RabbitInboundChannelAdapter(IApplicationContext, AbstractMessageListenerContainer, ILogger)

public RabbitInboundChannelAdapter(IApplicationContext context, AbstractMessageListenerContainer listenerContainer, ILogger logger = null)

Parameters

context IApplicationContext

listenerContainer AbstractMessageListenerContainer

logger ILogger

Properties

BatchingStrategy

public IBatchingStrategy BatchingStrategy { get; set; }

Property Value

IBatchingStrategy

BindSourceMessage

public bool BindSourceMessage { get; set; }

Property Value

bool

MessageConverter

public ISmartMessageConverter MessageConverter { get; set; }

Property Value

ISmartMessageConverter

RecoveryCallback

public IRecoveryCallback RecoveryCallback { get; set; }

Property Value

IRecoveryCallback

RetryTemplate

public RetryTemplate RetryTemplate { get; set; }

Property Value

RetryTemplate

Methods

DoStart()

protected override Task DoStart()

Returns

Task

DoStop()

protected override Task DoStop()

Returns

Task

GetErrorMessageAttributes(IMessage)

protected override IAttributeAccessor GetErrorMessageAttributes(IMessage message)

Parameters

message IMessage

Returns

IAttributeAccessor