List of all items
Structs
- AckResult
- AclClientRPCHook
- AclConstants
- AclSigner
- AclUtils
- AdminClient
- AdminToolResult
- AllocateMessageQueueAveragely
- AllocateMessageQueueAveragelyByCircle
- AllocateMessageQueueByConfig
- AllocateMessageQueueByMachineRoom
- AllocateMessageQueueByMachineRoomNearby
- AllocateMessageQueueConsistentHash
- AsyncTraceDispatcher
- BatchSendCallbackRequest
- BatchSendRequest
- BrokerConfigAllowlisted
- BrokerFilter
- BrokerMutationConfigState
- BrokerReadFailure
- CheckForbiddenContext
- ClientConfig
- ClientError
- ClientInstanceHandle
- ClientMetrics
- ClientOptions
- ClientPool
- ClientRuntime
- ClientRuntimeConfig
- ClientSession
- ConditionalConsumerOffsetOutcome
- ConsumeConcurrentlyContext
- ConsumeMessageContext
- ConsumeMessageOpenTracingHookImpl
- ConsumeOrderlyContext
- ConsumeRequest
- ConsumeStatsReadResult
- ConsumerClient
- ControllableOffset
- DefaultLitePullConsumer
- DefaultLitePullConsumerBuilder
- DefaultMQAdminExt
- DefaultMQAdminExtImpl
- DefaultMQProducer
- DefaultMQPullConsumer
- DefaultMQPullConsumerBuilder
- DefaultMQPullConsumerImpl
- DefaultMQPushConsumer
- DefaultMQPushConsumerBuilder
- DnsName
- DoNothingClientRemotingProcessor
- EndTransactionOpenTracingHookImpl
- InfrastructureObservationReadError
- LocalFileOffsetStore
- MQBrokerException
- MQClientAPIFactory
- MQClientException
- MQFaultStrategy
- MQHelper
- MQPullConsumerScheduleService
- MessageListener
- MessageMetadataRead
- MessageSelector
- MessageUtil
- MutationConsumerOffsetPreview
- MutationMessageRequestMode
- MutationMessageRequestModeOutcome
- MutationStateCasOutcome
- MutationSubscriptionGroupConfig
- MutationSubscriptionGroupConfigState
- MutationTopicConfig
- MutationTopicConfigState
- MutationTopicConfigVersioned
- NameServerAuthority
- NameServerDiscoveryConfig
- NameServerDiscoveryStatus
- NameserverAccessConfig
- NamespaceRpcHook
- NotifyResult
- OffsetNotFoundException
- OffsetSerialize
- OffsetSerializeWrapper
- Permission
- PopResult
- ProducerClient
- ProducerConfig
- PullOptions
- PullResult
- PullResultExt
- PullTaskContext
- PullTaskImpl
- ReadWriteCASLock
- RebalanceImpl
- RebalancePullImpl
- RecallRequest
- RemoteBrokerOffsetStore
- RequestReplyCallbackRequest
- RequestReplyRequest
- RequestTimeoutException
- ResolvedNameServerEndpoint
- RouteClient
- SelectMessageQueueByHash
- SelectMessageQueueByMachineRoom
- SelectMessageQueueByRandom
- SelectedRequestReplyCallbackRequest
- SelectedRequestReplyRequest
- SelectedSendCallbackRequest
- SelectedSendRequest
- SendCallbackRequest
- SendMessageOpenTracingHookImpl
- SendRequest
- SendResult
- SessionCredentials
- SubscriptionGroupConfigPatch
- SubscriptionGroupConfigVersioned
- TelemetryHandle
- ThreadLocalIndex
- TopicConfigPatch
- TopicConfigVersioned
- TopicCreateRequest
- TopicOffsetMutationOutcome
- TopicOffsetMutationTargetOutcome
- TraceDataEncoder
- TransactionClient
- TransactionMQProducer
- TransactionMQProducerBuilder
- TransactionSendRequest
- TransactionSendResult
Enums
- AckStatus
- AdminToolsResultCodeEnum
- BrokerConfigPatchOutcome
- ConsumeConcurrentlyStatus
- ConsumeOrderlyStatus
- ConsumerConnectionRead
- ConsumerGroupConfigRead
- ConsumerProgressRead
- ConsumerTuningProfile
- InfrastructureObservationReadErrorCode
- LocalTransactionState
- MutationExpectedMessageRequestMode
- MutationExpectedState
- MutationPersistenceState
- MutationTopicMessageType
- NameServerDiscoveryErrorCategory
- NameServerDiscoveryFreshness
- NameServerDiscoverySourceKind
- NameServerSource
- OffsetStore
- PopStatus
- ProducerQueryRequest
- ProducerQueryResponse
- PullStatus
- ReadFailureCode
- ReadOffsetType
- SendDestination
- SendMode
- SendStatus
- SubscriptionGroupConfigPatchOutcome
- TopicConfigPatchOutcome
- TopicOffsetMutationFailureCode
- TraceDispatcherOperation
- TraceDispatcherType
- TraceType
Traits
- AckCallback
- AllocateMessageQueueStrategy
- AssignmentControl
- AuthAdmin
- BrokerAdmin
- CheckForbiddenHook
- ClassicPullCallback
- ClientSessionProvider
- ConsumeMessageHook
- ConsumerAdmin
- ConsumerLifecycle
- ConsumerOffsetControl
- HashFunction
- JavaHashCode
- MQAdmin
- MQAdminConsumerObservationReadExt
- MQAdminInfrastructureObservationReadExt
- MQAdminMessageReadExt
- MQAdminMutationExt
- MQAdminReadExt
- MQAdminTopicInventoryReadExt
- MQAdminTopicStatsReadExt
- MQConsumer
- MQConsumerInner
- MQPullConsumer
- MQPushConsumer
- MachineRoomResolver
- MessageListenerConcurrently
- MessageListenerOrderly
- MessagePoll
- MessageQuery
- MessageQueueListener
- MessageQueueSelector
- MessageRecall
- MessageSend
- MqClientAdmin
- MqClientAdminInner
- OffsetAdmin
- PopCallback
- ProducerLifecycle
- ProducerTopicAdmin
- PullCallback
- PullTaskCallback
- RequestCallback
- RequestReply
- Resolver
- RouteAdmin
- SendCallback
- ServiceDetector
- SubscriptionControl
- TopicAdmin
- TopicMessageQueueChangeListener
- TraceDispatcher
- TransactionCheckListener
- TransactionListener
- TransactionSend
Macros
Functions
- client_config_for_managed_domain
- pop_retry_subscription_topics
- resolve_pop_retry_topic
- rpc_hook_from_outbound_signer
Type Aliases
- AbstractAllocateMessageQueueStrategy
- AckCallbackFn
- AclException
- AllocateMachineRoomNearby
- ArcMessageListenerConcurrently
- ArcMessageListenerOrderly
- ArcMessageQueueListener
- ArcSendCallback
- ArcTraceDispatcher
- ArcTransactionListener
- ClientResult
- ClientRpcHook
- ConsumeMessageHookArc
- MessageQueueSelectorFn
- PopCallbackFn
- PullCallbackFn
- PullOutcome
- QueryResult
- SigningAlgorithm