pub struct QueueMessageData {
pub payload: Value,
pub priority: Option<i32>,
pub enqueued_at_ns: u64,
pub attempts: u32,
pub max_attempts: u32,
pub acked: bool,
}Expand description
Queue message data
Fields§
§payload: ValueMessage payload
priority: Option<i32>Optional priority (higher = more urgent)
enqueued_at_ns: u64Enqueue timestamp (nanoseconds)
attempts: u32Number of delivery attempts
max_attempts: u32Maximum delivery attempts before DLQ
acked: boolWhether the message has been acknowledged
Trait Implementations§
Source§impl Clone for QueueMessageData
impl Clone for QueueMessageData
Auto Trait Implementations§
impl Freeze for QueueMessageData
impl RefUnwindSafe for QueueMessageData
impl Send for QueueMessageData
impl Sync for QueueMessageData
impl Unpin for QueueMessageData
impl UnsafeUnpin for QueueMessageData
impl UnwindSafe for QueueMessageData
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