Skip to main content

LapinPublisher

ruststream_lapin

Struct LapinPublisher

pub struct LapinPublisher { /* private fields */ }

Expand description

Fire-and-forget publisher on the broker’s shared publish channel.

OutgoingMessage::name is the routing key; the target exchange is a property of the publisher (the default exchange unless exchange says otherwise). On the default exchange the routing key addresses the queue with that name.

Messages are published persistent (delivery mode 2) unless persistent(false) opts out.

Obtained from LapinBroker::publisher; usable before Broker::connect resolves the connection (publishing earlier returns AmqpError::NotConnected).

Implementations§

impl LapinPublisher

pub fn exchange(self, exchange: impl Into<String>) -> Self

Publishes to exchange instead of the default exchange.

pub fn persistent(self, persistent: bool) -> Self

Whether messages are marked persistent (delivery mode 2). Defaults to true.

pub fn confirms(self) -> ConfirmsPublisher

Upgrades to a publisher that awaits broker confirms, with buffering transactions.

The recommended transactional publisher: durable and much faster than AMQP server transactions.

pub fn server_tx(self) -> ServerTxPublisher

Upgrades to a publisher backed by AMQP server transactions (tx.select).

Server-side atomicity, at the cost of a synchronous commit round trip that is significantly slower than confirms.

Trait Implementations§

impl Clone for LapinPublisher

fn clone(&self) -> LapinPublisher

Returns a duplicate of the value. Read more

1.0.0 (const: unstable) · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more

impl Debug for LapinPublisher

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

impl Publisher for LapinPublisher

async fn publish(&self, msg: OutgoingMessage<'_>) -> Result<(), Self::Error>

Publishes msg without waiting for a broker confirm.

§Errors

Returns AmqpError::NotConnected before Broker::connect resolves the connection and AmqpError::Publish when the channel rejects the frame.

§Cancel safety

Not cancel safe: dropping the future may leave the message published or not.

type Error = AmqpError

The error type returned by publish.

Auto Trait Implementations§

impl !RefUnwindSafe for LapinPublisher

impl !UnwindSafe for LapinPublisher

impl Freeze for LapinPublisher

impl Send for LapinPublisher

impl Sync for LapinPublisher

impl Unpin for LapinPublisher

impl UnsafeUnpin for LapinPublisher

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> CloneToUninit for T
where T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)

Performs copy-assignment from self to dest. Read more

impl<T> CompatExt for T

fn compat(self) -> Compat<T>
where T: Sized,

Applies the Compat adapter by value. Read more

fn compat_ref(&self) -> Compat<&T>

Applies the Compat adapter by shared reference. Read more

fn compat_mut(&mut self) -> Compat<&mut T>

Applies the Compat adapter by mutable reference. Read more

impl<P> ErasedPublisher for P
where P: Publisher,

fn publish_bytes<'a>( &'a self, name: &'a str, payload: &'a [u8], ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Sync + Send>>> + Send + 'a>>

Publishes payload to name, with no headers. Read more

fn publish_message<'a>( &'a self, name: &'a str, payload: &'a [u8], headers: &'a Headers, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Sync + Send>>> + Send + 'a>>

Publishes payload to name with headers. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> Same for T

type Output = T

Should always be Self

impl<T> ToOwned for T
where T: Clone,

type Owned = T

The resulting type after obtaining ownership.

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more

impl<T, U> TryFrom<U> for T
where 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>

Performs the conversion.

impl<T, U> TryInto<U> for T
where 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>

Performs the conversion.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more