所有程序包的分层结构

程序包分层结构:

• io.openmessaging.joyqueue,
• io.openmessaging.joyqueue.config,
• io.openmessaging.joyqueue.consumer,
• io.openmessaging.joyqueue.consumer.extension,
• io.openmessaging.joyqueue.consumer.interceptor,
• io.openmessaging.joyqueue.consumer.message,
• io.openmessaging.joyqueue.consumer.support,
• io.openmessaging.joyqueue.domain,
• io.openmessaging.joyqueue.extension,
• io.openmessaging.joyqueue.message,
• io.openmessaging.joyqueue.producer,
• io.openmessaging.joyqueue.producer.extension,
• io.openmessaging.joyqueue.producer.interceptor,
• io.openmessaging.joyqueue.producer.message,
• io.openmessaging.joyqueue.producer.support,
• io.openmessaging.joyqueue.support,
• org.joyqueue.client.internal,
• org.joyqueue.client.internal.cluster,
• org.joyqueue.client.internal.cluster.domain,
• org.joyqueue.client.internal.cluster.exception,
• org.joyqueue.client.internal.common.compress,
• org.joyqueue.client.internal.common.compress.support,
• org.joyqueue.client.internal.common.interceptor,
• org.joyqueue.client.internal.common.ordered,
• org.joyqueue.client.internal.consumer,
• org.joyqueue.client.internal.consumer.callback,
• org.joyqueue.client.internal.consumer.config,
• org.joyqueue.client.internal.consumer.container,
• org.joyqueue.client.internal.consumer.converter,
• org.joyqueue.client.internal.consumer.coordinator,
• org.joyqueue.client.internal.consumer.coordinator.domain,
• org.joyqueue.client.internal.consumer.domain,
• org.joyqueue.client.internal.consumer.exception,
• org.joyqueue.client.internal.consumer.interceptor,
• org.joyqueue.client.internal.consumer.support,
• org.joyqueue.client.internal.consumer.transport,
• org.joyqueue.client.internal.exception,
• org.joyqueue.client.internal.metadata,
• org.joyqueue.client.internal.metadata.converter,
• org.joyqueue.client.internal.metadata.domain,
• org.joyqueue.client.internal.metadata.exception,
• org.joyqueue.client.internal.nameserver,
• org.joyqueue.client.internal.nameserver.helper,
• org.joyqueue.client.internal.producer,
• org.joyqueue.client.internal.producer.callback,
• org.joyqueue.client.internal.producer.checker,
• org.joyqueue.client.internal.producer.config,
• org.joyqueue.client.internal.producer.converter,
• org.joyqueue.client.internal.producer.domain,
• org.joyqueue.client.internal.producer.exception,
• org.joyqueue.client.internal.producer.feedback,
• org.joyqueue.client.internal.producer.feedback.config,
• org.joyqueue.client.internal.producer.helper,
• org.joyqueue.client.internal.producer.interceptor,
• org.joyqueue.client.internal.producer.support,
• org.joyqueue.client.internal.producer.transport,
• org.joyqueue.client.internal.support,
• org.joyqueue.client.internal.trace,
• org.joyqueue.client.internal.trace.interceptor,
• org.joyqueue.client.internal.trace.support,
• org.joyqueue.client.internal.transport,
• org.joyqueue.client.internal.transport.config

类分层结构

• java.lang.Object
  • io.openmessaging.joyqueue.extension.AbstractExtensionAdapter (implements io.openmessaging.extension.Extension)
    • io.openmessaging.joyqueue.producer.extension.ExtensionAdapter
    • io.openmessaging.joyqueue.consumer.extension.ExtensionAdapter
  • org.joyqueue.client.internal.producer.support.AbstractPartitionSelector (implements org.joyqueue.client.internal.producer.PartitionSelector)
    • org.joyqueue.client.internal.producer.support.WeightedRoundRobinPartitionSelector
  • org.joyqueue.toolkit.service.Activity
    • org.joyqueue.toolkit.service.Service (implements org.joyqueue.toolkit.lang.LifeCycle)
      • io.openmessaging.joyqueue.support.AbstractServiceLifecycle (implements io.openmessaging.ServiceLifecycle)
        • io.openmessaging.joyqueue.consumer.support.ConsumerImpl (implements io.openmessaging.joyqueue.consumer.ExtensionConsumer)
        • io.openmessaging.joyqueue.producer.support.ProducerImpl (implements io.openmessaging.joyqueue.producer.ExtensionProducer)
      • org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller (implements org.joyqueue.client.internal.consumer.MessagePoller)
      • org.joyqueue.client.internal.transport.Client
      • org.joyqueue.client.internal.transport.ClientGroup
      • org.joyqueue.client.internal.transport.ClientGroupManager
      • org.joyqueue.client.internal.transport.ClientManager
      • org.joyqueue.client.internal.cluster.ClusterClientManager
      • org.joyqueue.client.internal.cluster.ClusterManager
        • org.joyqueue.client.internal.cluster.ClusterManagerWrapper
      • org.joyqueue.client.internal.consumer.transport.ConsumerClientManager
      • org.joyqueue.client.internal.consumer.coordinator.ConsumerCoordinator
      • org.joyqueue.client.internal.consumer.support.ConsumerLocalIndexStore
      • org.joyqueue.client.internal.consumer.coordinator.CoordinatorManager
      • org.joyqueue.client.internal.consumer.support.DefaultConsumerIndexManager (implements org.joyqueue.client.internal.consumer.ConsumerIndexManager)
      • org.joyqueue.client.internal.support.DefaultMessageAccessPoint (implements org.joyqueue.client.internal.MessageAccessPoint)
      • org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer (implements org.joyqueue.client.internal.consumer.MessageConsumer)
      • org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher (implements org.joyqueue.client.internal.consumer.MessageFetcher)
      • org.joyqueue.client.internal.consumer.container.DefaultMessageListenerContainer (implements org.joyqueue.client.internal.consumer.MessageListenerContainer)
      • org.joyqueue.client.internal.consumer.support.DefaultMessagePoller (implements org.joyqueue.client.internal.consumer.MessagePoller)
      • org.joyqueue.client.internal.producer.support.DefaultMessageProducer (implements org.joyqueue.client.internal.producer.MessageProducer)
      • org.joyqueue.client.internal.producer.support.DefaultMessageSender (implements org.joyqueue.client.internal.producer.MessageSender)
      • org.joyqueue.client.internal.producer.feedback.DefaultTxFeedbackManager (implements org.joyqueue.client.internal.producer.TxFeedbackManager)
      • org.joyqueue.client.internal.consumer.support.LocalConsumerIndexManager (implements org.joyqueue.client.internal.consumer.ConsumerIndexManager)
      • org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper (implements org.joyqueue.client.internal.consumer.MessageConsumer)
      • org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper (implements org.joyqueue.client.internal.consumer.MessageFetcher)
      • org.joyqueue.client.internal.consumer.container.MessageListenerContainerWrapper (implements org.joyqueue.client.internal.consumer.MessageListenerContainer)
      • org.joyqueue.client.internal.consumer.support.MessagePollerInner
      • org.joyqueue.client.internal.consumer.support.MessagePollerWrapper (implements org.joyqueue.client.internal.consumer.MessagePoller)
      • org.joyqueue.client.internal.producer.support.MessageProducerInner
      • org.joyqueue.client.internal.producer.support.MessageProducerWrapper (implements org.joyqueue.client.internal.producer.MessageProducer)
      • org.joyqueue.client.internal.producer.MessageSenderWrapper (implements org.joyqueue.client.internal.producer.MessageSender)
      • org.joyqueue.client.internal.cluster.MetadataUpdater
      • org.joyqueue.client.internal.consumer.coordinator.PartitionAssignmentManager
      • org.joyqueue.client.internal.consumer.support.PartitionMessagePoller (implements org.joyqueue.client.internal.consumer.MessagePoller)
      • org.joyqueue.client.internal.producer.transport.ProducerClientManager
      • org.joyqueue.client.internal.consumer.support.TopicMessageConsumer
      • org.joyqueue.client.internal.consumer.support.TopicMessageConsumerDispatcher
      • org.joyqueue.client.internal.consumer.support.TopicMessageConsumerScheduler (implements java.lang.Runnable)
      • org.joyqueue.client.internal.producer.feedback.TxFeedbackManagerWrapper (implements org.joyqueue.client.internal.producer.TxFeedbackManager)
      • org.joyqueue.client.internal.producer.feedback.TxFeedbackScheduler
  • org.joyqueue.client.internal.producer.callback.AsyncBatchProduceCallbackAdapter (implements org.joyqueue.client.internal.producer.callback.AsyncBatchProduceCallback)
  • org.joyqueue.client.internal.consumer.support.BatchConsumerInvoker (implements org.joyqueue.client.internal.consumer.interceptor.ConsumerInvoker)
  • io.openmessaging.joyqueue.consumer.support.BatchMessageListenerAdapter (implements org.joyqueue.client.internal.consumer.BatchMessageListener)
  • io.openmessaging.joyqueue.consumer.support.BatchMessageListenerContextAdapter (implements io.openmessaging.consumer.BatchMessageListener.Context)
  • org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignment
  • org.joyqueue.client.internal.consumer.converter.BrokerAssignmentConverter
  • org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignments
  • org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignmentsHolder
  • org.joyqueue.client.internal.consumer.support.BrokerLoadBalanceManager
  • org.joyqueue.client.internal.consumer.converter.BrokerMessageConverter
  • org.joyqueue.client.internal.transport.ClientConnectionInfo
  • org.joyqueue.client.internal.transport.ClientConnectionListener (implements org.joyqueue.toolkit.concurrent.EventListener<E>)
  • org.joyqueue.client.internal.transport.ClientConnectionState
  • org.joyqueue.client.internal.ClientConsts
  • org.joyqueue.client.internal.transport.ClientHeartbeatThread (implements java.lang.Runnable)
  • org.joyqueue.client.internal.cluster.ClusterClient
  • org.joyqueue.client.internal.cluster.ClusterClientManagerFactory
  • org.joyqueue.client.internal.cluster.ClusterManagerFactory
  • org.joyqueue.client.internal.metadata.domain.ClusterMetadata
  • org.joyqueue.client.internal.metadata.converter.ClusterMetadataConverter
  • org.joyqueue.client.internal.producer.callback.CompletableFutureAsyncBatchProduceCallback (implements org.joyqueue.client.internal.producer.callback.AsyncBatchProduceCallback)
  • org.joyqueue.client.internal.producer.callback.CompletableFutureAsyncProduceCallback (implements org.joyqueue.client.internal.producer.callback.AsyncProduceCallback)
  • org.joyqueue.client.internal.consumer.support.CompletableFuturePollerListener (implements org.joyqueue.client.internal.consumer.callback.PollerListener)
  • org.joyqueue.client.internal.trace.support.CompositeTrace (implements org.joyqueue.client.internal.trace.Trace)
  • org.joyqueue.client.internal.trace.support.CompositeTraceCaller (implements org.joyqueue.client.internal.trace.TraceCaller)
  • org.joyqueue.client.internal.common.compress.CompressorManager
  • org.joyqueue.client.internal.common.compress.CompressUtils
  • org.joyqueue.client.internal.transport.ConnectionState
  • org.joyqueue.client.internal.consumer.interceptor.ConsumeContext
  • org.joyqueue.client.internal.consumer.domain.ConsumeMessage (implements java.io.Serializable)
  • org.joyqueue.client.internal.consumer.converter.ConsumeMessageConverter
  • org.joyqueue.client.internal.consumer.transport.ConsumerClient
  • org.joyqueue.client.internal.consumer.transport.ConsumerClientConnectionListener (implements org.joyqueue.toolkit.concurrent.EventListener<E>)
  • org.joyqueue.client.internal.consumer.transport.ConsumerClientGroup
  • org.joyqueue.client.internal.consumer.transport.ConsumerClientManagerFactory
  • org.joyqueue.client.internal.consumer.config.ConsumerConfig
  • org.joyqueue.client.internal.consumer.transport.ConsumerConnectionState
  • org.joyqueue.client.internal.consumer.domain.ConsumeReply
  • io.openmessaging.joyqueue.consumer.ConsumerIndex
  • io.openmessaging.joyqueue.consumer.support.ConsumerInterceptorAdapter (implements org.joyqueue.client.internal.consumer.interceptor.ConsumerInterceptor)
  • org.joyqueue.client.internal.consumer.interceptor.ConsumerInterceptorManager
  • org.joyqueue.client.internal.consumer.interceptor.ConsumerInvocation
  • io.openmessaging.joyqueue.support.ConsumerWrapper (implements io.openmessaging.joyqueue.consumer.ExtensionConsumer)
  • io.openmessaging.joyqueue.producer.interceptor.ContextAdapter (implements io.openmessaging.interceptor.Context)
  • io.openmessaging.joyqueue.consumer.interceptor.ContextAdapter (implements io.openmessaging.interceptor.Context)
  • io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter (implements io.openmessaging.KeyValue)
  • io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter (implements io.openmessaging.KeyValue)
  • org.joyqueue.client.internal.producer.support.DefaultTransactionMessageProducer (implements org.joyqueue.client.internal.producer.TransactionMessageProducer)
  • io.openmessaging.joyqueue.message.EmptyMessageReceipt (implements io.openmessaging.consumer.MessageReceipt)
  • io.openmessaging.joyqueue.config.ExceptionConverter
  • io.openmessaging.joyqueue.producer.message.ExtensionMessageFactoryImpl (implements io.openmessaging.joyqueue.producer.extension.ExtensionMessageFactory)
  • io.openmessaging.joyqueue.producer.support.ExtensionTransactionalResultAdapter (implements io.openmessaging.joyqueue.producer.ExtensionTransactionalResult)
  • org.joyqueue.client.internal.producer.domain.FeedbackData
  • org.joyqueue.client.internal.consumer.config.FetcherConfig
  • org.joyqueue.client.internal.producer.domain.FetchFeedbackData
  • org.joyqueue.client.internal.consumer.domain.FetchIndexData
  • org.joyqueue.client.internal.consumer.domain.FetchMessageData
  • io.openmessaging.joyqueue.producer.support.FutureAdapter<V> (implements io.openmessaging.Future<V>)
  • org.joyqueue.client.internal.consumer.interceptor.GlobalConsumerInterceptorManager
  • org.joyqueue.client.internal.producer.interceptor.GlobalProducerInterceptorManager
  • io.openmessaging.joyqueue.JoyQueueOMSConsts
  • io.openmessaging.joyqueue.config.KeyValueConverter
  • io.openmessaging.joyqueue.config.KeyValueHelper
  • org.joyqueue.client.internal.consumer.domain.LocalIndexData
  • org.joyqueue.client.internal.MessageAccessPointFactory
  • io.openmessaging.joyqueue.support.MessageAccessPointHolder
  • io.openmessaging.joyqueue.producer.message.MessageAdapter (implements io.openmessaging.joyqueue.message.ExtensionMessage)
  • io.openmessaging.joyqueue.consumer.message.MessageAdapter (implements io.openmessaging.joyqueue.message.ExtensionMessage)
  • org.joyqueue.client.internal.consumer.MessageConsumerFactory
  • io.openmessaging.joyqueue.consumer.message.MessageConverter
  • org.joyqueue.client.internal.consumer.converter.MessageConvertSupport
  • io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter (implements io.openmessaging.joyqueue.producer.message.ExtensionHeader)
  • io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter (implements io.openmessaging.extension.ExtensionHeader)
  • org.joyqueue.client.internal.consumer.MessageFetcherFactory
  • io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter (implements io.openmessaging.message.Header)
  • io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter (implements io.openmessaging.message.Header)
  • io.openmessaging.joyqueue.consumer.support.MessageListenerAdapter (implements org.joyqueue.client.internal.consumer.MessageListener)
  • org.joyqueue.client.internal.consumer.container.MessageListenerContainerFactory
  • io.openmessaging.joyqueue.consumer.support.MessageListenerContextAdapter (implements io.openmessaging.consumer.MessageListener.Context)
  • org.joyqueue.client.internal.consumer.support.MessageListenerManager
  • org.joyqueue.client.internal.consumer.MessagePollerFactory
  • org.joyqueue.client.internal.producer.MessageProducerFactory
  • io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter (implements io.openmessaging.KeyValue)
  • io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter (implements io.openmessaging.KeyValue)
  • io.openmessaging.joyqueue.consumer.message.MessageReceiptAdapter (implements io.openmessaging.consumer.MessageReceipt)
  • org.joyqueue.client.internal.producer.converter.MessageSenderConverter
  • org.joyqueue.client.internal.producer.MessageSenderFactory
  • io.openmessaging.joyqueue.MessagingAccessPointImpl (implements io.openmessaging.MessagingAccessPoint)
  • org.joyqueue.client.internal.cluster.MetadataCacheManager
  • org.joyqueue.client.internal.metadata.MetadataManager
  • org.joyqueue.client.internal.nameserver.NameServerConfig
  • org.joyqueue.client.internal.nameserver.NameServerConfigChecker
  • org.joyqueue.client.internal.nameserver.helper.NameServerHelper
  • org.joyqueue.client.internal.trace.support.NoneTrace (implements org.joyqueue.client.internal.trace.Trace)
  • org.joyqueue.client.internal.trace.support.NoneTraceCaller (implements org.joyqueue.client.internal.trace.TraceCaller)
  • org.joyqueue.client.internal.consumer.support.OnceConsumerInvoker (implements org.joyqueue.client.internal.consumer.interceptor.ConsumerInvoker)
  • org.joyqueue.client.internal.common.ordered.OrderedComparator (implements java.util.Comparator<T>)
  • org.joyqueue.client.internal.common.ordered.OrderedSorter
  • io.openmessaging.joyqueue.extension.PartitionAdapter (implements io.openmessaging.extension.QueueMetaData.Partition)
  • org.joyqueue.client.internal.consumer.coordinator.domain.PartitionAssignment
  • org.joyqueue.client.internal.consumer.coordinator.domain.PartitionAssignmentHolder
  • org.joyqueue.client.internal.metadata.domain.PartitionGroupMetadata (implements java.io.Serializable)
  • org.joyqueue.client.internal.metadata.domain.PartitionMetadata (implements java.io.Serializable)
  • org.joyqueue.client.internal.producer.support.PartitionSelectorManager
  • org.joyqueue.client.internal.producer.interceptor.ProduceContext
  • org.joyqueue.client.internal.producer.domain.ProduceMessage (implements java.io.Serializable)
    • io.openmessaging.joyqueue.producer.message.OMSProduceMessage
  • org.joyqueue.client.internal.producer.checker.ProduceMessageChecker
  • org.joyqueue.client.internal.producer.converter.ProduceMessageConverter
  • org.joyqueue.client.internal.producer.transport.ProducerClient
  • org.joyqueue.client.internal.producer.transport.ProducerClientConnectionListener (implements org.joyqueue.toolkit.concurrent.EventListener<E>)
  • org.joyqueue.client.internal.producer.transport.ProducerClientGroup
  • org.joyqueue.client.internal.producer.transport.ProducerClientManagerFactory
  • org.joyqueue.client.internal.producer.config.ProducerConfig
  • org.joyqueue.client.internal.producer.transport.ProducerConnectionState
  • org.joyqueue.client.internal.producer.domain.ProduceResult (implements java.io.Serializable)
  • org.joyqueue.client.internal.producer.helper.ProducerHelper
  • io.openmessaging.joyqueue.producer.support.ProducerInterceptorAdapter (implements org.joyqueue.client.internal.producer.interceptor.ProducerInterceptor)
  • org.joyqueue.client.internal.producer.interceptor.ProducerInterceptorManager
  • org.joyqueue.client.internal.producer.interceptor.ProducerInvocation
  • io.openmessaging.joyqueue.support.ProducerWrapper (implements io.openmessaging.joyqueue.producer.ExtensionProducer)
  • io.openmessaging.joyqueue.extension.QueueMetaDataAdapter (implements io.openmessaging.extension.QueueMetaData)
  • org.joyqueue.client.internal.consumer.support.RandomBrokerLoadBalance (implements org.joyqueue.client.internal.consumer.BrokerLoadBalance)
  • org.joyqueue.client.internal.consumer.support.RoundRobinBrokerLoadBalance (implements org.joyqueue.client.internal.consumer.BrokerLoadBalance)
  • org.joyqueue.client.internal.producer.domain.SendBatchResultData
  • org.joyqueue.client.internal.producer.config.SenderConfig
  • org.joyqueue.client.internal.producer.domain.SendPrepareResult (implements java.io.Serializable)
  • org.joyqueue.client.internal.producer.domain.SendResult (implements java.io.Serializable)
  • io.openmessaging.joyqueue.producer.support.SendResultAdapter (implements io.openmessaging.producer.SendResult)
  • io.openmessaging.joyqueue.producer.support.SendResultConverter
  • org.joyqueue.client.internal.producer.domain.SendResultData
  • org.joyqueue.client.internal.common.compress.support.SnappyCompressor (implements org.joyqueue.client.internal.common.compress.Compressor)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.joyqueue.client.internal.exception.ClientException
          • org.joyqueue.client.internal.cluster.exception.ClusterException
          • org.joyqueue.client.internal.consumer.exception.ConsumerException
          • org.joyqueue.client.internal.consumer.exception.IgnoreAckException
          • org.joyqueue.client.internal.metadata.exception.MetadataException
          • org.joyqueue.client.internal.producer.exception.ProducerException
            • org.joyqueue.client.internal.producer.exception.NeedRetryException
        • org.joyqueue.client.internal.exception.SecurityException
  • org.joyqueue.client.internal.cluster.TopicAndApp
  • org.joyqueue.client.internal.metadata.domain.TopicMetadata (implements java.io.Serializable)
    • org.joyqueue.client.internal.metadata.domain.UnmodifiableTopicMetadata
  • org.joyqueue.client.internal.consumer.converter.TopicMetadataConverter
  • io.openmessaging.joyqueue.extension.TopicMetadataConverter
  • org.joyqueue.client.internal.cluster.domain.TopicMetadataHolder
  • org.joyqueue.client.internal.trace.TraceBuilder
  • org.joyqueue.client.internal.trace.interceptor.TraceConsumerInterceptor (implements org.joyqueue.client.internal.consumer.interceptor.ConsumerInterceptor, org.joyqueue.client.internal.common.ordered.Ordered)
  • org.joyqueue.client.internal.trace.TraceContext
  • org.joyqueue.client.internal.trace.TraceManager
  • org.joyqueue.client.internal.trace.interceptor.TraceProducerInterceptor (implements org.joyqueue.client.internal.common.ordered.Ordered, org.joyqueue.client.internal.producer.interceptor.ProducerInterceptor)
  • org.joyqueue.client.internal.trace.support.TraceWrapper (implements org.joyqueue.client.internal.trace.Trace)
  • io.openmessaging.joyqueue.producer.support.TransactionalContextAdapter (implements io.openmessaging.producer.TransactionStateCheckListener.TransactionalContext)
  • io.openmessaging.joyqueue.producer.support.TransactionalResultAdapter (implements io.openmessaging.producer.TransactionalResult)
  • io.openmessaging.joyqueue.producer.support.TransactionProducerImpl (implements io.openmessaging.joyqueue.producer.ExtensionProducer)
  • io.openmessaging.joyqueue.producer.support.TransactionStateCheckListenerAdapter (implements org.joyqueue.client.internal.producer.callback.TxFeedbackCallback)
  • org.joyqueue.client.internal.transport.config.TransportConfig
  • org.joyqueue.client.internal.transport.config.TransportConfigChecker
  • org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfig
  • org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfigChecker
  • org.joyqueue.client.internal.producer.feedback.TxFeedbackDispatcher
  • org.joyqueue.client.internal.producer.TxFeedbackManagerFactory
  • org.joyqueue.client.internal.common.compress.support.ZlibCompressor (implements org.joyqueue.client.internal.common.compress.Compressor)

接口分层结构

• org.joyqueue.client.internal.producer.callback.AsyncBatchProduceCallback
• org.joyqueue.client.internal.producer.callback.AsyncBatchSendCallback
• org.joyqueue.client.internal.producer.callback.AsyncMultiBatchSendCallback
• org.joyqueue.client.internal.producer.callback.AsyncProduceCallback
• org.joyqueue.client.internal.producer.callback.AsyncSendCallback
• org.joyqueue.client.internal.common.interceptor.BaseInterceptor
  • org.joyqueue.client.internal.consumer.interceptor.ConsumerInterceptor
  • org.joyqueue.client.internal.producer.interceptor.ProducerInterceptor
• org.joyqueue.client.internal.consumer.BaseMessageListener
  • org.joyqueue.client.internal.consumer.BatchMessageListener
  • org.joyqueue.client.internal.consumer.MessageListener
• org.joyqueue.client.internal.consumer.callback.BatchFetchListener
• org.joyqueue.client.internal.consumer.callback.BatchPartitionFetchListener
• io.openmessaging.Client
  • io.openmessaging.consumer.Consumer (并 extends io.openmessaging.ServiceLifecycle)
    • io.openmessaging.joyqueue.consumer.ExtensionConsumer
  • io.openmessaging.joyqueue.consumer.ExtensionConsumer
  • io.openmessaging.joyqueue.producer.ExtensionProducer (并 extends io.openmessaging.joyqueue.producer.extension.ExtensionMessageFactory, io.openmessaging.producer.Producer)
  • io.openmessaging.producer.Producer (并 extends io.openmessaging.message.MessageFactory, io.openmessaging.ServiceLifecycle)
    • io.openmessaging.joyqueue.producer.ExtensionProducer (并 extends io.openmessaging.joyqueue.producer.extension.ExtensionMessageFactory)
• org.joyqueue.client.internal.consumer.interceptor.ConsumerInvoker
• io.openmessaging.extension.Extension
  • io.openmessaging.consumer.Consumer (并 extends io.openmessaging.Client, io.openmessaging.ServiceLifecycle)
    • io.openmessaging.joyqueue.consumer.ExtensionConsumer
  • io.openmessaging.joyqueue.consumer.ExtensionConsumer
  • io.openmessaging.joyqueue.producer.ExtensionProducer (并 extends io.openmessaging.joyqueue.producer.extension.ExtensionMessageFactory, io.openmessaging.producer.Producer)
  • io.openmessaging.producer.Producer (并 extends io.openmessaging.Client, io.openmessaging.message.MessageFactory, io.openmessaging.ServiceLifecycle)
    • io.openmessaging.joyqueue.producer.ExtensionProducer (并 extends io.openmessaging.joyqueue.producer.extension.ExtensionMessageFactory)
  • io.openmessaging.ServiceLifecycle
    • io.openmessaging.consumer.Consumer (并 extends io.openmessaging.Client)
      • io.openmessaging.joyqueue.consumer.ExtensionConsumer
    • io.openmessaging.joyqueue.consumer.ExtensionConsumer
    • io.openmessaging.joyqueue.producer.ExtensionProducer (并 extends io.openmessaging.joyqueue.producer.extension.ExtensionMessageFactory, io.openmessaging.producer.Producer)
    • io.openmessaging.producer.Producer (并 extends io.openmessaging.Client, io.openmessaging.message.MessageFactory)
      • io.openmessaging.joyqueue.producer.ExtensionProducer (并 extends io.openmessaging.joyqueue.producer.extension.ExtensionMessageFactory)
• io.openmessaging.extension.ExtensionHeader
  • io.openmessaging.joyqueue.producer.message.ExtensionHeader
• io.openmessaging.joyqueue.producer.ExtensionTransactionalResult
• org.joyqueue.client.internal.consumer.callback.FetchListener
• io.openmessaging.message.Message
  • io.openmessaging.joyqueue.message.ExtensionMessage
• io.openmessaging.message.MessageFactory
  • io.openmessaging.joyqueue.producer.extension.ExtensionMessageFactory
    • io.openmessaging.joyqueue.producer.ExtensionProducer (并 extends io.openmessaging.producer.Producer)
  • io.openmessaging.joyqueue.producer.ExtensionProducer (并 extends io.openmessaging.joyqueue.producer.extension.ExtensionMessageFactory, io.openmessaging.producer.Producer)
  • io.openmessaging.producer.Producer (并 extends io.openmessaging.Client, io.openmessaging.ServiceLifecycle)
    • io.openmessaging.joyqueue.producer.ExtensionProducer (并 extends io.openmessaging.joyqueue.producer.extension.ExtensionMessageFactory)
• io.openmessaging.OMSBuiltinKeys
  • io.openmessaging.joyqueue.JoyQueueBuiltinKeys (并 extends io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueNameServerBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueTxFeedbackBuiltinKeys)
  • io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys
    • io.openmessaging.joyqueue.JoyQueueBuiltinKeys (并 extends io.openmessaging.joyqueue.domain.JoyQueueNameServerBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueTxFeedbackBuiltinKeys, io.openmessaging.OMSBuiltinKeys)
  • io.openmessaging.joyqueue.domain.JoyQueueNameServerBuiltinKeys
    • io.openmessaging.joyqueue.JoyQueueBuiltinKeys (并 extends io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueTxFeedbackBuiltinKeys, io.openmessaging.OMSBuiltinKeys)
  • io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys
    • io.openmessaging.joyqueue.JoyQueueBuiltinKeys (并 extends io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueNameServerBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueTxFeedbackBuiltinKeys, io.openmessaging.OMSBuiltinKeys)
  • io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys
    • io.openmessaging.joyqueue.JoyQueueBuiltinKeys (并 extends io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueNameServerBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueTxFeedbackBuiltinKeys, io.openmessaging.OMSBuiltinKeys)
  • io.openmessaging.joyqueue.domain.JoyQueueTxFeedbackBuiltinKeys
    • io.openmessaging.joyqueue.JoyQueueBuiltinKeys (并 extends io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueNameServerBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys, io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys, io.openmessaging.OMSBuiltinKeys)
• org.joyqueue.toolkit.lang.Online
  • org.joyqueue.client.internal.consumer.ConsumerIndexManager
  • org.joyqueue.toolkit.lang.LifeCycle
    • org.joyqueue.client.internal.consumer.ConsumerIndexManager
    • org.joyqueue.client.internal.MessageAccessPoint
    • org.joyqueue.client.internal.consumer.MessageConsumer
    • org.joyqueue.client.internal.consumer.MessageFetcher
    • org.joyqueue.client.internal.consumer.MessageListenerContainer
    • org.joyqueue.client.internal.consumer.MessagePoller
    • org.joyqueue.client.internal.producer.MessageProducer
    • org.joyqueue.client.internal.producer.MessageSender
    • org.joyqueue.client.internal.producer.TxFeedbackManager
  • org.joyqueue.client.internal.MessageAccessPoint
  • org.joyqueue.client.internal.consumer.MessageConsumer
  • org.joyqueue.client.internal.consumer.MessageFetcher
  • org.joyqueue.client.internal.consumer.MessageListenerContainer
  • org.joyqueue.client.internal.consumer.MessagePoller
  • org.joyqueue.client.internal.producer.MessageProducer
  • org.joyqueue.client.internal.producer.MessageSender
  • org.joyqueue.client.internal.producer.TxFeedbackManager
• org.joyqueue.client.internal.common.ordered.Ordered
• org.joyqueue.client.internal.consumer.callback.PartitionConsumerListener
• org.joyqueue.client.internal.consumer.callback.PartitionFetchListener
• org.joyqueue.client.internal.Plugins
• org.joyqueue.client.internal.consumer.callback.PollerListener
• org.joyqueue.client.internal.producer.interceptor.ProducerInvoker
• org.joyqueue.client.internal.trace.TraceCaller
• org.joyqueue.client.internal.producer.TransactionMessageProducer
• org.joyqueue.client.internal.producer.callback.TxFeedbackCallback
• com.jd.laf.extension.Type<T>
  • org.joyqueue.client.internal.consumer.BrokerLoadBalance
  • org.joyqueue.client.internal.common.compress.Compressor
  • org.joyqueue.client.internal.consumer.converter.MessageConverter
  • org.joyqueue.client.internal.producer.PartitionSelector
  • org.joyqueue.client.internal.trace.Trace

枚举分层结构

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.joyqueue.client.internal.producer.domain.TransactionStatus
    • org.joyqueue.client.internal.trace.TraceType
    • org.joyqueue.client.internal.transport.ClientState