Class PublishContextProxy<TMessage>

Namespace

MassTransit.Context

Assembly

MassTransit.Abstractions.dll

public class PublishContextProxy<TMessage> : PublishContextProxy, PublishContext<TMessage>, SendContext<TMessage>, PublishContext, SendContext, PipeContext where TMessage : class

Type Parameters

TMessage

Inheritance

object

ProxyPipeContext

PublishContextProxy

PublishContextProxy<TMessage>

Implements

PublishContext<TMessage>

SendContext<TMessage>

PublishContext

SendContext

PipeContext

Inherited Members

PublishContextProxy.CreateProxy<T>(T)

PublishContextProxy.SourceAddress

PublishContextProxy.DestinationAddress

PublishContextProxy.ResponseAddress

PublishContextProxy.FaultAddress

PublishContextProxy.RequestId

PublishContextProxy.MessageId

PublishContextProxy.CorrelationId

PublishContextProxy.ConversationId

PublishContextProxy.InitiatorId

PublishContextProxy.ScheduledMessageId

PublishContextProxy.Headers

PublishContextProxy.TimeToLive

PublishContextProxy.SentTime

PublishContextProxy.ContentType

PublishContextProxy.Durable

PublishContextProxy.Delay

PublishContextProxy.Serializer

PublishContextProxy.Serialization

PublishContextProxy.BodyLength

PublishContextProxy.Mandatory

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, TMessage)

public PublishContextProxy(PublishContext context, TMessage message)

Parameters

context PublishContext

message TMessage

Properties

Message

The message being sent

public TMessage Message { get; }

Property Value

TMessage