Class RepublishMessageRecoverer

Namespace

Steeltoe.Messaging.RabbitMQ.Retry

Assembly

Steeltoe.Messaging.RabbitMQ.dll

[Obsolete("This feature will be removed in the next major version. See https://steeltoe.io/docs/v3/obsolete for details.")]
public class RepublishMessageRecoverer : IMessageRecoverer

Inheritance

object

RepublishMessageRecoverer

Implements

IMessageRecoverer

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

RepublishMessageRecoverer(RabbitTemplate, ILogger)

public RepublishMessageRecoverer(RabbitTemplate errorTemplate, ILogger logger = null)

Parameters

errorTemplate RabbitTemplate

logger ILogger

RepublishMessageRecoverer(RabbitTemplate, string, ILogger)

public RepublishMessageRecoverer(RabbitTemplate errorTemplate, string errorExchange, ILogger logger = null)

Parameters

errorTemplate RabbitTemplate

errorExchange string

logger ILogger

RepublishMessageRecoverer(RabbitTemplate, string, string, ILogger)

public RepublishMessageRecoverer(RabbitTemplate errorTemplate, string errorExchange, string errorRoutingKey, ILogger logger = null)

Parameters

errorTemplate RabbitTemplate

errorExchange string

errorRoutingKey string

logger ILogger

Fields

DEFAULT_FRAME_MAX_HEADROOM

public const int DEFAULT_FRAME_MAX_HEADROOM = 20000

Field Value

int

X_EXCEPTION_MESSAGE

public const string X_EXCEPTION_MESSAGE = "x-exception-message"

Field Value

string

X_EXCEPTION_STACKTRACE

public const string X_EXCEPTION_STACKTRACE = "x-exception-stacktrace"

Field Value

string

X_ORIGINAL_EXCHANGE

public const string X_ORIGINAL_EXCHANGE = "x-original-exchange"

Field Value

string

X_ORIGINAL_ROUTING_KEY

public const string X_ORIGINAL_ROUTING_KEY = "x-original-routingKey"

Field Value

string

Properties

DeliveryMode

public MessageDeliveryMode DeliveryMode { get; set; }

Property Value

MessageDeliveryMode

ErrorExchangeName

public string ErrorExchangeName { get; }

Property Value

string

ErrorRoutingKey

public string ErrorRoutingKey { get; }

Property Value

string

ErrorRoutingKeyPrefix

public string ErrorRoutingKeyPrefix { get; set; }

Property Value

string

ErrorTemplate

public RabbitTemplate ErrorTemplate { get; }

Property Value

RabbitTemplate

FrameMaxHeadroom

public int FrameMaxHeadroom { get; set; }

Property Value

int

MaxStackTraceLength

public int MaxStackTraceLength { get; set; }

Property Value

int

Methods

AddAdditionalHeaders(IMessage, Exception)

protected virtual Dictionary<string, object> AddAdditionalHeaders(IMessage message, Exception cause)

Parameters

message IMessage

cause Exception

Returns

Dictionary<string, object>

Recover(IMessage, Exception)

public void Recover(IMessage message, Exception exception)

Parameters

message IMessage

exception Exception