Struct mcai_worker_sdk::prelude::Channel
source · 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 !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