Struct rocketmq_common::common::message::MessageConst

source ·
pub struct MessageConst;

Implementations§

source§

impl MessageConst

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

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_REPLY_MESSAGE_ARRIVE_TIME: &'static str = "ARRIVE_TIME"

source

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

source

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

source

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

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_FIRST_POP_TIME: &'static str = "1ST_POP_TIME"

source

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

source

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

source

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

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_TRACE_CONTEXT: &'static str = "TRACE_CONTEXT"

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_BORN_HOST: &'static str = "__BORNHOST"

source

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

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_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 KEY_SEPARATOR: &'static str = " "

source

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

source

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

source

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

source

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

source

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

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_CRC32: &'static str = "__CRC32#"

source

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

properties for DLQ

source

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

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

§

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