Class AbstractRabbitOutboundEndpoint

Inheritance

System.Object

AbstractMessageHandler

AbstractMessageProducingHandler

AbstractReplyProducingMessageHandler

AbstractRabbitOutboundEndpoint

RabbitOutboundEndpoint

Implements

IOrdered

IMessageProducer

IHeaderPropagation

ILifecycle

Inherited Members

AbstractReplyProducingMessageHandler.RequiresReply

AbstractReplyProducingMessageHandler.HandleMessageInternal(IMessage)

AbstractReplyProducingMessageHandler.HandleRequestMessage(IMessage)

AbstractMessageProducingHandler.OutputChannel

AbstractMessageProducingHandler.OutputChannelName

AbstractMessageProducingHandler.NotPropagatedHeaders

AbstractMessageProducingHandler.AddNotPropagatedHeaders(String[])

AbstractMessageProducingHandler.SendTimeout

AbstractMessageProducingHandler.ShouldCopyRequestHeaders

Steeltoe.Integration.Handler.AbstractMessageProducingHandler.UpdateNotPropagatedHeaders(IList<>, System.Boolean)

AbstractMessageProducingHandler.SendOutputs(Object, IMessage)

AbstractMessageProducingHandler.ProduceOutput(Object, IMessage)

AbstractMessageProducingHandler.SendOutput(Object, Object, Boolean)

AbstractMessageProducingHandler.ShouldSplitOutput(IEnumerable)

AbstractMessageProducingHandler.CreateOutputMessage(Object, IMessageHeaders)

AbstractMessageHandler.IntegrationServices

AbstractMessageHandler.ApplicationContext

AbstractMessageHandler.ComponentType

AbstractMessageHandler.ServiceName

AbstractMessageHandler.ComponentName

AbstractMessageHandler.Order

AbstractMessageHandler.HandleMessage(IMessage)

Namespace: Steeltoe.Integration.Rabbit.Outbound

Assembly: Steeltoe.Integration.RabbitMQ.dll

Syntax

public abstract class AbstractRabbitOutboundEndpoint : AbstractReplyProducingMessageHandler

Constructors

| Edit this page View Source

AbstractRabbitOutboundEndpoint(IApplicationContext, ILogger)

Declaration

protected AbstractRabbitOutboundEndpoint(IApplicationContext context, ILogger logger)

Parameters

Type	Name	Description
IApplicationContext	context
ILogger	logger

Properties

| Edit this page View Source

ConfirmAckChannel

Declaration

public IMessageChannel ConfirmAckChannel { get; set; }

Property Value

Type	Description
IMessageChannel

| Edit this page View Source

ConfirmAckChannelName

Declaration

public string ConfirmAckChannelName { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

ConfirmCorrelationExpression

Declaration

public IExpression ConfirmCorrelationExpression { get; set; }

Property Value

Type	Description
IExpression

| Edit this page View Source

ConfirmNackChannel

Declaration

public IMessageChannel ConfirmNackChannel { get; set; }

Property Value

Type	Description
IMessageChannel

| Edit this page View Source

ConfirmNackChannelName

Declaration

public string ConfirmNackChannelName { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

ConfirmTimeout

Declaration

public TimeSpan? ConfirmTimeout { get; set; }

Property Value

Type	Description
System.Nullable<TimeSpan>

| Edit this page View Source

ConnectionFactory

Declaration

public IConnectionFactory ConnectionFactory { get; set; }

Property Value

Type	Description
IConnectionFactory

| Edit this page View Source

CorrelationDataGenerator

Declaration

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

Property Value

Type	Description
ExpressionEvaluatingMessageProcessor<System.Object>

| Edit this page View Source

DefaultDeliveryMode

Declaration

public MessageDeliveryMode DefaultDeliveryMode { get; set; }

Property Value

Type	Description
MessageDeliveryMode

| Edit this page View Source

DelayExpression

Declaration

public IExpression DelayExpression { get; set; }

Property Value

Type	Description
IExpression

| Edit this page View Source

DelayGenerator

Declaration

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

Property Value

Type	Description
ExpressionEvaluatingMessageProcessor<System.Int32>

| Edit this page View Source

ErrorMessageStrategy

Declaration

public IErrorMessageStrategy ErrorMessageStrategy { get; set; }

Property Value

Type	Description
IErrorMessageStrategy

| Edit this page View Source

ExchangeName

Declaration

public string ExchangeName { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

ExchangeNameExpression

Declaration

public IExpression ExchangeNameExpression { get; set; }

Property Value

Type	Description
IExpression

| Edit this page View Source

ExchangeNameGenerator

Declaration

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

Property Value

Type	Description
ExpressionEvaluatingMessageProcessor<System.String>

| Edit this page View Source

HeaderMapper

Declaration

public IRabbitHeaderMapper HeaderMapper { get; set; }

Property Value

Type	Description
IRabbitHeaderMapper

| Edit this page View Source

HeadersMappedLast

Declaration

public bool HeadersMappedLast { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

IsRunning

Declaration

public bool IsRunning { get; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

LazyConnect

Declaration

public bool LazyConnect { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

ReturnChannel

Declaration

public IMessageChannel ReturnChannel { get; set; }

Property Value

Type	Description
IMessageChannel

| Edit this page View Source

RoutingKey

Declaration

public string RoutingKey { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

RoutingKeyExpression

Declaration

public IExpression RoutingKeyExpression { get; set; }

Property Value

Type	Description
IExpression

| Edit this page View Source

RoutingKeyGenerator

Declaration

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

Property Value

Type	Description
ExpressionEvaluatingMessageProcessor<System.String>

| Edit this page View Source

Running

Declaration

public bool Running { get; set; }

Property Value

Type	Description
System.Boolean

Methods

| Edit this page View Source

AddDelayProperty(IMessage)

Declaration

protected virtual void AddDelayProperty(IMessage message)

Parameters

Type	Name	Description
IMessage	message

| Edit this page View Source

BuildReply(IMessageConverter, IMessage)

Declaration

protected virtual IMessageBuilder BuildReply(IMessageConverter converter, IMessage amqpReplyMessage)

Parameters

Type	Name	Description
IMessageConverter	converter
IMessage	amqpReplyMessage

Returns

Type	Description
IMessageBuilder

| Edit this page View Source

BuildReturnedMessage(IMessage, Int32, String, String, String, IMessageConverter)

Declaration

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

Parameters

Type	Name	Description
IMessage	message
System.Int32	replyCode
System.String	replyText
System.String	exchange
System.String	returnedRoutingKey
IMessageConverter	converter

Returns

Type	Description
IMessage

| Edit this page View Source

DoStart()

Declaration

protected virtual void DoStart()

| Edit this page View Source

DoStop()

Declaration

protected virtual void DoStop()

| Edit this page View Source

EndpointInit()

Declaration

protected virtual void EndpointInit()

| Edit this page View Source

GenerateCorrelationData(IMessage)

Declaration

protected virtual CorrelationData GenerateCorrelationData(IMessage requestMessage)

Parameters

Type	Name	Description
IMessage	requestMessage

Returns

Type	Description
CorrelationData

| Edit this page View Source

GenerateExchangeName(IMessage)

Declaration

protected virtual string GenerateExchangeName(IMessage requestMessage)

Parameters

Type	Name	Description
IMessage	requestMessage

Returns

Type	Description
System.String

| Edit this page View Source

GenerateRoutingKey(IMessage)

Declaration

protected virtual string GenerateRoutingKey(IMessage requestMessage)

Parameters

Type	Name	Description
IMessage	requestMessage

Returns

Type	Description
System.String

| Edit this page View Source

GetConfirmAckChannel()

Declaration

protected virtual IMessageChannel GetConfirmAckChannel()

Returns

Type	Description
IMessageChannel

| Edit this page View Source

GetConfirmNackChannel()

Declaration

protected virtual IMessageChannel GetConfirmNackChannel()

Returns

Type	Description
IMessageChannel

| Edit this page View Source

GetRabbitTemplate()

Declaration

protected abstract RabbitTemplate GetRabbitTemplate()

Returns

Type	Description
RabbitTemplate

| Edit this page View Source

HandleConfirm(CorrelationData, Boolean, String)

Declaration

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

Parameters

Type	Name	Description
CorrelationData	correlationData
System.Boolean	ack
System.String	cause

| Edit this page View Source

Initialize()

Declaration

public override void Initialize()

Overrides

AbstractMessageHandler.Initialize()

| Edit this page View Source

SetConfirmCorrelationExpressionString(String)

Declaration

public void SetConfirmCorrelationExpressionString(string confirmCorrelationExpression)

Parameters

Type	Name	Description
System.String	confirmCorrelationExpression

| Edit this page View Source

SetConfirmTimeout(Int32)

Declaration

public void SetConfirmTimeout(int confirmTimeout)

Parameters

Type	Name	Description
System.Int32	confirmTimeout

| Edit this page View Source

SetDelay(Int32)

Declaration

public void SetDelay(int delay)

Parameters

Type	Name	Description
System.Int32	delay

| Edit this page View Source

SetDelayExpressionString(String)

Declaration

public void SetDelayExpressionString(string delayExpression)

Parameters

Type	Name	Description
System.String	delayExpression

| Edit this page View Source

SetExchangeNameExpressionString(String)

Declaration

public void SetExchangeNameExpressionString(string exchangeNameExpression)

Parameters

Type	Name	Description
System.String	exchangeNameExpression

| Edit this page View Source

SetRoutingKeyExpressionString(String)

Declaration

public void SetRoutingKeyExpressionString(string routingKeyExpression)

Parameters

Type	Name	Description
System.String	routingKeyExpression

| Edit this page View Source

Start()

Declaration

public void Start()

| Edit this page View Source

Stop()

Declaration

public void Stop()

Implements

IOrdered

IMessageProducer

IHeaderPropagation

ILifecycle