Struct StaticConnectionFactory 

pub struct StaticConnectionFactory { /* private fields */ }

A simple factory that creates channels from a static lapin::Connection.

Does not handle reconnection — if the connection drops, channel creation will fail until the connection is re-established externally.

For applications with their own connection management (e.g. connection pools or reconnect loops), implement ChannelFactory directly to integrate with your reconnection logic.

Implementations

impl StaticConnectionFactory

pub fn new(connection: Connection) -> Self

Create a factory backed by the given connection.

Trait Implementations

impl ChannelFactory for StaticConnectionFactory

fn create_channel<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Channel, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Create a new AMQP channel.