Struct lapin::Connection [−][src]
pub struct Connection { /* fields omitted */ }
Implementations
Connect to an AMQP Server
pub fn connect_with_config(
uri: &str,
options: ConnectionProperties,
config: TLSConfig<'_, '_, '_>
) -> PromiseChain<Connection>
pub fn connect_with_config(
uri: &str,
options: ConnectionProperties,
config: TLSConfig<'_, '_, '_>
) -> PromiseChain<Connection>
Connect to an AMQP Server
Connect to an AMQP Server
pub fn connect_uri_with_identity(
uri: AMQPUri,
options: ConnectionProperties,
config: TLSConfig<'_, '_, '_>
) -> PromiseChain<Connection>
pub fn connect_uri_with_identity(
uri: AMQPUri,
options: ConnectionProperties,
config: TLSConfig<'_, '_, '_>
) -> PromiseChain<Connection>
Connect to an AMQP Server
Restore the specified topology
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”.
Block all consumers and publishers on this connection
Update the secret used by some authentication module such as OAuth2
pub fn connector(
options: ConnectionProperties
) -> impl FnOnce(AMQPUri, HandshakeResult) -> PromiseChain<Connection> + 'static
Get the current topology
This includes exchanges, queues, bindings and consumers declared by this Connection