List of all items

Structs

• allocation::AllocateMessageQueueAveragely
• allocation::AllocateMessageQueueAveragelyByCircle
• allocation::AllocateMessageQueueByConfig
• allocation::AllocateMessageQueueByMachineRoom
• allocation::AllocateMessageQueueByMachineRoomNearby
• allocation::AllocateMessageQueueConsistentHash
• common::FAQUrl
• common::Pair
• common::attribute::AttributeBase
• common::attribute::attribute_parser::AttributeParser
• common::attribute::attribute_util::AttributeUtil
• common::attribute::bool_attribute::BooleanAttribute
• common::attribute::enum_attribute::EnumAttribute
• common::attribute::long_range_attribute::LongRangeAttribute
• common::attribute::string_attribute::StringAttribute
• common::attribute::subscription_group_attributes::SubscriptionGroupAttributes
• common::attribute::topic_attributes::TopicAttributes
• common::base::plain_access_config::PlainAccessConfig
• common::broker::broker_identity::BrokerIdentity
• common::chain::HandlerChain
• common::coldctr::acc_and_time_stamp::AccAndTimeStamp
• common::constant::PermName
• common::constant::consume_init_mode::ConsumeInitMode
• common::consumer::receipt_handle::ReceiptHandle
• common::consumer::receipt_handle::ReceiptHandleBuilder
• common::entity::ClientGroup
• common::entity::TopicGroup
• common::filter::expression_type::ExpressionType
• common::filter::filter_context::FilterContext
• common::filter::op::OpBase
• common::filter::operand::Operand
• common::filter::operator::Operator
• common::hasher::string_hasher::JavaStringHasher
• common::key_builder::KeyBuilder
• common::lite::LiteLagInfo
• common::lite::LiteSubscription
• common::lite::LiteSubscriptionDTO
• common::lite::OffsetOption
• common::message::MessageConst
• common::message::broker_message::BrokerMessage
• common::message::message_accessor::MessageAccessor
• common::message::message_batch::MessageBatch
• common::message::message_batch::MessageExtBatch
• common::message::message_batch_v2::MessageBatchV2
• common::message::message_body::MessageBody
• common::message::message_builder::MessageBuilder
• common::message::message_client_ext::MessageClientExt
• common::message::message_client_id_setter::MessageClientIDSetter
• common::message::message_envelope::MessageEnvelope
• common::message::message_ext::MessageExt
• common::message::message_ext_broker_inner::MessageExtBrokerInner
• common::message::message_flag::MessageFlag
• common::message::message_id::MessageId
• common::message::message_property::MessageProperties
• common::message::message_queue_assignment::MessageQueueAssignment
• common::message::message_queue_for_c::MessageQueueForC
• common::message::message_single::Message
• common::message::routing_context::RoutingContext
• common::message::storage_metadata::StorageMetadata
• common::message::timer_request::NormalizedTimerRequest
• common::message::timer_request::TimerPolicySnapshot
• common::pop_ack_constants::PopAckConstants
• common::pop_retry_policy::PopRetryPolicy
• common::producer::recall_message_handle::HandleV1
• common::sys_flag::message_sys_flag::MessageSysFlag
• common::sys_flag::pull_sys_flag::PullSysFlag
• common::tools::broker_operator_result::BrokerOperatorResult
• common::tools::message_track::MessageTrack
• common::topic::TopicValidator
• common::topic::ValidateTopicResult
• consistent_hash::ConsistentHashRouter
• consistent_hash::MD5Hash
• consistent_hash::VirtualNode
• message::MessageQueue
• result::PullOutcome
• result::QueryResult
• result::SendResult
• topic::TopicConfig
• utils::correlation_id_util::CorrelationIdUtil
• utils::data_converter::DataConverter
• utils::env_utils::EnvUtils
• utils::queue_type_utils::QueueTypeUtils
• utils::serde_json_utils::SerdeJsonUtils
• utils::string_utils::StringUtils

Enums

• ModelContractViolation
• boundary_type::BoundaryType
• common::attribute::cleanup_policy::CleanupPolicy
• common::attribute::cq_type::CQType
• common::base::service_state::ServiceState
• common::broker::broker_role::BrokerRole
• common::compression::compression_type::CompressionType
• common::consumer::consume_from_where::ConsumeFromWhere
• common::filter::filter_type::FilterType
• common::lite::LiteSubscriptionAction
• common::lite::OffsetOptionType
• common::message::MessageVersion
• common::message::message_enum::MessageRequestMode
• common::message::message_enum::MessageType
• common::message::message_property::MessagePropertyKey
• common::message::timer_request::TimerRequestKind
• common::pop_retry_policy::PopRetryMigrationState
• common::pop_retry_policy::PopRetryPolicyOutcome
• common::pop_retry_policy::PopRetryTopicVersion
• common::producer::recall_message_handle::RecallMessageHandle
• common::running::running_stats::RunningStats
• common::tools::track_type::TrackType
• result::PullStatus
• result::SendStatus
• topic::TopicFilterType
• topic::TopicMessageType
• version::RocketMqVersion

Traits

• allocation::AllocateMessageQueueStrategy
• allocation::MachineRoomResolver
• common::attribute::Attribute
• common::chain::handler::Handler
• common::filter::op::Op
• common::message::MessageTrait
• consistent_hash::HashFunction
• consistent_hash::Node

Macros

• hashset

Functions

• allocation::check
• codec::bytes_to_string
• codec::message_properties_to_string
• codec::string_to_bytes
• codec::string_to_message_properties
• codec::write_int
• codec::write_short
• common::message::message_client_id_setter::create_fake_ip
• common::message::message_single::parse_topic_filter_type
• common::message::message_single::tags_string2tags_code
• common::message::timer_request::normalize_timer_request
• common::message::timer_request::normalize_timer_request_fields
• common::mix_all::broker_vip_channel
• common::mix_all::get_dlq_topic
• common::mix_all::get_reply_topic
• common::mix_all::get_retry_topic
• common::mix_all::get_ws_addr
• common::mix_all::human_readable_byte_count
• common::mix_all::is_lmq
• common::mix_all::is_sys_consumer_group
• common::mix_all::is_sys_consumer_group_for_no_cold_read_limit
• common::mix_all::properties_to_string
• common::mix_all::string_to_properties
• common::sys_flag::topic_sys_flag::build_sys_flag
• common::sys_flag::topic_sys_flag::clear_unit_flag
• common::sys_flag::topic_sys_flag::clear_unit_sub_flag
• common::sys_flag::topic_sys_flag::has_unit_flag
• common::sys_flag::topic_sys_flag::has_unit_sub_flag
• common::sys_flag::topic_sys_flag::set_unit_flag
• common::sys_flag::topic_sys_flag::set_unit_sub_flag
• lite::belongs_to
• lite::get_lite_topic
• lite::get_parent_and_lite_topic
• lite::get_parent_topic
• lite::is_lite_topic_queue
• lite::to_lmq_name
• time::current_millis
• topic::is_system_topic
• utils::cleanup_policy_utils::get_delete_policy
• utils::cleanup_policy_utils::get_delete_policy_arc_mut
• utils::cleanup_policy_utils::is_compaction
• utils::crc32_utils::crc32
• utils::crc32_utils::crc32_bytebuffer
• utils::crc32_utils::crc32_bytebuffers
• utils::crc32_utils::crc32_bytes
• utils::crc32_utils::crc32_bytes_offset
• utils::crc32_utils::crc32_range
• utils::message_utils::build_batch_message_id
• utils::message_utils::build_message_id
• utils::message_utils::delete_property
• utils::message_utils::delete_property_to_cheetah_string
• utils::message_utils::delete_property_v2
• utils::message_utils::get_sharding_key_index
• utils::message_utils::get_sharding_key_index_by_msg
• utils::message_utils::get_sharding_key_indexes
• utils::message_utils::parse_message_id
• utils::message_utils::socket_address_to_vec
• version::value2version

Type Aliases

• allocation::AbstractAllocateMessageQueueStrategy
• allocation::AllocateMachineRoomNearby

Statics

• common::message::STRING_HASH_SET
• common::mix_all::MULTI_PATH_SPLITTER

Constants

• codec::NAME_VALUE_SEPARATOR
• codec::PROPERTY_SEPARATOR
• common::attribute::subscription_group_attributes::LITE_BIND_TOPIC_ATTRIBUTE_NAME
• common::attribute::subscription_group_attributes::LITE_SUB_CLIENT_MAX_EVENT_COUNT_ATTRIBUTE_NAME
• common::attribute::subscription_group_attributes::LITE_SUB_CLIENT_QUOTA_ATTRIBUTE_NAME
• common::attribute::subscription_group_attributes::LITE_SUB_MODEL_ATTRIBUTE_NAME
• common::attribute::subscription_group_attributes::LITE_SUB_RESET_OFFSET_EXCLUSIVE_ATTRIBUTE_NAME
• common::attribute::subscription_group_attributes::LITE_SUB_RESET_OFFSET_UNSUBSCRIBE_ATTRIBUTE_NAME
• common::attribute::subscription_group_attributes::LITE_SUB_WILDCARD_ATTRIBUTE_NAME
• common::attribute::subscription_group_attributes::PRIORITY_FACTOR_ATTRIBUTE_NAME
• common::constant::common_constants::ASTERISK
• common::constant::common_constants::COLON
• common::constant::common_constants::COMMA
• common::constant::common_constants::EQUAL
• common::constant::common_constants::HYPHEN
• common::constant::common_constants::POUND
• common::constant::common_constants::SLASH
• common::constant::common_constants::SPACE
• common::constant::db_msg_constants::MAX_BODY_SIZE
• common::constant::file_readahead_mode::READ_AHEAD_MODE
• common::constant::ha_proxy_constants::CHANNEL_ID
• common::constant::ha_proxy_constants::PROXY_PROTOCOL_ADDR
• common::constant::ha_proxy_constants::PROXY_PROTOCOL_PORT
• common::constant::ha_proxy_constants::PROXY_PROTOCOL_PREFIX
• common::constant::ha_proxy_constants::PROXY_PROTOCOL_SERVER_ADDR
• common::constant::ha_proxy_constants::PROXY_PROTOCOL_SERVER_PORT
• common::constant::ha_proxy_constants::PROXY_PROTOCOL_TLV_PREFIX
• common::consumer::receipt_handle::NORMAL_TOPIC
• common::consumer::receipt_handle::RETRY_TOPIC
• common::consumer::receipt_handle::RETRY_TOPIC_V2
• common::key_builder::POP_ORDER_REVIVE_QUEUE
• common::key_builder::POP_RETRY_REGEX_SEPARATOR_V2
• common::key_builder::POP_RETRY_SEPARATOR_V1
• common::key_builder::POP_RETRY_SEPARATOR_V2
• common::message::MESSAGE_MAGIC_CODE_V1
• common::message::MESSAGE_MAGIC_CODE_V2
• common::message::timer_request::JAVA_COMPAT_TIMER_PRECISIONS_MS
• common::mix_all::ACL_CONF_TOOLS_FILE
• common::mix_all::ALL_ACK_IN_SYNC_STATE_SET
• common::mix_all::CID_ONSAPI_OWNER_GROUP
• common::mix_all::CID_ONSAPI_PERMISSION_GROUP
• common::mix_all::CID_ONSAPI_PULL_GROUP
• common::mix_all::CID_RMQ_SYS_PREFIX
• common::mix_all::CID_SYS_RMQ_TRANS
• common::mix_all::CLIENT_INNER_PRODUCER_GROUP
• common::mix_all::CONSUME_CONTEXT_TYPE
• common::mix_all::DEFAULT_CHARSET
• common::mix_all::DEFAULT_CONSUMER_GROUP
• common::mix_all::DEFAULT_NAMESRV_ADDR_LOOKUP
• common::mix_all::DEFAULT_PRODUCER_GROUP
• common::mix_all::DEFAULT_TRACE_REGION_ID
• common::mix_all::DLQ_GROUP_TOPIC_PREFIX
• common::mix_all::FILTERSRV_CONSUMER_GROUP
• common::mix_all::FIRST_BROKER_CONTROLLER_ID
• common::mix_all::FIRST_SLAVE_ID
• common::mix_all::IS_SUB_CHANGE
• common::mix_all::IS_SUPPORT_HEART_BEAT_V2
• common::mix_all::LEGACY_NAMESRV_ADDR_PROPERTY
• common::mix_all::LMQ_PREFIX
• common::mix_all::LMQ_QUEUE_ID
• common::mix_all::LOGICAL_QUEUE_MOCK_BROKER_NAME_NOT_EXIST
• common::mix_all::LOGICAL_QUEUE_MOCK_BROKER_PREFIX
• common::mix_all::MASTER_ID
• common::mix_all::MESSAGE_COMPRESS_LEVEL
• common::mix_all::MESSAGE_COMPRESS_TYPE
• common::mix_all::METADATA_SCOPE_GLOBAL
• common::mix_all::MONITOR_CONSUMER_GROUP
• common::mix_all::MULTI_DISPATCH_QUEUE_SPLITTER
• common::mix_all::NAMESRV_ADDR_ENV
• common::mix_all::NAMESRV_ADDR_PROPERTY
• common::mix_all::ONS_HTTP_PROXY_GROUP
• common::mix_all::REPLY_MESSAGE_FLAG
• common::mix_all::REPLY_TOPIC_POSTFIX
• common::mix_all::REQ_T
• common::mix_all::RETRY_GROUP_TOPIC_PREFIX
• common::mix_all::ROCKETMQ_HOME_ENV
• common::mix_all::ROCKETMQ_HOME_PROPERTY
• common::mix_all::ROCKETMQ_ZONE_ENV
• common::mix_all::ROCKETMQ_ZONE_MODE_ENV
• common::mix_all::ROCKETMQ_ZONE_MODE_PROPERTY
• common::mix_all::ROCKETMQ_ZONE_PROPERTY
• common::mix_all::RPC_REQUEST_HEADER_NAMESPACED_FIELD
• common::mix_all::RPC_REQUEST_HEADER_NAMESPACE_FIELD
• common::mix_all::SCHEDULE_CONSUMER_GROUP
• common::mix_all::SELF_TEST_CONSUMER_GROUP
• common::mix_all::SELF_TEST_PRODUCER_GROUP
• common::mix_all::TOOLS_CONSUMER_GROUP
• common::mix_all::UNIQUE_MSG_QUERY_FLAG
• common::mix_all::UNIT_PRE_SIZE_FOR_MSG
• common::mix_all::WS_DOMAIN_NAME
• common::mix_all::ZONE_MODE
• common::mix_all::ZONE_NAME
• common::topic::TOPIC_MAX_LENGTH
• lite::LITE_TOPIC_PREFIX
• lite::SEPARATOR
• topic::DLQ_GROUP_TOPIC_PREFIX
• topic::RETRY_GROUP_TOPIC_PREFIX
• topic::SYSTEM_TOPICS
• topic::SYSTEM_TOPIC_PREFIX
• version::CURRENT_VERSION