pub struct Channel { /* private fields */ }
Implementations§
Source§impl Channel
impl Channel
pub fn status(&self) -> &ChannelStatus
pub fn id(&self) -> u16
pub fn close( &self, reply_code: u16, reply_text: &str, ) -> PinkySwear<Result<(), Error>>
pub fn basic_consume( &self, queue: &str, consumer_tag: &str, options: BasicConsumeOptions, arguments: FieldTable, ) -> PinkySwear<Result<Consumer, Error>, Result<(), Error>>
pub fn basic_get( &self, queue: &str, options: BasicGetOptions, ) -> PinkySwear<Result<Option<BasicGetMessage>, Error>, Result<(), Error>>
pub fn exchange_declare( &self, exchange: &str, kind: ExchangeKind, options: ExchangeDeclareOptions, arguments: FieldTable, ) -> PinkySwear<Result<(), Error>>
pub fn wait_for_confirms( &self, ) -> PinkySwear<Result<Vec<BasicReturnMessage>, Error>, Result<Confirmation, Error>>
Source§impl Channel
impl Channel
pub fn channel_flow( &self, options: ChannelFlowOptions, ) -> PinkySwear<Result<bool, Error>, Result<(), Error>>
pub fn do_channel_close( &self, reply_code: u16, reply_text: &str, class_id: u16, method_id: u16, ) -> PinkySwear<Result<(), Error>>
pub fn access_request( &self, realm: &str, options: AccessRequestOptions, ) -> PinkySwear<Result<(), Error>>
pub fn do_exchange_declare( &self, exchange: &str, kind: &str, options: ExchangeDeclareOptions, arguments: FieldTable, exchange_kind: ExchangeKind, ) -> PinkySwear<Result<(), Error>>
Sourcepub fn exchange_delete(
&self,
exchange: &str,
options: ExchangeDeleteOptions,
) -> PinkySwear<Result<(), Error>>
pub fn exchange_delete( &self, exchange: &str, options: ExchangeDeleteOptions, ) -> PinkySwear<Result<(), Error>>
Delete an exchange
pub fn exchange_bind( &self, destination: &str, source: &str, routing_key: &str, options: ExchangeBindOptions, arguments: FieldTable, ) -> PinkySwear<Result<(), Error>>
pub fn exchange_unbind( &self, destination: &str, source: &str, routing_key: &str, options: ExchangeUnbindOptions, arguments: FieldTable, ) -> PinkySwear<Result<(), Error>>
pub fn queue_declare( &self, queue: &str, options: QueueDeclareOptions, arguments: FieldTable, ) -> PinkySwear<Result<Queue, Error>, Result<(), Error>>
pub fn queue_bind( &self, queue: &str, exchange: &str, routing_key: &str, options: QueueBindOptions, arguments: FieldTable, ) -> PinkySwear<Result<(), Error>>
pub fn queue_purge( &self, queue: &str, options: QueuePurgeOptions, ) -> PinkySwear<Result<u32, Error>, Result<(), Error>>
pub fn queue_delete( &self, queue: &str, options: QueueDeleteOptions, ) -> PinkySwear<Result<u32, Error>, Result<(), Error>>
pub fn queue_unbind( &self, queue: &str, exchange: &str, routing_key: &str, arguments: FieldTable, ) -> PinkySwear<Result<(), Error>>
pub fn basic_qos( &self, prefetch_count: u16, options: BasicQosOptions, ) -> PinkySwear<Result<(), Error>>
pub fn do_basic_consume( &self, queue: &str, consumer_tag: &str, options: BasicConsumeOptions, arguments: FieldTable, original: Option<Consumer>, ) -> PinkySwear<Result<Consumer, Error>, Result<(), Error>>
pub fn basic_cancel( &self, consumer_tag: &str, options: BasicCancelOptions, ) -> PinkySwear<Result<(), Error>>
pub fn basic_publish( &self, exchange: &str, routing_key: &str, options: BasicPublishOptions, payload: Vec<u8>, properties: AMQPProperties, ) -> PinkySwear<Result<PublisherConfirm, Error>, Result<(), Error>>
pub fn do_basic_get( &self, queue: &str, options: BasicGetOptions, original: Option<Pinky<Result<Option<BasicGetMessage>, Error>>>, ) -> PinkySwear<Result<Option<BasicGetMessage>, Error>, Result<(), Error>>
pub fn basic_ack( &self, delivery_tag: u64, options: BasicAckOptions, ) -> PinkySwear<Result<(), Error>>
pub fn basic_reject( &self, delivery_tag: u64, options: BasicRejectOptions, ) -> PinkySwear<Result<(), Error>>
pub fn basic_recover_async( &self, options: BasicRecoverAsyncOptions, ) -> PinkySwear<Result<(), Error>>
pub fn basic_recover( &self, options: BasicRecoverOptions, ) -> PinkySwear<Result<(), Error>>
pub fn basic_nack( &self, delivery_tag: u64, options: BasicNackOptions, ) -> PinkySwear<Result<(), Error>>
pub fn tx_select(&self) -> PinkySwear<Result<(), Error>>
pub fn tx_commit(&self) -> PinkySwear<Result<(), Error>>
pub fn tx_rollback(&self) -> PinkySwear<Result<(), Error>>
pub fn confirm_select( &self, options: ConfirmSelectOptions, ) -> PinkySwear<Result<(), Error>>
Trait Implementations§
Auto Trait Implementations§
impl Freeze for Channel
impl !RefUnwindSafe for Channel
impl Send for Channel
impl Sync for Channel
impl Unpin for Channel
impl !UnwindSafe for Channel
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more