Struct MessageConst

Source
pub struct MessageConst;

Implementations§

Source§

impl MessageConst

Source

pub const DUP_INFO: &'static str = "DUP_INFO"

Source

pub const KEY_SEPARATOR: &'static str = " "

Source

pub const PROPERTY_BORN_HOST: &'static str = "__BORNHOST"

Source

pub const PROPERTY_BORN_TIMESTAMP: &'static str = "BORN_TIMESTAMP"

Source

pub const PROPERTY_BUYER_ID: &'static str = "BUYER_ID"

Source

pub const PROPERTY_CHECK_IMMUNITY_TIME_IN_SECONDS: &'static str = "CHECK_IMMUNITY_TIME_IN_SECONDS"

Source

pub const PROPERTY_CLUSTER: &'static str = "CLUSTER"

Source

pub const PROPERTY_CONSUME_START_TIMESTAMP: &'static str = "CONSUME_START_TIME"

Source

pub const PROPERTY_CORRECTION_FLAG: &'static str = "CORRECTION_FLAG"

Source

pub const PROPERTY_CORRELATION_ID: &'static str = "CORRELATION_ID"

Source

pub const PROPERTY_CRC32: &'static str = "__CRC32#"

Source

pub const PROPERTY_DELAY_TIME_LEVEL: &'static str = "DELAY"

Source

pub const PROPERTY_DLQ_ORIGIN_MESSAGE_ID: &'static str = "DLQ_ORIGIN_MESSAGE_ID"

Source

pub const PROPERTY_STARTDE_LIVER_TIME: &'static str = "__STARTDELIVERTIME"

Source

pub const PROPERTY_DLQ_ORIGIN_TOPIC: &'static str = "DLQ_ORIGIN_TOPIC"

properties for DLQ

Source

pub const PROPERTY_EXTEND_UNIQ_INFO: &'static str = "EXTEND_UNIQ_INFO"

Source

pub const PROPERTY_FIRST_POP_TIME: &'static str = "1ST_POP_TIME"

Source

pub const PROPERTY_FORWARD_QUEUE_ID: &'static str = "PROPERTY_FORWARD_QUEUE_ID"

Source

pub const PROPERTY_INNER_BASE: &'static str = "INNER_BASE"

Source

pub const PROPERTY_INNER_MULTI_DISPATCH: &'static str = "INNER_MULTI_DISPATCH"

Source

pub const PROPERTY_INNER_MULTI_QUEUE_OFFSET: &'static str = "INNER_MULTI_QUEUE_OFFSET"

Source

pub const PROPERTY_INNER_NUM: &'static str = "INNER_NUM"

Source

pub const PROPERTY_INSTANCE_ID: &'static str = "INSTANCE_ID"

Source

pub const PROPERTY_KEYS: &'static str = "KEYS"

Source

pub const PROPERTY_MAX_OFFSET: &'static str = "MAX_OFFSET"

Source

pub const PROPERTY_MAX_RECONSUME_TIMES: &'static str = "MAX_RECONSUME_TIMES"

Source

pub const PROPERTY_MESSAGE_REPLY_TO_CLIENT: &'static str = "REPLY_TO_CLIENT"

Source

pub const PROPERTY_MESSAGE_TTL: &'static str = "TTL"

Source

pub const PROPERTY_MESSAGE_TYPE: &'static str = "MSG_TYPE"

Source

pub const PROPERTY_MIN_OFFSET: &'static str = "MIN_OFFSET"

Source

pub const PROPERTY_MQ2_FLAG: &'static str = "MQ2_FLAG"

Source

pub const PROPERTY_MSG_REGION: &'static str = "MSG_REGION"

Source

pub const PROPERTY_ORIGIN_MESSAGE_ID: &'static str = "ORIGIN_MESSAGE_ID"

Source

pub const PROPERTY_POP_CK: &'static str = "POP_CK"

Source

pub const PROPERTY_POP_CK_OFFSET: &'static str = "POP_CK_OFFSET"

Source

pub const PROPERTY_PRODUCER_GROUP: &'static str = "PGROUP"

Source

pub const PROPERTY_PUSH_REPLY_TIME: &'static str = "PUSH_REPLY_TIME"

Source

pub const PROPERTY_REAL_QUEUE_ID: &'static str = "REAL_QID"

Source

pub const PROPERTY_REAL_TOPIC: &'static str = "REAL_TOPIC"

Source

pub const PROPERTY_RECONSUME_TIME: &'static str = "RECONSUME_TIME"

Source

pub const PROPERTY_REDIRECT: &'static str = "REDIRECT"

Source

pub const PROPERTY_REPLY_MESSAGE_ARRIVE_TIME: &'static str = "ARRIVE_TIME"

Source

pub const PROPERTY_RETRY_TOPIC: &'static str = "RETRY_TOPIC"

Source

pub const PROPERTY_SHARDING_KEY: &'static str = "__SHARDINGKEY"

Source

pub const PROPERTY_TAGS: &'static str = "TAGS"

Source

pub const PROPERTY_TIMER_DELAY_LEVEL: &'static str = "TIMER_DELAY_LEVEL"

Source

pub const PROPERTY_TIMER_DELAY_MS: &'static str = "TIMER_DELAY_MS"

Source

pub const PROPERTY_TIMER_DELAY_SEC: &'static str = "TIMER_DELAY_SEC"

Source

pub const PROPERTY_TIMER_DELIVER_MS: &'static str = "TIMER_DELIVER_MS"

Source

pub const PROPERTY_TIMER_DEL_UNIQKEY: &'static str = "TIMER_DEL_UNIQKEY"

Source

pub const PROPERTY_TIMER_DEQUEUE_MS: &'static str = "TIMER_DEQUEUE_MS"

Source

pub const PROPERTY_TIMER_ENQUEUE_MS: &'static str = "TIMER_ENQUEUE_MS"

Source

pub const PROPERTY_TIMER_OUT_MS: &'static str = "TIMER_OUT_MS"

Source

pub const PROPERTY_TIMER_ROLL_TIMES: &'static str = "TIMER_ROLL_TIMES"

Source

pub const PROPERTY_TRACE_CONTEXT: &'static str = "TRACE_CONTEXT"

Source

pub const PROPERTY_TRACE_SWITCH: &'static str = "TRACE_ON"

Source

pub const PROPERTY_TRANSACTION_CHECK_TIMES: &'static str = "TRANSACTION_CHECK_TIMES"

Source

pub const PROPERTY_TRANSACTION_ID: &'static str = "__transactionId__"

Source

pub const PROPERTY_TRANSACTION_PREPARED: &'static str = "TRAN_MSG"

Source

pub const PROPERTY_TRANSACTION_PREPARED_QUEUE_OFFSET: &'static str = "TRAN_PREPARED_QUEUE_OFFSET"

Source

pub const PROPERTY_TRANSFER_FLAG: &'static str = "TRANSFER_FLAG"

Source

pub const PROPERTY_TRANSIENT_GROUP_CONFIG: &'static str = "__RMQ.TRANSIENT.GROUP_SYS_FLAG"

the transient property key of groupSysFlag (set by the client when pulling messages)

Source

pub const PROPERTY_TRANSIENT_PREFIX: &'static str = "__RMQ.TRANSIENT."

property which name starts with “__RMQ.TRANSIENT.” is called transient one that will not be stored in broker disks.

Source

pub const PROPERTY_TRANSIENT_TOPIC_CONFIG: &'static str = "__RMQ.TRANSIENT.TOPIC_SYS_FLAG"

the transient property key of topicSysFlag (set by the client when pulling messages)

Source

pub const PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX: &'static str = "UNIQ_KEY"

Source

pub const PROPERTY_WAIT_STORE_MSG_OK: &'static str = "WAIT"

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> Instrument for T

Source§

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

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

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
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>,

Source§

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>,

Source§

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

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

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
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

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

impl<T> ErasedDestructor for T
where T: 'static,

Source§

impl<T> MaybeSendSync for T