Class PublishContextProxy

Namespace

MassTransit.Context

Assembly

MassTransit.Abstractions.dll

public class PublishContextProxy : ProxyPipeContext, PublishContext, SendContext, PipeContext

Inheritance

object

ProxyPipeContext

PublishContextProxy

Implements

PublishContext

SendContext

PipeContext

Derived

PublishContextProxy<TMessage>

Inherited Members

ProxyPipeContext.HasPayloadType(Type)

ProxyPipeContext.TryGetPayload<T>(out T)

ProxyPipeContext.GetOrAddPayload<T>(PayloadFactory<T>)

ProxyPipeContext.AddOrUpdatePayload<T>(PayloadFactory<T>, UpdatePayloadFactory<T>)

ProxyPipeContext.CancellationToken

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

PipeExtensions.GetPayload<TPayload>(PipeContext)

PipeExtensions.GetPayload<TPayload>(PipeContext, TPayload)

PipeExtensions.OneTimeSetup<T>(PipeContext, Func<T, Task>, PayloadFactory<T>)

RoutingKeyExtensions.RoutingKey(SendContext)

RoutingKeyExtensions.SetRoutingKey(SendContext, string?)

RoutingKeyExtensions.TrySetRoutingKey(SendContext, string?)

SendContextExtensions.ApplyRedeliveryOptions(SendContext, ConsumeContext, RedeliveryOptions)

SendContextExtensions.ReplaceMessageId(SendContext, ConsumeContext)

SendContextExtensions.StartNewConversation(SendContext)

SendContextExtensions.StartNewConversation(SendContext, Guid)

SendContextExtensions.TransferConsumeContextHeaders(SendContext, ConsumeContext)

SerializerContextExtensions.TryGetHeader<T>(SendContext, string, out T?)

SerializerContextExtensions.TryGetHeader<T>(SendContext, string, out T?)

Constructors

PublishContextProxy(PublishContext)

protected PublishContextProxy(PublishContext context)

Parameters

context PublishContext

Properties

BodyLength

After serialization, should return the length of the message body

public long? BodyLength { get; }

Property Value

long?

ContentType

public ContentType? ContentType { get; set; }

Property Value

ContentType

ConversationId

public Guid? ConversationId { get; set; }

Property Value

Guid?

CorrelationId

public Guid? CorrelationId { get; set; }

Property Value

Guid?

Delay

If specified, the message delivery will be delayed by the transport (if supported)

public TimeSpan? Delay { get; set; }

Property Value

TimeSpan?

DestinationAddress

public Uri? DestinationAddress { get; set; }

Property Value

Uri

Durable

True if the message should be persisted to disk to survive a broker restart

public bool Durable { get; set; }

Property Value

bool

FaultAddress

public Uri? FaultAddress { get; set; }

Property Value

Uri

Headers

public SendHeaders Headers { get; }

Property Value

SendHeaders

InitiatorId

public Guid? InitiatorId { get; set; }

Property Value

Guid?

Mandatory

True if the message must be delivered to a subscriber

public bool Mandatory { get; set; }

Property Value

bool

MessageId

public Guid? MessageId { get; set; }

Property Value

Guid?

RequestId

public Guid? RequestId { get; set; }

Property Value

Guid?

ResponseAddress

public Uri? ResponseAddress { get; set; }

Property Value

Uri

ScheduledMessageId

public Guid? ScheduledMessageId { get; set; }

Property Value

Guid?

SentTime

public DateTime? SentTime { get; }

Property Value

DateTime?

Serialization

The endpoint configured serialization collection

public ISerialization Serialization { get; set; }

Property Value

ISerialization

Serializer

The serializer to use when serializing the message to the transport

public IMessageSerializer Serializer { get; set; }

Property Value

IMessageSerializer

SourceAddress

public Uri? SourceAddress { get; set; }

Property Value

Uri

TimeToLive

public TimeSpan? TimeToLive { get; set; }

Property Value

TimeSpan?

Methods

CreateProxy<T>(T)

Create a send context proxy with the new message type

public SendContext<T> CreateProxy<T>(T message) where T : class

Parameters

message T

Returns

SendContext<T>

Type Parameters

T