[−][src]Struct lapin_futures::Client
use lapin instead
Connect to a server and create channels
Methods
impl Client
[src]
pub fn connect(uri: &str, options: ConnectionProperties) -> ClientFuture
[src]
use lapin instead
Connect to an AMQP Server
pub fn connect_with_identity(
uri: &str,
options: ConnectionProperties,
identity: Identity
) -> ClientFuture
[src]
uri: &str,
options: ConnectionProperties,
identity: Identity
) -> ClientFuture
use lapin instead
Connect to an AMQP Server
pub fn connect_uri(uri: AMQPUri, options: ConnectionProperties) -> ClientFuture
[src]
use lapin instead
Connect to an AMQP Server
pub fn connect_uri_with_identity(
uri: AMQPUri,
options: ConnectionProperties,
identity: Identity
) -> ClientFuture
[src]
uri: AMQPUri,
options: ConnectionProperties,
identity: Identity
) -> ClientFuture
use lapin instead
Connect to an AMQP Server
pub fn create_channel(
&self
) -> impl Future<Item = Channel, Error = Error> + Send + 'static
[src]
&self
) -> impl Future<Item = Channel, Error = Error> + Send + 'static
use lapin instead
Return a future that resolves to a Channel
once the method succeeds
pub fn update_secret(
&self,
new_secret: &str,
reason: &str
) -> ConfirmationFuture<()>
[src]
&self,
new_secret: &str,
reason: &str
) -> ConfirmationFuture<()>
use lapin instead
Update the secret used by some authentication module such as oauth2
pub fn block(&self, reason: &str) -> ConfirmationFuture<()>
[src]
use lapin instead
Block all consumers and publishers on this connection
pub fn unblock(&self) -> ConfirmationFuture<()>
[src]
use lapin instead
Unblock all consumers and publishers on this connection
pub fn on_error<E: Fn(Error) + Send + 'static>(&self, handler: Box<E>)
[src]
use lapin instead
Register an error handler which will be called when connection reaches an Error state
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for Client
impl Send for Client
impl Sync for Client
impl Unpin for Client
impl !UnwindSafe for Client
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,