Struct lapin::Connection

pub struct Connection { /* fields omitted */ }

Implementations

impl Connection

pub fn connect(
    uri: &str,
    options: ConnectionProperties
) -> PromiseChain<Connection>

Connect to an AMQP Server

pub fn connect_with_config(
    uri: &str,
    options: ConnectionProperties,
    config: TLSConfig<'_, '_, '_>
) -> PromiseChain<Connection>

Connect to an AMQP Server

pub fn connect_uri(
    uri: AMQPUri,
    options: ConnectionProperties
) -> PromiseChain<Connection>

Connect to an AMQP Server

pub fn connect_uri_with_identity(
    uri: AMQPUri,
    options: ConnectionProperties,
    config: TLSConfig<'_, '_, '_>
) -> PromiseChain<Connection>

Connect to an AMQP Server

pub async fn restore(
    &self,
    topology: TopologyDefinition
) -> Result<RestoredTopology>

Restore the specified topology

pub fn create_channel(&self) -> PromiseChain<Channel>

pub fn run(self) -> Result<()>

Block current thread while the connection is still active. This is useful when you only have a consumer and nothing else keeping your application “alive”.

pub fn on_error<E: FnMut(Error) + Send + 'static>(&self, handler: E)

pub fn configuration(&self) -> &Configuration

pub fn status(&self) -> &ConnectionStatus

pub fn close(&self, reply_code: ShortUInt, reply_text: &str) -> Promise<()>

pub fn block(&self, reason: &str) -> Promise<()>

Block all consumers and publishers on this connection

pub fn unblock(&self) -> Promise<()>

Unblock all consumers and publishers on this connection

pub fn update_secret(&self, new_secret: &str, reason: &str) -> Promise<()>

Update the secret used by some authentication module such as OAuth2

pub fn connector(
    options: ConnectionProperties
) -> impl FnOnce(AMQPUri, HandshakeResult) -> PromiseChain<Connection> + 'static

pub fn topology(&self) -> TopologyDefinition

Get the current topology

This includes exchanges, queues, bindings and consumers declared by this Connection

Trait Implementations

impl Debug for Connection

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

Formats the value using the given formatter.