List of all items

Structs

• AsyncTraceDispatcher
• ConsumeMessageContext
• MQClientAPIFactory
• PullResultExt
• TraceDataEncoder
• admin::default_mq_admin_ext::DefaultMQAdminExt
• admin::default_mq_admin_ext_impl::DefaultMQAdminExtImpl
• admin::mq_admin_ext_async_inner::MQAdminExtInnerImpl
• base::client_config::ClientConfig
• base::client_config_builder::ClientConfigBuilder
• base::client_config_validation::ClientConfigValidator
• base::query_result::QueryResult
• base::validators::Validators
• common::acl::AclConstants
• common::acl::AclSigner
• common::acl::AclUtils
• common::acl::Permission
• common::acl_client_rpc_hook::AclClientRPCHook
• common::admin_tool_result::AdminToolResult
• common::client_error_code::ClientErrorCode
• common::nameserver_access_config::NameserverAccessConfig
• common::session_credentials::SessionCredentials
• common::thread_local_index::ThreadLocalIndex
• consumer::ack_result::AckResult
• consumer::consumer_impl::consume_message_service::ConsumeMessagePopServiceGeneral
• consumer::consumer_impl::consume_message_service::ConsumeMessageServiceGeneral
• consumer::consumer_impl::pop_process_queue::PopProcessQueue
• consumer::consumer_impl::process_queue::ProcessQueue
• consumer::consumer_impl::pull_message_service::PullMessageService
• consumer::consumer_impl::pull_request::PullRequest
• consumer::default_lite_pull_consumer::DefaultLitePullConsumer
• consumer::default_lite_pull_consumer_builder::DefaultLitePullConsumerBuilder
• consumer::default_mq_push_consumer::ConsumerConfig
• consumer::default_mq_push_consumer::DefaultMQPushConsumer
• consumer::default_mq_push_consumer_builder::DefaultMQPushConsumerBuilder
• consumer::listener::consume_concurrently_context::ConsumeConcurrentlyContext
• consumer::listener::consume_orderly_context::ConsumeOrderlyContext
• consumer::listener::message_listener::MessageListener
• consumer::message_queue_lock::MessageQueueLock
• consumer::message_selector::MessageSelector
• consumer::mq_consumer_inner::MQConsumerInnerImpl
• consumer::notify_result::NotifyResult
• consumer::pop_callback::DefaultPopCallback
• consumer::pop_result::PopResult
• consumer::pull_result::PullResult
• consumer::rebalance_strategy::allocate_message_queue_averagely::AllocateMessageQueueAveragely
• consumer::rebalance_strategy::allocate_message_queue_averagely_by_circle::AllocateMessageQueueAveragelyByCircle
• consumer::rebalance_strategy::allocate_message_queue_by_config::AllocateMessageQueueByConfig
• consumer::rebalance_strategy::allocate_message_queue_by_machine_room::AllocateMessageQueueByMachineRoom
• consumer::rebalance_strategy::allocate_message_queue_by_machine_room_nearby::AllocateMessageQueueByMachineRoomNearby
• consumer::rebalance_strategy::allocate_message_queue_consistent_hash::AllocateMessageQueueConsistentHash
• consumer::store::ControllableOffset
• consumer::store::OffsetSerialize
• consumer::store::OffsetSerializeWrapper
• consumer::store::local_file_offset_store::LocalFileOffsetStore
• consumer::store::remote_broker_offset_store::RemoteBrokerOffsetStore
• exception::MQBrokerException
• exception::MQClientException
• exception::OffsetNotFoundException
• exception::RequestTimeoutException
• factory::mq_client_instance::MQClientInstance
• implementation::mq_client_manager::MQClientManager
• latency::BrokerFilter
• latency::MQFaultStrategy
• legacy::ConsumeMessageOpenTracingHookImpl
• legacy::ConsumeRequest
• legacy::DefaultMQPullConsumer
• legacy::DefaultMQPullConsumerImpl
• legacy::DoNothingClientRemotingProcessor
• legacy::EndTransactionOpenTracingHookImpl
• legacy::MQHelper
• legacy::MQPullConsumerScheduleService
• legacy::PullTaskContext
• legacy::PullTaskImpl
• legacy::RebalanceImpl
• legacy::RebalancePullImpl
• legacy::SendMessageOpenTracingHookImpl
• lock::ReadWriteCASLock
• producer::default_mq_produce_builder::DefaultMQProducerBuilder
• producer::default_mq_producer::DefaultMQProducer
• producer::default_mq_producer::ProducerConfig
• producer::produce_accumulator::AggregateKey
• producer::produce_accumulator::ProduceAccumulator
• producer::producer_config_validation::ProducerConfigValidator
• producer::producer_impl::topic_publish_info::TopicPublishInfo
• producer::queue_selector::select_message_queue_by_hash::SelectMessageQueueByHash
• producer::queue_selector::select_message_queue_by_machine_room::SelectMessageQueueByMachineRoom
• producer::queue_selector::select_message_queue_by_random::SelectMessageQueueByRandom
• producer::send_result::SendResult
• producer::transaction_mq_produce_builder::TransactionMQProducerBuilder
• producer::transaction_mq_producer::TransactionMQProducer
• producer::transaction_mq_producer::TransactionProducerConfig
• producer::transaction_send_result::TransactionSendResult
• stat::consumer_stats_manager::ConsumerStatsManager
• utils::message_util::MessageUtil

Enums

• TraceDispatcherOperation
• TraceDispatcherType
• TraceType
• base::access_channel::AccessChannel
• common::admin_tools_result_code_enum::AdminToolsResultCodeEnum
• consumer::ack_status::AckStatus
• consumer::listener::consume_concurrently_status::ConsumeConcurrentlyStatus
• consumer::listener::consume_orderly_status::ConsumeOrderlyStatus
• consumer::listener::consume_return_type::ConsumeReturnType
• consumer::pop_status::PopStatus
• consumer::pull_status::PullStatus
• consumer::store::offset_store::OffsetStore
• consumer::store::read_offset_type::ReadOffsetType
• producer::local_transaction_state::LocalTransactionState
• producer::send_status::SendStatus

Traits

• ConsumeMessageHook
• HashFunction
• TraceDispatcher
• admin::mq_admin_ext_async::MQAdminExt
• admin::mq_admin_ext_inner::MQAdminExtInner
• base::mq_admin::MQAdmin
• base::mq_client_admin::MqClientAdmin
• base::mq_client_admin::MqClientAdminInner
• consumer::HashFunction
• consumer::PullCallback
• consumer::ack_callback::AckCallback
• consumer::allocate_message_queue_strategy::AllocateMessageQueueStrategy
• consumer::consumer_impl::consume_message_service::ConsumeMessageService
• consumer::consumer_impl::consume_message_service::ConsumeMessageServiceTrait
• consumer::listener::message_listener_concurrently::MessageListenerConcurrently
• consumer::listener::message_listener_orderly::MessageListenerOrderly
• consumer::lite_pull_consumer::LitePullConsumer
• consumer::lite_pull_consumer::LitePullConsumerLocal
• consumer::message_queue_listener::MessageQueueListener
• consumer::mq_consumer::MQConsumer
• consumer::mq_consumer_inner::MQConsumerInner
• consumer::mq_consumer_inner::MQConsumerInnerAny
• consumer::mq_consumer_inner::MQConsumerInnerLocal
• consumer::mq_push_consumer::MQPushConsumer
• consumer::pop_callback::PopCallback
• consumer::pop_callback::PopCallbackInner
• consumer::rebalance_strategy::allocate_message_queue_by_machine_room_nearby::MachineRoomResolver
• consumer::topic_message_queue_change_listener::TopicMessageQueueChangeListener
• latency::Resolver
• latency::ServiceDetector
• legacy::MQPullConsumer
• legacy::PullTaskCallback
• legacy::TransactionCheckListener
• producer::message_queue_selector::MessageQueueSelector
• producer::mq_producer::MQProducer
• producer::producer_impl::queue_filter::QueueFilter
• producer::queue_selector::select_message_queue_by_hash::JavaHashCode
• producer::request_callback::RequestCallback
• producer::send_callback::SendCallback
• producer::transaction_listener::TransactionListener

Macros

• client_broker_err
• mq_client_err

Functions

• consumer::rebalance_strategy::check
• factory::mq_client_instance::topic_route_data2_topic_publish_info
• factory::mq_client_instance::topic_route_data2_topic_subscribe_info
• factory::mq_client_instance::topic_route_data2topic_publish_info
• factory::mq_client_instance::topic_route_data2topic_subscribe_info
• producer::producer_impl::timeout_utils::with_timeout
• producer::producer_impl::timeout_utils::with_timeout_all
• producer::producer_impl::timeout_utils::with_timeout_millis
• producer::producer_impl::timeout_utils::with_timeout_named

Type Aliases

• ArcTraceDispatcher
• ConsumeMessageHookArc
• MQClientAPIExt
• MqClientAdminImpl
• common::acl::AclException
• common::acl::SigningAlgorithm
• consumer::PullCallbackFn
• consumer::ack_callback::AckCallbackFn
• consumer::allocate_message_queue_strategy::AbstractAllocateMessageQueueStrategy
• consumer::listener::message_listener_concurrently::ArcMessageListenerConcurrently
• consumer::listener::message_listener_orderly::ArcMessageListenerOrderly
• consumer::message_queue_listener::ArcMessageQueueListener
• consumer::pop_callback::PopCallbackFn
• consumer::rebalance_strategy::allocate_message_queue_by_machine_room_nearby::AllocateMachineRoomNearby
• factory::client_tables::AdminExtTable
• factory::client_tables::BrokerAddrTable
• factory::client_tables::BrokerHeartbeatFingerprintTable
• factory::client_tables::BrokerSupportV2HeartbeatSet
• factory::client_tables::BrokerVersionTable
• factory::client_tables::ConsumerTable
• factory::client_tables::ProducerTable
• factory::client_tables::TopicEndPointsTable
• factory::client_tables::TopicRouteTable
• producer::message_queue_selector::MessageQueueSelectorFn
• producer::request_callback::RequestCallbackFn
• producer::send_callback::ArcSendCallback
• producer::send_callback::SendMessageCallback
• producer::transaction_listener::ArcTransactionListener

Statics

• consumer::consumer_impl::process_queue::REBALANCE_LOCK_INTERVAL
• consumer::consumer_impl::process_queue::REBALANCE_LOCK_MAX_LIVE_TIME

Constants

• common::session_credentials::ACCESS_KEY
• common::session_credentials::SECRET_KEY
• common::session_credentials::SECURITY_TOKEN
• common::session_credentials::SIGNATURE