Struct ntex_amqp::Configuration

pub struct Configuration {
    pub max_frame_size: u32,
    pub channel_max: u16,
    pub idle_time_out: Milliseconds,
    pub hostname: Option<ByteString>,
    /* private fields */
}

Amqp1 transport configuration.

Fields

max_frame_size: u32

channel_max: u16

idle_time_out: Milliseconds

hostname: Option<ByteString>

Implementations

impl Configuration

pub fn new() -> Self

Create connection configuration.

pub fn channel_max(&mut self, num: u16) -> &mut Self

The channel-max value is the highest channel number that may be used on the Connection. This value plus one is the maximum number of Sessions that can be simultaneously active on the Connection.

By default channel max value is set to 1024

pub fn max_frame_size(&mut self, size: u32) -> &mut Self

Set max frame size for the connection.

By default max size is set to 64kb

pub fn get_max_frame_size(&self) -> u32

Get max frame size for the connection.

pub fn idle_timeout(&mut self, timeout: u16) -> &mut Self

Set idle time-out for the connection in seconds.

By default idle time-out is set to 120 seconds

pub fn hostname(&mut self, hostname: &str) -> &mut Self

Set connection hostname

Hostname is not set by default

pub fn max_size(&mut self, size: usize) -> &mut Self

Set max inbound frame size.

If max size is set to 0, size is unlimited. By default max size is set to 0

pub fn handshake_timeout(&mut self, timeout: Seconds) -> &mut Self

Set handshake timeout.

By default handshake timeout is 5 seconds.

pub fn keepalive_timeout(&mut self, val: Seconds) -> &mut Self

Set server connection keep-alive timeout.

To disable timeout set value to 0.

By default keep-alive timeout is disabled.

pub fn disconnect_timeout(&mut self, val: Seconds) -> &mut Self

Set server connection disconnect timeout.

Defines a timeout for disconnect connection. If a disconnect procedure does not complete within this time, the connection get dropped.

To disable timeout set value to 0.

By default disconnect timeout is set to 3 seconds.

pub fn frame_read_rate( &mut self, timeout: Seconds, max_timeout: Seconds, rate: u16 ) -> &mut Self

Set read rate parameters for single frame.

Set read timeout, max timeout and rate for reading payload. If the client sends rate amount of data within timeout period of time, extend timeout by timeout seconds. But no more than max_timeout timeout.

By default frame read rate is disabled.

pub fn to_open(&self) -> Open

Create Open performative for this configuration.

pub fn from_remote(&self, open: &Open) -> Configuration

Trait Implementations

impl Clone for Configuration

fn clone(&self) -> Configuration

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Configuration

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Configuration

fn default() -> Self

Returns the “default value” for a type.