List of all items

Structs

• connection::MqConnection
• consumer::pull_consumer_v2::PullConsumer
• producer::Producer
• protocols::ConvertUtil
• protocols::PermName
• protocols::body::broker_data::BrokerData
• protocols::body::cluster_info::ClusterInfo
• protocols::body::consumer_data::ConsumerData
• protocols::body::consumer_running_info::ConsumerRunningInfo
• protocols::body::consumer_running_info::ProcessQueueInfo
• protocols::body::get_consumer_list_by_group_response_body::GetConsumerListByGroupResponseBody
• protocols::body::get_consumer_status_body::GetConsumerStatusBody
• protocols::body::heartbeat_data::HeartbeatData
• protocols::body::message_body::MessageBody
• protocols::body::message_queue::MessageQueue
• protocols::body::mq_message::MqMessage
• protocols::body::producer_data::ProducerData
• protocols::body::queue_data::QueueData
• protocols::body::subscription_data::SubscriptionData
• protocols::body::topic_route_data::TopicRouteData
• protocols::header::get_consumer_list_by_group_request_header::GetConsumerListByGroupRequestHeader
• protocols::header::get_consumer_running_info_requestheader::GetConsumerRunningInfoRequestHeader
• protocols::header::get_consumer_status_request_header::GetConsumerStatusRequestHeader
• protocols::header::get_max_offset_request_header::GetMaxOffsetRequestHeader
• protocols::header::get_max_offset_response_header::GetMaxOffsetResponseHeader
• protocols::header::get_route_info_request_header::GetRouteInfoRequestHeader
• protocols::header::notify_consumer_ids_changed_request_header::NotifyConsumerIdsChangedRequestHeader
• protocols::header::pull_message_request_header::PullMessageRequestHeader
• protocols::header::pull_message_response_header::PullMessageResponseHeader
• protocols::header::query_consumer_offset_request_header::QueryConsumerOffsetRequestHeader
• protocols::header::query_consumer_offset_response_header::QueryConsumerOffsetResponseHeader
• protocols::header::send_message_request_header::SendMessageRequestHeader
• protocols::header::send_message_request_header::SendMessageRequestHeaderV2
• protocols::header::update_consumer_offset_request_header::UpdateConsumerOffsetRequestHeader
• protocols::mq_command::MqCommand
• protocols::mq_command::RemotingCommand

Traits

• consumer::message_handler::MessageHandler
• protocols::SerializeDeserialize

Functions

• connection::get_client_ip
• protocols::fixed_un_standard_json
• protocols::get_current_time_millis
• protocols::sleep

Constants

• protocols::body::consumer_data::CONSUME_FROM_FIRST_OFFSET
• protocols::body::consumer_data::CONSUME_FROM_LAST_OFFSET
• protocols::body::consumer_data::CONSUME_FROM_TIMESTAMP
• protocols::body::consumer_data::CONSUME_TYPE_PULL
• protocols::body::consumer_data::CONSUME_TYPE_PUSH
• protocols::body::consumer_data::MESSAGE_MODEL_BROADCAST
• protocols::body::consumer_data::MESSAGE_MODEL_CLUSTER
• protocols::mq_command::HEADER_SERIALIZE_METHOD_JSON
• protocols::mq_command::HEADER_SERIALIZE_METHOD_PRIVATE
• protocols::mq_command::VERSION_FLAG
• protocols::request_code::ADJUST_CONSUMER_THREAD_POOL
• protocols::request_code::CHECK_CLIENT_CONFIG
• protocols::request_code::CHECK_TRANSACTION_STATE
• protocols::request_code::CLEAN_EXPIRED_CONSUME_QUEUE
• protocols::request_code::CLEAN_UNUSED_TOPIC
• protocols::request_code::CLONE_GROUP_OFFSET
• protocols::request_code::CONSUMER_SEND_MSG_BACK
• protocols::request_code::CONSUME_MESSAGE_DIRECTLY
• protocols::request_code::DELETE_KV_CONFIG
• protocols::request_code::DELETE_SUBSCRIPTION_GROUP
• protocols::request_code::DELETE_TOPIC_IN_BROKER
• protocols::request_code::DELETE_TOPIC_IN_NAME_SRV
• protocols::request_code::END_TRANSACTION
• protocols::request_code::GET_ALL_CONSUMER_OFFSET
• protocols::request_code::GET_ALL_DELAY_OFFSET
• protocols::request_code::GET_ALL_SUBSCRIPTION_GROUP_CONFIG
• protocols::request_code::GET_ALL_TOPIC_CONFIG
• protocols::request_code::GET_ALL_TOPIC_LIST_FROM_NAMESERVER
• protocols::request_code::GET_BROKER_CLUSTER_INFO
• protocols::request_code::GET_BROKER_CONFIG
• protocols::request_code::GET_BROKER_CONSUME_STATS
• protocols::request_code::GET_BROKER_RUNTIME_INFO
• protocols::request_code::GET_CONSUMER_CONNECTION_LIST
• protocols::request_code::GET_CONSUMER_LIST_BY_GROUP
• protocols::request_code::GET_CONSUMER_RUNNING_INFO
• protocols::request_code::GET_CONSUMER_STATUS_FROM_CLIENT
• protocols::request_code::GET_CONSUME_STATS
• protocols::request_code::GET_EARLIEST_MSG_STORE_TIME
• protocols::request_code::GET_HAS_UNIT_SUB_TOPIC_LIST
• protocols::request_code::GET_HAS_UNIT_SUB_UN_UNIT_TOPIC_LIST
• protocols::request_code::GET_KV_CONFIG
• protocols::request_code::GET_KV_LIST_BY_NAMESPACE
• protocols::request_code::GET_MAX_OFFSET
• protocols::request_code::GET_MIN_OFFSET
• protocols::request_code::GET_NAME_SRV_CONFIG
• protocols::request_code::GET_PRODUCER_CONNECTION_LIST
• protocols::request_code::GET_ROUTE_BY_TOPIC
• protocols::request_code::GET_SYSTEM_TOPIC_LIST_FROM_BROKER
• protocols::request_code::GET_SYSTEM_TOPIC_LIST_FROM_NS
• protocols::request_code::GET_TOPICS_BY_CLUSTER
• protocols::request_code::GET_TOPIC_CONFIG_LIST
• protocols::request_code::GET_TOPIC_NAME_LIST
• protocols::request_code::GET_TOPIC_STATS_INFO
• protocols::request_code::GET_UNIT_TOPIC_LIST
• protocols::request_code::HEART_BEAT
• protocols::request_code::INVOKE_BROKER_TO_GET_CONSUMER_STATUS
• protocols::request_code::INVOKE_BROKER_TO_RESET_OFFSET
• protocols::request_code::LOCK_BATCH_MQ
• protocols::request_code::NOTIFY_CONSUMER_IDS_CHANGED
• protocols::request_code::PULL_MESSAGE
• protocols::request_code::PUT_KV_CONFIG
• protocols::request_code::QUERY_BROKER_OFFSET
• protocols::request_code::QUERY_CONSUMER_OFFSET
• protocols::request_code::QUERY_CONSUME_QUEUE
• protocols::request_code::QUERY_CONSUME_TIME_SPAN
• protocols::request_code::QUERY_CORRECTION_OFFSET
• protocols::request_code::QUERY_DATA_VERSION
• protocols::request_code::QUERY_MESSAGE
• protocols::request_code::QUERY_TOPIC_CONSUME_BY_WHO
• protocols::request_code::REGISTER_BROKER
• protocols::request_code::REGISTER_FILTER_SERVER
• protocols::request_code::REGISTER_MESSAGE_FILTER_CLASS
• protocols::request_code::RESET_CONSUMER_CLIENT_OFFSET
• protocols::request_code::RESET_CONSUMER_OFFSET_IN_BROKER
• protocols::request_code::RESET_CONSUMER_OFFSET_IN_CONSUMER
• protocols::request_code::RESUME_CONSUMER
• protocols::request_code::SEARCH_OFFSET_BY_TIMESTAMP
• protocols::request_code::SEND_BATCH_MESSAGE
• protocols::request_code::SEND_MESSAGE
• protocols::request_code::SEND_MESSAGE_V2
• protocols::request_code::SUSPEND_CONSUMER
• protocols::request_code::TRIGGER_DELETE_FILES
• protocols::request_code::UNLOCK_BATCH_MQ
• protocols::request_code::UNREGISTER_BROKER
• protocols::request_code::UNREGISTER_CLIENT
• protocols::request_code::UPDATE_AND_CREATE_SUBSCRIPTION_GROUP
• protocols::request_code::UPDATE_AND_CREATE_TOPIC
• protocols::request_code::UPDATE_BROKER_CONFIG
• protocols::request_code::UPDATE_CONSUMER_OFFSET
• protocols::request_code::UPDATE_NAME_SRV_CONFIG
• protocols::request_code::VIEW_BROKER_STATS_DATA
• protocols::request_code::VIEW_MESSAGE_BY_ID
• protocols::request_code::WHO_CONSUME_THE_MESSAGE
• protocols::request_code::WIPE_WRITE_PERM_OF_BROKER
• protocols::response_code::CONSUMER_NOT_ONLINE
• protocols::response_code::CONSUME_MSG_TIMEOUT
• protocols::response_code::FILTER_DATA_NOT_EXIST
• protocols::response_code::FILTER_DATA_NOT_LATEST
• protocols::response_code::FLUSH_DISK_TIMEOUT
• protocols::response_code::FLUSH_SLAVE_TIMEOUT
• protocols::response_code::MESSAGE_ILLEGAL
• protocols::response_code::NOT_IN_CURRENT_UNIT
• protocols::response_code::NO_BUYER_ID
• protocols::response_code::NO_MESSAGE
• protocols::response_code::NO_PERMISSION
• protocols::response_code::PULL_NOT_FOUND
• protocols::response_code::PULL_OFFSET_MOVED
• protocols::response_code::PULL_RETRY_IMMEDIATELY
• protocols::response_code::QUERY_NOT_FOUND
• protocols::response_code::REQUEST_CODE_NOT_SUPPORTED
• protocols::response_code::SERVICE_NOT_AVAILABLE
• protocols::response_code::SLAVE_NOT_AVAILABLE
• protocols::response_code::SUBSCRIPTION_GROUP_NOT_EXIST
• protocols::response_code::SUBSCRIPTION_NOT_EXIST
• protocols::response_code::SUBSCRIPTION_NOT_LATEST
• protocols::response_code::SUBSCRIPTION_PARSE_FAILED
• protocols::response_code::SUCCESS
• protocols::response_code::SYSTEM_BUSY
• protocols::response_code::SYSTEM_ERROR
• protocols::response_code::TOPIC_EXIST_ALREADY
• protocols::response_code::TOPIC_NOT_EXIST
• protocols::response_code::TRANSACTION_FAILED
• protocols::response_code::TRANSACTION_SHOULD_COMMIT
• protocols::response_code::TRANSACTION_SHOULD_ROLLBACK
• protocols::response_code::TRANSACTION_STATE_GROUP_WRONG
• protocols::response_code::TRANSACTION_STATE_UNKNOWN
• protocols::response_code::VERSION_NOT_SUPPORTED