Struct ntex_amqp::client::Connector

pub struct Connector<A, T> { /* fields omitted */ }

Amqp client connector

Implementations

impl<A> Connector<A, ()>

pub fn new() -> Connector<A, Connector<A>>

Create new amqp connector

impl<A, T> Connector<A, T> where
    A: Address,
    T: Service<Request = Connect<A>, Error = ConnectError>,
    T::Response: AsyncRead + AsyncWrite + Unpin + 'static, 

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) -> usize

Get max frame size for the connection.

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

Set idle time-out for the connection.

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 handshake_timeout(self, timeout: Seconds) -> Self

Set handshake timeout.

Handshake includes connect packet and response connect-ack. By default handshake timeuot is disabled.

pub fn disconnect_timeout(self, timeout: Seconds) -> Self

Set client 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 buffer_params(
    self,
    max_read_buf_size: u16,
    max_write_buf_size: u16,
    min_buf_size: u16
) -> Self

Set read/write buffer params

By default read buffer is 8kb, write buffer is 8kb

pub fn connector<U>(self, connector: U) -> Connector<A, U> where
    U: Service<Request = Connect<A>, Error = ConnectError>,
    U::Response: AsyncRead + AsyncWrite + Unpin + 'static, 

Use custom connector

pub fn connect(
    &self,
    address: A
) -> impl Future<Output = Result<Client<T::Response>, ConnectError>>

Connect to amqp server

pub fn negotiate<Io>(
    &self,
    io: Io
) -> impl Future<Output = Result<Client<Io>, ConnectError>> where
    Io: AsyncRead + AsyncWrite + Unpin + 'static, 

Negotiate amqp protocol over opened socket

pub fn connect_sasl(
    &self,
    addr: A,
    auth: SaslAuth
) -> impl Future<Output = Result<Client<T::Response>, ConnectError>>

Connect to amqp server

pub fn negotiate_sasl<Io>(
    &self,
    io: Io,
    auth: SaslAuth
) -> impl Future<Output = Result<Client<Io>, ConnectError>> where
    Io: AsyncRead + AsyncWrite + Unpin + 'static, 

Negotiate amqp sasl protocol over opened socket