Class DefaultRabbitHeaderMapper

Namespace

Steeltoe.Integration.Rabbit.Support

Assembly

Steeltoe.Integration.RabbitMQ.dll

public class DefaultRabbitHeaderMapper : AbstractHeaderMapper<IMessageHeaders>, IRabbitHeaderMapper, IRequestReplyHeaderMapper<IMessageHeaders>

Inheritance

object

AbstractHeaderMapper<IMessageHeaders>

DefaultRabbitHeaderMapper

Implements

IRabbitHeaderMapper

IRequestReplyHeaderMapper<IMessageHeaders>

Inherited Members

AbstractHeaderMapper<IMessageHeaders>.STANDARD_REQUEST_HEADER_NAME_PATTERN

AbstractHeaderMapper<IMessageHeaders>.STANDARD_REPLY_HEADER_NAME_PATTERN

AbstractHeaderMapper<IMessageHeaders>.NON_STANDARD_HEADER_NAME_PATTERN

AbstractHeaderMapper<IMessageHeaders>.StandardHeaderPrefix

AbstractHeaderMapper<IMessageHeaders>.RequestHeaderNames

AbstractHeaderMapper<IMessageHeaders>.ReplyHeaderNames

AbstractHeaderMapper<IMessageHeaders>.RequestHeaderMatcher

AbstractHeaderMapper<IMessageHeaders>.ReplyHeaderMatcher

AbstractHeaderMapper<IMessageHeaders>.SetRequestHeaderNames(params string[])

AbstractHeaderMapper<IMessageHeaders>.SetReplyHeaderNames(params string[])

AbstractHeaderMapper<IMessageHeaders>.FromHeadersToRequest(IMessageHeaders, IMessageHeaders)

AbstractHeaderMapper<IMessageHeaders>.FromHeadersToReply(IMessageHeaders, IMessageHeaders)

AbstractHeaderMapper<IMessageHeaders>.ToHeadersFromRequest(IMessageHeaders)

AbstractHeaderMapper<IMessageHeaders>.ToHeadersFromReply(IMessageHeaders)

AbstractHeaderMapper<IMessageHeaders>.CreateDefaultHeaderMatcher(string, List<string>)

AbstractHeaderMapper<IMessageHeaders>.CreateHeaderMatcher(string[])

AbstractHeaderMapper<IMessageHeaders>.GetHeaderIfAvailable<V>(IDictionary<string, object>, string, Type)

AbstractHeaderMapper<IMessageHeaders>.CreateTargetPropertyName(string, bool)

AbstractHeaderMapper<IMessageHeaders>.GetTransientHeaderNames()

AbstractHeaderMapper<IMessageHeaders>.PopulateStandardHeaders(IDictionary<string, object>, IDictionary<string, object>, IMessageHeaders)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

DefaultRabbitHeaderMapper(string[], string[], ILogger)

protected DefaultRabbitHeaderMapper(string[] requestHeaderNames, string[] replyHeaderNames, ILogger logger)

Parameters

requestHeaderNames string[]

replyHeaderNames string[]

logger ILogger

Properties

InboundReplyHeaders

public static string[] InboundReplyHeaders { get; }

Property Value

string[]

InboundRequestHeaders

public static string[] InboundRequestHeaders { get; }

Property Value

string[]

OutboundReplyHeaders

public static string[] OutboundReplyHeaders { get; }

Property Value

string[]

OutboundRequestHeaders

public static string[] OutboundRequestHeaders { get; }

Property Value

string[]

SafeOutboundHeaders

public static string[] SafeOutboundHeaders { get; }

Property Value

string[]

Methods

ExtractStandardHeaders(IMessageHeaders)

protected override IDictionary<string, object> ExtractStandardHeaders(IMessageHeaders source)

Parameters

source IMessageHeaders

Returns

IDictionary<string, object>

ExtractUserDefinedHeaders(IMessageHeaders)

protected override IDictionary<string, object> ExtractUserDefinedHeaders(IMessageHeaders source)

Parameters

source IMessageHeaders

Returns

IDictionary<string, object>

GetInboundMapper(ILogger)

public static DefaultRabbitHeaderMapper GetInboundMapper(ILogger logger)

Parameters

logger ILogger

Returns

DefaultRabbitHeaderMapper

GetOutboundMapper(ILogger)

public static DefaultRabbitHeaderMapper GetOutboundMapper(ILogger logger)

Parameters

logger ILogger

Returns

DefaultRabbitHeaderMapper

PopulateStandardHeaders(IDictionary<string, object>, IMessageHeaders)

protected override void PopulateStandardHeaders(IDictionary<string, object> headers, IMessageHeaders target)

Parameters

headers IDictionary<string, object>

target IMessageHeaders

PopulateUserDefinedHeader(string, object, IMessageHeaders)

protected override void PopulateUserDefinedHeader(string headerName, object headerValue, IMessageHeaders target)

Parameters

headerName string

headerValue object

target IMessageHeaders