- Namespace
- Steeltoe.Messaging.RabbitMQ.Support
- Assembly
- Steeltoe.Messaging.RabbitMQ.dll
public class RabbitHeaderAccessor : MessageHeaderAccessor, IMessageHeaderAccessor
- Inheritance
-
RabbitHeaderAccessor
- Implements
-
- Inherited Members
-
Constructors
public RabbitHeaderAccessor()
public RabbitHeaderAccessor(IMessage message)
Parameters
message
IMessage
protected RabbitHeaderAccessor(MessageHeaders headers)
Parameters
headers
MessageHeaders
Fields
public const string BATCH_FORMAT_LENGTH_HEADER4 = "lengthHeader4"
Field Value
- string
public const string DEFAULT_CONTENT_TYPE = "application/octet-stream"
Field Value
- string
public const MessageDeliveryMode DEFAULT_DELIVERY_MODE = PERSISTENT
Field Value
- MessageDeliveryMode
public const int DEFAULT_PRIORITY = 0
Field Value
- int
public const int INT_MASK = 32
Field Value
- int
public const string SPRING_AUTO_DECOMPRESS = "springAutoDecompress"
Field Value
- string
public const string SPRING_BATCH_FORMAT = "springBatchFormat"
Field Value
- string
public const string X_DELAY = "x-delay"
Field Value
- string
Properties
public string AppId { get; set; }
Property Value
- string
public string ClusterId { get; set; }
Property Value
- string
public string ConsumerQueue { get; set; }
Property Value
- string
public string ConsumerTag { get; set; }
Property Value
- string
public string ContentEncoding { get; set; }
Property Value
- string
public long? ContentLength { get; set; }
Property Value
- long?
public string CorrelationId { get; set; }
Property Value
- string
public int? Delay { get; set; }
Property Value
- int?
public MessageDeliveryMode? DeliveryMode { get; set; }
Property Value
- MessageDeliveryMode?
public ulong? DeliveryTag { get; set; }
Property Value
- ulong?
public string Expiration { get; set; }
Property Value
- string
public bool? FinalRetryForMessageWithNoId { get; set; }
Property Value
- bool?
public Type InferredArgumentType { get; set; }
Property Value
- Type
public bool IsContentLengthSet { get; }
Property Value
- bool
public bool IsDeliveryTagSet { get; }
Property Value
- bool
public bool IsFinalRetryForMessageWithNoId { get; }
Property Value
- bool
public bool? LastInBatch { get; set; }
Property Value
- bool?
public uint? MessageCount { get; set; }
Property Value
- uint?
public string MessageId { get; set; }
Property Value
- string
public int? Priority { get; set; }
Property Value
- int?
public ulong? PublishSequenceNumber { get; set; }
Property Value
- ulong?
public int? ReceivedDelay { get; set; }
Property Value
- int?
public MessageDeliveryMode? ReceivedDeliveryMode { get; set; }
Property Value
- MessageDeliveryMode?
public string ReceivedExchange { get; set; }
Property Value
- string
public string ReceivedRoutingKey { get; set; }
Property Value
- string
public string ReceivedUserId { get; set; }
Property Value
- string
public bool? Redelivered { get; set; }
Property Value
- bool?
public string ReplyTo { get; set; }
Property Value
- string
public Address ReplyToAddress { get; set; }
Property Value
- Address
public object Target { get; set; }
Property Value
- object
public MethodInfo TargetMethod { get; set; }
Property Value
- MethodInfo
public long? Timestamp { get; set; }
Property Value
- long?
public string Type { get; set; }
Property Value
- string
public string UserId { get; set; }
Property Value
- string
Methods
protected RabbitHeaderAccessor CreateMutableAccessor(IMessage message)
Parameters
message
IMessage
Returns
- RabbitHeaderAccessor
protected RabbitHeaderAccessor CreateMutableAccessor(IMessageHeaders messageHeaders)
Parameters
messageHeaders
IMessageHeaders
Returns
- RabbitHeaderAccessor
public static RabbitHeaderAccessor GetAccessor(IMessage message)
Parameters
message
IMessage
Returns
- RabbitHeaderAccessor
public static RabbitHeaderAccessor GetAccessor(IMessageHeaders messageHeaders)
Parameters
messageHeaders
IMessageHeaders
Returns
- RabbitHeaderAccessor
public static RabbitHeaderAccessor GetMutableAccessor(IMessage message)
Parameters
message
IMessage
Returns
- RabbitHeaderAccessor
public static RabbitHeaderAccessor GetMutableAccessor(IMessageHeaders headers)
Parameters
headers
IMessageHeaders
Returns
- RabbitHeaderAccessor
public List<Dictionary<string, object>> GetXDeathHeader()
Returns
- List<Dictionary<string, object>>
protected override bool IsReadOnly(string headerName)
Parameters
headerName
string
Returns
- bool
public override IMessageHeaders ToMessageHeaders()
Returns
- IMessageHeaders
protected override void VerifyType(string headerName, object headerValue)
Parameters
headerName
string
headerValue
object