X

Class RabbitOutboundEndpoint

Inheritance
System.Object
AbstractMessageHandler
AbstractMessageProducingHandler
AbstractReplyProducingMessageHandler
AbstractRabbitOutboundEndpoint
RabbitOutboundEndpoint
Implements
IOrdered
ILifecycle
Inherited Members
Steeltoe.Integration.Handler.AbstractMessageProducingHandler.UpdateNotPropagatedHeaders(IList<>, System.Boolean)
Namespace: Steeltoe.Integration.Rabbit.Outbound
Assembly: Steeltoe.Integration.RabbitMQ.dll
Syntax
public class RabbitOutboundEndpoint : AbstractRabbitOutboundEndpoint, RabbitTemplate.IConfirmCallback, RabbitTemplate.IReturnCallback

Constructors

| Edit this page View Source

RabbitOutboundEndpoint(IApplicationContext, RabbitTemplate, ILogger)

Declaration
public RabbitOutboundEndpoint(IApplicationContext context, RabbitTemplate rabbitTemplate, ILogger logger)
Parameters
Type Name Description
IApplicationContext context
RabbitTemplate rabbitTemplate
ILogger logger

Properties

| Edit this page View Source

ExpectReply

Declaration
public bool ExpectReply { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

ShouldWaitForConfirm

Declaration
public bool ShouldWaitForConfirm { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

Template

Declaration
public RabbitTemplate Template { get; }
Property Value
Type Description
RabbitTemplate
| Edit this page View Source

WaitForConfirmTimeout

Declaration
public TimeSpan WaitForConfirmTimeout { get; set; }
Property Value
Type Description
TimeSpan

Methods

| Edit this page View Source

Confirm(CorrelationData, Boolean, String)

Declaration
public void Confirm(CorrelationData correlationData, bool ack, string cause)
Parameters
Type Name Description
CorrelationData correlationData
System.Boolean ack
System.String cause
| Edit this page View Source

DoStop()

Declaration
protected override void DoStop()
Overrides
| Edit this page View Source

EndpointInit()

Declaration
protected override void EndpointInit()
Overrides
| Edit this page View Source

GetRabbitTemplate()

Declaration
protected override RabbitTemplate GetRabbitTemplate()
Returns
Type Description
RabbitTemplate
Overrides
| Edit this page View Source

HandleRequestMessage(IMessage)

Declaration
protected override object HandleRequestMessage(IMessage requestMessage)
Parameters
Type Name Description
IMessage requestMessage
Returns
Type Description
System.Object
| Edit this page View Source

Initialize()

Declaration
public void Initialize()
| Edit this page View Source

ReturnedMessage(IMessage<Byte[]>, Int32, String, String, String)

Declaration
public void ReturnedMessage(IMessage<byte[]> message, int replyCode, string replyText, string exchange, string routingKey)
Parameters
Type Name Description
IMessage<System.Byte[]> message
System.Int32 replyCode
System.String replyText
System.String exchange
System.String routingKey

Implements

IOrdered
ILifecycle