[−][src]Struct ntex_amqp_codec::OutMessage
Fields
message_format: Option<MessageFormat>
header: Option<Header>
delivery_annotations: Option<Annotations>
message_annotations: Option<VecSymbolMap>
properties: Option<Properties>
application_properties: Option<VecStringMap>
body: MessageBody
Methods
impl OutMessage
[src]
pub fn with_body(body: Bytes) -> OutMessage
[src]
Create new message and set body
pub fn with_messages(messages: Vec<TransferBody>) -> OutMessage
[src]
Create new message and set messages as body
pub fn header(&self) -> Option<&Header>
[src]
Header
pub fn set_header(&mut self, header: Header) -> &mut Self
[src]
Set message header
pub fn properties(&self) -> Option<&Properties>
[src]
Message properties
pub fn properties_mut(&mut self) -> &mut Properties
[src]
Mutable reference to properties
pub fn set_properties<F>(&mut self, f: F) -> &mut Self where
F: Fn(&mut Properties),
[src]
F: Fn(&mut Properties),
Add property
pub fn app_properties(&self) -> Option<&VecStringMap>
[src]
Get application property
pub fn set_app_property<K, V>(&mut self, key: K, value: V) -> &mut Self where
K: Into<Str>,
V: Into<Variant>,
[src]
K: Into<Str>,
V: Into<Variant>,
Add application property
pub fn add_message_annotation<K, V>(&mut self, key: K, value: V) -> &mut Self where
K: Into<Symbol>,
V: Into<Variant>,
[src]
K: Into<Symbol>,
V: Into<Variant>,
Add message annotation
pub fn delivery_annotations(&self) -> Option<&Annotations>
[src]
Delivery annotations
pub fn update<F>(self, f: F) -> Self where
F: Fn(Self) -> Self,
[src]
F: Fn(Self) -> Self,
Call closure with message reference
pub fn if_some<T, F>(self, value: &Option<T>, f: F) -> Self where
F: Fn(Self, &T) -> Self,
[src]
F: Fn(Self, &T) -> Self,
Call closure if value is Some value
pub fn body(&self) -> &MessageBody
[src]
Message body
pub fn value(&self) -> Option<&Variant>
[src]
Message value
pub fn set_value<V: Into<Variant>>(&mut self, v: V) -> &mut Self
[src]
Set message body value
pub fn set_body<F>(&mut self, f: F) -> &mut Self where
F: FnOnce(&mut MessageBody),
[src]
F: FnOnce(&mut MessageBody),
Set message body
pub fn reply_message(&self) -> OutMessage
[src]
Create new message and set correlation_id
property
Trait Implementations
impl Clone for OutMessage
[src]
fn clone(&self) -> OutMessage
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for OutMessage
[src]
impl Decode for OutMessage
[src]
impl Default for OutMessage
[src]
fn default() -> OutMessage
[src]
impl Encode for OutMessage
[src]
impl From<InMessage> for OutMessage
[src]
impl From<OutMessage> for TransferBody
[src]
fn from(original: OutMessage) -> TransferBody
[src]
impl PartialEq<OutMessage> for OutMessage
[src]
fn eq(&self, other: &OutMessage) -> bool
[src]
fn ne(&self, other: &OutMessage) -> bool
[src]
impl StructuralPartialEq for OutMessage
[src]
Auto Trait Implementations
impl !RefUnwindSafe for OutMessage
impl Send for OutMessage
impl !Sync for OutMessage
impl Unpin for OutMessage
impl UnwindSafe for OutMessage
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,