Table of Contents

Class RabbitOutboundEndpoint

Namespace
Steeltoe.Integration.Rabbit.Outbound
Assembly
Steeltoe.Integration.RabbitMQ.dll
public class RabbitOutboundEndpoint : AbstractRabbitOutboundEndpoint, IMessageHandler, IServiceNameAware, IOrdered, IMessageProducer, IHeaderPropagation, ILifecycle, RabbitTemplate.IConfirmCallback, RabbitTemplate.IReturnCallback
Inheritance
RabbitOutboundEndpoint
Implements
Inherited Members

Constructors

RabbitOutboundEndpoint(IApplicationContext, RabbitTemplate, ILogger) 

public RabbitOutboundEndpoint(IApplicationContext context, RabbitTemplate rabbitTemplate, ILogger logger)

Parameters

context IApplicationContext
rabbitTemplate RabbitTemplate
logger ILogger

Properties

ExpectReply 

public bool ExpectReply { get; set; }

Property Value

bool

ShouldWaitForConfirm 

public bool ShouldWaitForConfirm { get; set; }

Property Value

bool

Template 

public RabbitTemplate Template { get; }

Property Value

RabbitTemplate

WaitForConfirmTimeout 

public TimeSpan WaitForConfirmTimeout { get; set; }

Property Value

TimeSpan

Methods

Confirm(CorrelationData, bool, string) 

public void Confirm(CorrelationData correlationData, bool ack, string cause)

Parameters

correlationData CorrelationData
ack bool
cause string

DoStop() 

protected override void DoStop()

EndpointInit() 

protected override void EndpointInit()

GetRabbitTemplate() 

protected override RabbitTemplate GetRabbitTemplate()

Returns

RabbitTemplate

HandleRequestMessage(IMessage) 

protected override object HandleRequestMessage(IMessage requestMessage)

Parameters

requestMessage IMessage

Returns

object

Initialize() 

public void Initialize()

ReturnedMessage(IMessage<byte[]>, int, string, string, string) 

public void ReturnedMessage(IMessage<byte[]> message, int replyCode, string replyText, string exchange, string routingKey)

Parameters

message IMessage<byte[]>
replyCode int
replyText string
exchange string
routingKey string