Proton DotNet
Loading...
Searching...
No Matches
Public Member Functions | Static Public Member Functions | Properties | List of all members
Apache.Qpid.Proton.Client.Implementation.ClientMessage< T > Class Template Referencesealed
Inheritance diagram for Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >:
Apache.Qpid.Proton.Client.IAdvancedMessage< T > Apache.Qpid.Proton.Client.IMessage< T >

Public Member Functions

IAdvancedMessage< T > ToAdvancedMessage ()
 Returns this message as an advanced message instance.
 
IProtonBuffer Encode (IDictionary< string, object > deliveryAnnotations)
 Encodes the advanced message for transmission by the client. The provided delivery annotations can be included or augmented by the advanced implementation based on the target message format. The implementation is responsible for ensuring that the delivery annotations are treated correctly encoded into the correct location in the message.
 
bool HasAnnotation (string key)
 Query the message to determine if the message carries the given annotation keyed value.
 
object GetAnnotation (string key)
 Returns the requested message annotation value from this message if it exists or returns null otherwise.
 
IMessage< T > SetAnnotation (string key, object value)
 Add the annotation to he set of message annotations or update the value stored with the given annotation key.
 
object RemoveAnnotation (string key)
 Removes the given annotation from the message if present and returns the value that was stored within.
 
IMessage< T > ForEachAnnotation (Action< string, object > consumer)
 Efficient walk of all the current message annotations contained in this message.
 
bool HasProperty (string key)
 Query the message to determine if the message carries the given property.
 
object GetProperty (string key)
 Returns the requested message property value from this message if it exists or returns null otherwise.
 
IMessage< T > SetProperty (string key, object value)
 Add the property to he set of message properties or update the value stored with the given mapping.
 
object RemoveProperty (string key)
 Removes the given property from the message if present and returns the value that was stored within.
 
IMessage< T > ForEachProperty (Action< string, object > consumer)
 Efficient walk of all the current message properties contained in this message.
 
bool HasFooter (string key)
 Query the message to determine if the message carries the given footer entry.
 
object GetFooter (string key)
 Returns the requested message footer value from this message if it exists or returns null otherwise.
 
IMessage< T > SetFooter (string key, object value)
 Add the footer to he set of message footers or update the value stored with the given mapping.
 
object RemoveFooter (string key)
 Removes the given property from the message if present and returns the value that was stored within.
 
IMessage< T > ForEachFooter (Action< string, object > consumer)
 Efficient walk of all the current message footers contained in this message.
 
IAdvancedMessage< T > AddBodySection (ISection section)
 Adds the given section to the internal collection of sections that will be sent to the remote peer when this message is encoded. If a previous section was added by a call to the set body method it should be retained as the first element of the running list of body sections contained in this message.
 
IEnumerable< ISectionGetBodySections ()
 Create and return an unmodifiable read-only view that contains the section instances currently assigned to this message.
 
IAdvancedMessage< T > SetBodySections (IEnumerable< ISection > sections)
 Sets the body section instances to use when encoding this message. The value set replaces any existing sections assigned to this message through the add body sections API or the singular body set method. Calling the set method with a null or empty enumerable is equivalent to calling the clear body sections method. The values from the passed enumerable are copied and changes to it following calls to this method are not reflected in the collection contained in this message.
 
IAdvancedMessage< T > ClearBodySections ()
 Clears all currently set body sections from this message instance.
 
IAdvancedMessage< T > ForEachBodySection (Action< ISection > consumer)
 Efficient enumeration over all currently assigned body sections in this message.
 

Static Public Member Functions

static ClientMessage< T > Create ()
 Creates a new advanced message instance using the Proton implementation.
 
static ClientMessage< T > Create (ISection body)
 
static ClientMessage< T > CreateAdvancedMessage ()
 
- Static Public Member Functions inherited from Apache.Qpid.Proton.Client.IMessage< T >
static IMessage< T > Create (T value)
 Create and return an IMessage that will carry the body section provided.
 
static IMessage< byte[]> Create (byte[] value)
 Create and return an IMessage that will carry the body section provided as an AMQP Data section that carries the provided bytes.
 
static IMessage< IList > Create (IList value)
 Create and return an IMessage that will carry the body section provided as an AMQP Sequence section that carries the provided list entries.
 
static IMessage< IDictionary > Create< K, V > (IDictionary value)
 Create and return an IMessage that will carry the body section provided as an AMQP Value section that carries the provided map entries.
 

Properties

uint MessageFormat [get, set]
 Access the message format value present in this message. The exact structure of a message, together with its encoding, is defined by the message format (default is the AMQP defined message format zero.
 
bool Durable [get, set]
 For a message being sent this gets and sets the durability flag on the message. For a received message this gets or overwrites the durability flag set by the original sender (unless already locally updated).
 
byte Priority [get, set]
 For a message being sent this gets and sets the message priority on the message. For a received message this gets or overwrites the priority value set by the original sender (unless already locally updated).
 
uint TimeToLive [get, set]
 For a message being sent this gets and sets the message time to live on the message. For a received message this gets or overwrites the time to live value set by the original sender (unless already locally updated).
 
bool FirstAcquirer [get, set]
 For a message being sent this gets and sets the first acquirer flag on the message. For a received message this gets or overwrites the first acquirer flag set by the original sender (unless already locally updated).
 
uint DeliveryCount [get, set]
 For a message being sent this gets and sets the message delivery count on the message. For a received message this gets or overwrites the delivery count set by the original sender (unless already locally updated).
 
object MessageId [get, set]
 The message Id, if set, uniquely identifies a message within the message system. The message producer is usually responsible for setting the message-id in such a way that it is assured to be globally unique. A remote peer MAY discard a message as a duplicate if the value of the message-id matches that of a previously received message sent to the same node.
 
byte[] UserId [get, set]
 The identity of the user responsible for producing the message. The client sets this value, and it MAY be authenticated by intermediaries.
 
string To [get, set]
 The to field identifies the node that is the intended destination of the message. On any given transfer this might not be the node at the receiving end of the link.
 
string Subject [get, set]
 The Subject field is a common field for summary information about the message content and purpose.
 
string ReplyTo [get, set]
 The reply to field identifies a node that is the intended destination for responses to this message.
 
object CorrelationId [get, set]
 This is a client-specific id that can be used to mark or identify messages between clients.
 
string ContentType [get, set]
 The RFC-2046 MIME type for the message's application-data section (body). As per RFC-2046 this can contain a charset parameter defining the character encoding used: e.g., 'text/plain; charset="utf-8"'.
 
string ContentEncoding [get, set]
 The content-encoding property is used as a modifier to the content-type. When present, its value indicates what additional content encodings have been applied to the application-data, and thus what decoding mechanisms need to be applied in order to obtain the media-type referenced by the content-type header field. Content-encoding is primarily used to allow a document to be compressed without losing the identity of its underlying content type.
 
ulong AbsoluteExpiryTime [get, set]
 An absolute time when this message is considered to be expired.
 
ulong CreationTime [get, set]
 An absolute time when this message was created.
 
string GroupId [get, set]
 Identifies the group the message belongs to.
 
uint GroupSequence [get, set]
 The relative position of this message within its group.
 
string ReplyToGroupId [get, set]
 This is a client-specific id that is used so that client can send replies to this message to a specific group.
 
bool HasAnnotations [get]
 Checks if the message carries any annotations.
 
bool HasProperties [get]
 Checks if the message carries any message properties.
 
bool HasFooters [get]
 Checks if the message carries any footers.
 
Header Header [get, set]
 Provides access to the AMQP Header instance that is carried in the message.
 
Properties Properties [get, set]
 Provides access to the AMQP Properties instance that is carried in the message.
 
MessageAnnotations Annotations [get, set]
 Provides access to the AMQP MessageAnnotations instance that is carried in the message.
 
ApplicationProperties ApplicationProperties [get, set]
 Provides access to the AMQP ApplicationProperties instance that is carried in the message.
 
Footer Footer [get, set]
 Provides access to the AMQP Footer instance that is carried in the message.
 
Body [get, set]
 Access the body of this message. Depending on the current state of the message an exception might be thrown indicating that the body is not readable or is not writable.
 
- Properties inherited from Apache.Qpid.Proton.Client.IAdvancedMessage< T >
- Properties inherited from Apache.Qpid.Proton.Client.IMessage< T >

Member Function Documentation

◆ AddBodySection()

Adds the given section to the internal collection of sections that will be sent to the remote peer when this message is encoded. If a previous section was added by a call to the set body method it should be retained as the first element of the running list of body sections contained in this message.

The implementation should make an attempt to validate that sections added are valid for the message format that is assigned when they are added.

Parameters
sectionThe section to add to the collection of sections in this message
Returns
This advanced message instance.

Implements Apache.Qpid.Proton.Client.IAdvancedMessage< T >.

◆ ClearBodySections()

Clears all currently set body sections from this message instance.

Returns
This advanced message instance.

Implements Apache.Qpid.Proton.Client.IAdvancedMessage< T >.

◆ Create()

Creates a new advanced message instance using the Proton implementation.

Returns
A new advanced message instance.

Implements Apache.Qpid.Proton.Client.IAdvancedMessage< T >.

◆ Encode()

IProtonBuffer Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.Encode ( IDictionary< string, object >  deliveryAnnotations)
inline

Encodes the advanced message for transmission by the client. The provided delivery annotations can be included or augmented by the advanced implementation based on the target message format. The implementation is responsible for ensuring that the delivery annotations are treated correctly encoded into the correct location in the message.

Parameters
deliveryAnnotationsOptions delivery annotations to encode with the message
Returns
The encoded message bytes in a proton buffer instance

Implements Apache.Qpid.Proton.Client.IAdvancedMessage< T >.

◆ ForEachAnnotation()

IMessage< T > Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.ForEachAnnotation ( Action< string, object >  consumer)
inline

Efficient walk of all the current message annotations contained in this message.

Parameters
consumerFunction that will be called for each annotation

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ ForEachBodySection()

IAdvancedMessage< T > Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.ForEachBodySection ( Action< ISection consumer)
inline

Efficient enumeration over all currently assigned body sections in this message.

Parameters
consumerFunction to invoke for each section in the message
Returns
This advanced message instance.

Implements Apache.Qpid.Proton.Client.IAdvancedMessage< T >.

◆ ForEachFooter()

IMessage< T > Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.ForEachFooter ( Action< string, object >  consumer)
inline

Efficient walk of all the current message footers contained in this message.

Parameters
consumer

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ ForEachProperty()

IMessage< T > Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.ForEachProperty ( Action< string, object >  consumer)
inline

Efficient walk of all the current message properties contained in this message.

Parameters
consumer

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ GetAnnotation()

object Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.GetAnnotation ( string  key)
inline

Returns the requested message annotation value from this message if it exists or returns null otherwise.

Parameters
keyThe message annotation key
Returns
The value that is stored in the message annotation mapping

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ GetBodySections()

IEnumerable< ISection > Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.GetBodySections ( )
inline

Create and return an unmodifiable read-only view that contains the section instances currently assigned to this message.

Returns
a read-only view of the sections in this message's body

Implements Apache.Qpid.Proton.Client.IAdvancedMessage< T >.

◆ GetFooter()

object Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.GetFooter ( string  key)
inline

Returns the requested message footer value from this message if it exists or returns null otherwise.

Parameters
keyThe message footer key
Returns
The value that is mapped to the given key

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ GetProperty()

object Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.GetProperty ( string  key)
inline

Returns the requested message property value from this message if it exists or returns null otherwise.

Parameters
keyThe message property key
Returns
The value that is mapped to the given key

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ HasAnnotation()

bool Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.HasAnnotation ( string  key)
inline

Query the message to determine if the message carries the given annotation keyed value.

Returns
true if the message instance carries the annotation

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ HasFooter()

bool Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.HasFooter ( string  key)
inline

Query the message to determine if the message carries the given footer entry.

Returns
true if the message instance carries the footer entry

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ HasProperty()

bool Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.HasProperty ( string  key)
inline

Query the message to determine if the message carries the given property.

Returns
true if the message instance carries the property

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ RemoveAnnotation()

object Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.RemoveAnnotation ( string  key)
inline

Removes the given annotation from the message if present and returns the value that was stored within.

Parameters
keyThe annotation key whose value should be removed.
Returns
The annotation value removed or null if not present

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ RemoveFooter()

object Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.RemoveFooter ( string  key)
inline

Removes the given property from the message if present and returns the value that was stored within.

Parameters
keyThe property key which is to be removed
Returns
The property value removed or null if not present

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ RemoveProperty()

object Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.RemoveProperty ( string  key)
inline

Removes the given property from the message if present and returns the value that was stored within.

Parameters
keyThe property key which is to be removed
Returns
The property value removed or null if not present

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ SetAnnotation()

IMessage< T > Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.SetAnnotation ( string  key,
object  value 
)
inline

Add the annotation to he set of message annotations or update the value stored with the given annotation key.

Parameters
keyThe whose value is being added or updated
valueThe value to store with the given key
Returns
This message instance

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ SetBodySections()

IAdvancedMessage< T > Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.SetBodySections ( IEnumerable< ISection section)
inline

Sets the body section instances to use when encoding this message. The value set replaces any existing sections assigned to this message through the add body sections API or the singular body set method. Calling the set method with a null or empty enumerable is equivalent to calling the clear body sections method. The values from the passed enumerable are copied and changes to it following calls to this method are not reflected in the collection contained in this message.

Parameters
sectionsThe collection of body sections to assign to this message
Returns
This advanced message instance.

Implements Apache.Qpid.Proton.Client.IAdvancedMessage< T >.

◆ SetFooter()

IMessage< T > Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.SetFooter ( string  key,
object  value 
)
inline

Add the footer to he set of message footers or update the value stored with the given mapping.

Parameters
keyThe whose value is being added or updated
valueThe value to store with the given key
Returns
This message object instance

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ SetProperty()

IMessage< T > Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.SetProperty ( string  key,
object  value 
)
inline

Add the property to he set of message properties or update the value stored with the given mapping.

Parameters
keyThe whose value is being added or updated
valueThe value to store with the given key
Returns
This message object instance

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ ToAdvancedMessage()

Returns this message as an advanced message instance.

Returns
This message instance as an advanced message interface

Implements Apache.Qpid.Proton.Client.IMessage< T >.

Property Documentation

◆ AbsoluteExpiryTime

ulong Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.AbsoluteExpiryTime
getset

An absolute time when this message is considered to be expired.

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ Annotations

Provides access to the AMQP MessageAnnotations instance that is carried in the message.

Implements Apache.Qpid.Proton.Client.IAdvancedMessage< T >.

◆ ApplicationProperties

Provides access to the AMQP ApplicationProperties instance that is carried in the message.

Implements Apache.Qpid.Proton.Client.IAdvancedMessage< T >.

◆ Body

Access the body of this message. Depending on the current state of the message an exception might be thrown indicating that the body is not readable or is not writable.

Returns
The message body
Exceptions
ClientExceptionIf the message body cannot be read or written

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ ContentEncoding

string Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.ContentEncoding
getset

The content-encoding property is used as a modifier to the content-type. When present, its value indicates what additional content encodings have been applied to the application-data, and thus what decoding mechanisms need to be applied in order to obtain the media-type referenced by the content-type header field. Content-encoding is primarily used to allow a document to be compressed without losing the identity of its underlying content type.

Content-encodings are to be interpreted as per section 3.5 of RFC 2616 [RFC2616]. Valid content-encodings are registered at IANA [IANAHTTPPARAMS].

The content-encoding MUST NOT be set when the application-data section is other than data. The binary representation of all other application-data section types is defined completely in terms of the AMQP type system.

Implementations MUST NOT use the identity encoding. Instead, implementations SHOULD NOT set this property. Implementations SHOULD NOT use the compress encoding, except as to remain compatible with messages originally sent with other protocols, e.g. HTTP or SMTP.

Implementations SHOULD NOT specify multiple content-encoding values except as to be compatible with messages originally sent with other protocols, e.g. HTTP or SMTP.

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ ContentType

The RFC-2046 MIME type for the message's application-data section (body). As per RFC-2046 this can contain a charset parameter defining the character encoding used: e.g., 'text/plain; charset="utf-8"'.

When using an application-data section with a section code other than data, content-type SHOULD NOT be set.

For clarity, as per section 7.2.1 of RFC-2616, where the content type is unknown the content-type SHOULD NOT be set. This allows the recipient the opportunity to determine the actual type. Where the section is known to be truly opaque binary data, the content-type SHOULD be set to application/octet-stream.

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ CorrelationId

This is a client-specific id that can be used to mark or identify messages between clients.

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ CreationTime

An absolute time when this message was created.

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ DeliveryCount

For a message being sent this gets and sets the message delivery count on the message. For a received message this gets or overwrites the delivery count set by the original sender (unless already locally updated).

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ Durable

For a message being sent this gets and sets the durability flag on the message. For a received message this gets or overwrites the durability flag set by the original sender (unless already locally updated).

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ FirstAcquirer

For a message being sent this gets and sets the first acquirer flag on the message. For a received message this gets or overwrites the first acquirer flag set by the original sender (unless already locally updated).

If this value is true, then this message has not been acquired by any other link. If this value is false, then this message MAY have previously been acquired by another link or links.

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ Footer

Provides access to the AMQP Footer instance that is carried in the message.

Implements Apache.Qpid.Proton.Client.IAdvancedMessage< T >.

◆ GroupId

Identifies the group the message belongs to.

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ GroupSequence

The relative position of this message within its group.

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ HasAnnotations

Checks if the message carries any annotations.

Returns
true if the message instance carries any annotations

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ HasFooters

Checks if the message carries any footers.

Returns
true if the message instance carries any footers

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ HasProperties

Checks if the message carries any message properties.

Returns
true if the message instance carries any properties

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ Header

Provides access to the AMQP Header instance that is carried in the message.

Implements Apache.Qpid.Proton.Client.IAdvancedMessage< T >.

◆ MessageFormat

Access the message format value present in this message. The exact structure of a message, together with its encoding, is defined by the message format (default is the AMQP defined message format zero.

This field MUST be specified for the first transfer of a streamed message, if it is not set at the time of send of the first transfer the sender uses the AMQP default value of zero for this field.

The upper three octets of a message format code identify a particular message format. The lowest octet indicates the version of said message format. Any given version of a format is forwards compatible with all higher versions.

Implements Apache.Qpid.Proton.Client.IAdvancedMessage< T >.

◆ MessageId

The message Id, if set, uniquely identifies a message within the message system. The message producer is usually responsible for setting the message-id in such a way that it is assured to be globally unique. A remote peer MAY discard a message as a duplicate if the value of the message-id matches that of a previously received message sent to the same node.

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ Priority

For a message being sent this gets and sets the message priority on the message. For a received message this gets or overwrites the priority value set by the original sender (unless already locally updated).

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ Properties

Provides access to the AMQP Properties instance that is carried in the message.

Implements Apache.Qpid.Proton.Client.IAdvancedMessage< T >.

◆ ReplyTo

The reply to field identifies a node that is the intended destination for responses to this message.

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ ReplyToGroupId

string Apache.Qpid.Proton.Client.Implementation.ClientMessage< T >.ReplyToGroupId
getset

This is a client-specific id that is used so that client can send replies to this message to a specific group.

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ Subject

The Subject field is a common field for summary information about the message content and purpose.

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ TimeToLive

For a message being sent this gets and sets the message time to live on the message. For a received message this gets or overwrites the time to live value set by the original sender (unless already locally updated).

The time to live duration in milliseconds for which the message is to be considered "live". If this is set then a message expiration time will be computed based on the time of arrival at an intermediary. Messages that live longer than their expiration time will be discarded (or dead lettered). When a message is transmitted by an intermediary that was received with a time to live, the transmitted message's header SHOULD contain a time to live that is computed as the difference between the current time and the formerly computed message expiration time, i.e., the reduced time to live, so that messages will eventually die if they end up in a delivery loop.

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ To

The to field identifies the node that is the intended destination of the message. On any given transfer this might not be the node at the receiving end of the link.

Implements Apache.Qpid.Proton.Client.IMessage< T >.

◆ UserId

The identity of the user responsible for producing the message. The client sets this value, and it MAY be authenticated by intermediaries.

Implements Apache.Qpid.Proton.Client.IMessage< T >.


The documentation for this class was generated from the following file: