Class AbstractRabbitOutboundEndpoint

Namespace

Steeltoe.Integration.Rabbit.Outbound

Assembly

Steeltoe.Integration.RabbitMQ.dll

public abstract class AbstractRabbitOutboundEndpoint : AbstractReplyProducingMessageHandler, IMessageHandler, IServiceNameAware, IOrdered, IMessageProducer, IHeaderPropagation, ILifecycle

Inheritance

object

AbstractMessageHandler

AbstractMessageProducingHandler

AbstractReplyProducingMessageHandler

AbstractRabbitOutboundEndpoint

Implements

IMessageHandler

IServiceNameAware

IOrdered

IMessageProducer

IHeaderPropagation

ILifecycle

Derived

RabbitOutboundEndpoint

Inherited Members

AbstractReplyProducingMessageHandler.RequiresReply

AbstractReplyProducingMessageHandler.HandleMessageInternal(IMessage)

AbstractReplyProducingMessageHandler.HandleRequestMessage(IMessage)

AbstractMessageProducingHandler.OutputChannel

AbstractMessageProducingHandler.OutputChannelName

AbstractMessageProducingHandler.NotPropagatedHeaders

AbstractMessageProducingHandler.AddNotPropagatedHeaders(params string[])

AbstractMessageProducingHandler.SendTimeout

AbstractMessageProducingHandler.ShouldCopyRequestHeaders

AbstractMessageProducingHandler.UpdateNotPropagatedHeaders(IList<string>, bool)

AbstractMessageProducingHandler.SendOutputs(object, IMessage)

AbstractMessageProducingHandler.ProduceOutput(object, IMessage)

AbstractMessageProducingHandler.SendOutput(object, object, bool)

AbstractMessageProducingHandler.ShouldSplitOutput(IEnumerable)

AbstractMessageProducingHandler.CreateOutputMessage(object, IMessageHeaders)

AbstractMessageHandler.IntegrationServices

AbstractMessageHandler.ApplicationContext

AbstractMessageHandler.ComponentType

AbstractMessageHandler.ServiceName

AbstractMessageHandler.ComponentName

AbstractMessageHandler.Order

AbstractMessageHandler.HandleMessage(IMessage)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

AbstractRabbitOutboundEndpoint(IApplicationContext, ILogger)

protected AbstractRabbitOutboundEndpoint(IApplicationContext context, ILogger logger)

Parameters

context IApplicationContext

logger ILogger

Properties

ConfirmAckChannel

public IMessageChannel ConfirmAckChannel { get; set; }

Property Value

IMessageChannel

ConfirmAckChannelName

public string ConfirmAckChannelName { get; set; }

Property Value

string

ConfirmCorrelationExpression

public IExpression ConfirmCorrelationExpression { get; set; }

Property Value

IExpression

ConfirmNackChannel

public IMessageChannel ConfirmNackChannel { get; set; }

Property Value

IMessageChannel

ConfirmNackChannelName

public string ConfirmNackChannelName { get; set; }

Property Value

string

ConfirmTimeout

public TimeSpan? ConfirmTimeout { get; set; }

Property Value

TimeSpan?

ConnectionFactory

public IConnectionFactory ConnectionFactory { get; set; }

Property Value

IConnectionFactory

CorrelationDataGenerator

public ExpressionEvaluatingMessageProcessor<object> CorrelationDataGenerator { get; set; }

Property Value

ExpressionEvaluatingMessageProcessor<object>

DefaultDeliveryMode

public MessageDeliveryMode DefaultDeliveryMode { get; set; }

Property Value

MessageDeliveryMode

DelayExpression

public IExpression DelayExpression { get; set; }

Property Value

IExpression

DelayGenerator

public ExpressionEvaluatingMessageProcessor<int> DelayGenerator { get; set; }

Property Value

ExpressionEvaluatingMessageProcessor<int>

ErrorMessageStrategy

public IErrorMessageStrategy ErrorMessageStrategy { get; set; }

Property Value

IErrorMessageStrategy

ExchangeName

public string ExchangeName { get; set; }

Property Value

string

ExchangeNameExpression

public IExpression ExchangeNameExpression { get; set; }

Property Value

IExpression

ExchangeNameGenerator

public ExpressionEvaluatingMessageProcessor<string> ExchangeNameGenerator { get; set; }

Property Value

ExpressionEvaluatingMessageProcessor<string>

HeaderMapper

public IRabbitHeaderMapper HeaderMapper { get; set; }

Property Value

IRabbitHeaderMapper

HeadersMappedLast

public bool HeadersMappedLast { get; set; }

Property Value

bool

IsRunning

Gets a value indicating whether gets a value indicating if its running

public bool IsRunning { get; }

Property Value

bool

LazyConnect

public bool LazyConnect { get; set; }

Property Value

bool

ReturnChannel

public IMessageChannel ReturnChannel { get; set; }

Property Value

IMessageChannel

RoutingKey

public string RoutingKey { get; set; }

Property Value

string

RoutingKeyExpression

public IExpression RoutingKeyExpression { get; set; }

Property Value

IExpression

RoutingKeyGenerator

public ExpressionEvaluatingMessageProcessor<string> RoutingKeyGenerator { get; set; }

Property Value

ExpressionEvaluatingMessageProcessor<string>

Running

public bool Running { get; set; }

Property Value

bool

Methods

AddDelayProperty(IMessage)

protected virtual void AddDelayProperty(IMessage message)

Parameters

message IMessage

BuildReply(IMessageConverter, IMessage)

protected virtual IMessageBuilder BuildReply(IMessageConverter converter, IMessage amqpReplyMessage)

Parameters

converter IMessageConverter

amqpReplyMessage IMessage

Returns

IMessageBuilder

BuildReturnedMessage(IMessage, int, string, string, string, IMessageConverter)

protected virtual IMessage BuildReturnedMessage(IMessage message, int replyCode, string replyText, string exchange, string returnedRoutingKey, IMessageConverter converter)

Parameters

message IMessage

replyCode int

replyText string

exchange string

returnedRoutingKey string

converter IMessageConverter

Returns

IMessage

DoStart()

protected virtual void DoStart()

DoStop()

protected virtual void DoStop()

EndpointInit()

protected virtual void EndpointInit()

GenerateCorrelationData(IMessage)

protected virtual CorrelationData GenerateCorrelationData(IMessage requestMessage)

Parameters

requestMessage IMessage

Returns

CorrelationData

GenerateExchangeName(IMessage)

protected virtual string GenerateExchangeName(IMessage requestMessage)

Parameters

requestMessage IMessage

Returns

string

GenerateRoutingKey(IMessage)

protected virtual string GenerateRoutingKey(IMessage requestMessage)

Parameters

requestMessage IMessage

Returns

string

GetConfirmAckChannel()

protected virtual IMessageChannel GetConfirmAckChannel()

Returns

IMessageChannel

GetConfirmNackChannel()

protected virtual IMessageChannel GetConfirmNackChannel()

Returns

IMessageChannel

GetRabbitTemplate()

protected abstract RabbitTemplate GetRabbitTemplate()

Returns

RabbitTemplate

HandleConfirm(CorrelationData, bool, string)

protected void HandleConfirm(CorrelationData correlationData, bool ack, string cause)

Parameters

correlationData CorrelationData

ack bool

cause string

Initialize()

public override void Initialize()

SetConfirmCorrelationExpressionString(string)

public void SetConfirmCorrelationExpressionString(string confirmCorrelationExpression)

Parameters

confirmCorrelationExpression string

SetConfirmTimeout(int)

public void SetConfirmTimeout(int confirmTimeout)

Parameters

confirmTimeout int

SetDelay(int)

public void SetDelay(int delay)

Parameters

delay int

SetDelayExpressionString(string)

public void SetDelayExpressionString(string delayExpression)

Parameters

delayExpression string

SetExchangeNameExpressionString(string)

public void SetExchangeNameExpressionString(string exchangeNameExpression)

Parameters

exchangeNameExpression string

SetRoutingKeyExpressionString(string)

public void SetRoutingKeyExpressionString(string routingKeyExpression)

Parameters

routingKeyExpression string

Start()

public void Start()

Stop()

public void Stop()