TransportMessageBuilder

Properties

Headers

public List<TransportHeader> Headers { get; private set; }

Contains the list of name/value pair transport headers. Whenever a TransportMessageReceived is available the received transport headers are also included.

Methods

Local

public TransportMessageBuilder Local();

This sets the RecipientInboxWorkQueueUri tot he local inbox work queue uri. If there is no inbox an expection is thrown.

Reply

public TransportMessageBuilder Reply();

This sets the RecipientInboxWorkQueueUri to the SenderInboxWorkQueueUri of the transport message that was received. This method, therefore, is only available in a [HandlerContext]. If no transport message received instance is available or if the received transport message does not have a SenderInboxWorkQueueUri property (the sender has no inbox) an exception is thrown.

WithRecipient

public TransportMessageBuilder WithRecipient(IQueue queue);
public TransportMessageBuilder WithRecipient(Uri uri);
public TransportMessageBuilder WithRecipient(string uri);

This sets the RecipientInboxWorkQueueUri explicitly and no routing will be applied.

WithCorrelationId

public TransportMessageBuilder WithCorrelationId(string correlationId);

Sets the correlation id for the message.

Defer

public TransportMessageBuilder Defer(DateTime ignoreTillDate);

Ignores the TransportMessage until the given date/time has been reached. The TransportMessage is sent immediately and it is up to the receiving endpoint to decide how to defer it. It is recommended that you configure a deferred queue.

Without a dedicated deferred queue the work queue will contain the deferred message. This may slow down processing as a deferred message is not regarded as work. If the queue contains too many deferred messages the queue processing will become very slow and unresponsive.

WillExpire

public TransportMessageBuilder WillExpire(DateTime expiryDate);

The message will only remain valid until this date is reached. After this is will not be processed but rather immediately acknowledged. The queuing mechanism may also, should it support message expiry, remove the message internally from the queue.

WithPriority

public TransportMessageBuilder WithPriority(int priority);

WithEncryption

public TransportMessageBuilder WithEncryption(string encryption);

WithCompression

public TransportMessageBuilder WithCompression(string compression);

HasRecipient

public bool HasRecipient { get; }

Returns true if the transport message has a RecipientInboxWorkQueueUri; else false.