Struct oracle::aq::DeqOptions

source ·
pub struct DeqOptions { /* private fields */ }
Expand description

Options when dequeuing messages using advanced queueing

Warning: The type is unstable. It may be changed incompatibly by minor version upgrades.

Implementations§

source§

impl DeqOptions

source

pub fn condition(&self) -> Result<String>

Returns the condition that must be satisfied in order for a message to be dequeued.

See set_condition method for more information

source

pub fn consumer_name(&self) -> Result<String>

Returns the name of the consumer that is dequeuing messages.

see set_consumer_name method for more information.

source

pub fn correlation(&self) -> Result<String>

Returns the correlation of the message to be dequeued.

See set_correlation method for more information.

source

pub fn mode(&self) -> Result<DeqMode>

Returns the mode that is to be used when dequeuing messages.

source

pub fn message_id(&self) -> Result<Vec<u8>>

Returns the identifier of the specific message that is to be dequeued.

source

pub fn navigation(&self) -> Result<DeqNavigation>

Returns the position of the message that is to be dequeued.

source

pub fn transformation(&self) -> Result<String>

Returns the transformation of the message to be dequeued.

See set_transformation method for more information.

source

pub fn visibility(&self) -> Result<Visibility>

Returns whether the message being dequeued is part of the current transaction or constitutes a transaction on its own.

source

pub fn wait(&self) -> Result<Duration>

Returns the time to wait for a message matching the search criteria.

source

pub fn set_condition(&mut self, val: &str) -> Result<()>

Sets the condition which must be true for messages to be dequeued.

The condition must be a valid boolean expression similar to the where clause of a SQL query. The expression can include conditions on message properties, user data properties and PL/SQL or SQL functions. User data properties must be prefixed with tab.user_data as a qualifier to indicate the specific column of the queue table that stores the message payload.

source

pub fn set_consumer_name(&mut self, val: &str) -> Result<()>

Sets the name of the consumer which will be dequeuing messages. This value should only be set if the queue is set up for multiple consumers.

source

pub fn set_correlation(&mut self, val: &str) -> Result<()>

Sets the correlation of the message to be dequeued.

Special pattern matching characters such as the percent sign (%) and the underscore (_) can be used. If multiple messages satisfy the pattern, the order of dequeuing is undetermined.

source

pub fn set_delivery_mode(&mut self, val: &MessageDeliveryMode) -> Result<()>

Sets the message delivery mode that is to be used when dequeuing messages.

source

pub fn set_mode(&mut self, val: &DeqMode) -> Result<()>

Sets the mode that is to be used when dequeuing messages.

source

pub fn set_message_id(&mut self, val: &[u8]) -> Result<()>

Sets the identifier of the specific message to be dequeued.

source

pub fn set_navigation(&mut self, val: &DeqNavigation) -> Result<()>

Sets the position in the queue of the message that is to be dequeued.

source

pub fn set_transformation(&mut self, val: &str) -> Result<()>

Sets the transformation of the message to be dequeued.

The transformation is applied after the message is dequeued but before it is returned to the application. It must be created using DBMS_TRANSFORM.

source

pub fn set_visibility(&mut self, val: &Visibility) -> Result<()>

Sets whether the message being dequeued is part of the current transaction or constitutes a transaction on its own.

source

pub fn set_wait(&mut self, val: &Duration) -> Result<()>

Set the time to wait for a message matching the search criteria.

Trait Implementations§

source§

impl Debug for DeqOptions

source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

source§

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

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

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

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

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

source§

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

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

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

source§

fn into(self) -> U

Calls U::from(self).

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

source§

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

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

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.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.