A B C D E F G H I J K L M N O P Q R S T U V W Z

A

AbstractExtensionAdapter - io.openmessaging.joyqueue.extension中的类

AbstractExtensionAdapter author: gaohaoxiang date: 2019/3/1

AbstractExtensionAdapter() - 类 的构造器io.openmessaging.joyqueue.extension.AbstractExtensionAdapter

AbstractPartitionSelector - org.joyqueue.client.internal.producer.support中的类

AbstractPartitionSelector author: gaohaoxiang date: 2018/12/10

AbstractPartitionSelector() - 类 的构造器org.joyqueue.client.internal.producer.support.AbstractPartitionSelector

AbstractServiceLifecycle - io.openmessaging.joyqueue.support中的类

AbstractServiceLifecycle author: gaohaoxiang date: 2019/2/19

AbstractServiceLifecycle() - 类 的构造器io.openmessaging.joyqueue.support.AbstractServiceLifecycle

ack() - 类 中的方法io.openmessaging.joyqueue.consumer.support.BatchMessageListenerContextAdapter

ack(MessageReceipt) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

ack() - 类 中的方法io.openmessaging.joyqueue.consumer.support.MessageListenerContextAdapter

ack(MessageReceipt) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

ACK_TIMEOUT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

addApp(String) - 类 中的方法org.joyqueue.client.internal.transport.ConnectionState

addBatchListener(String, BatchMessageListener) - 类 中的方法org.joyqueue.client.internal.consumer.container.DefaultMessageListenerContainer

addBatchListener(String, BatchMessageListener) - 类 中的方法org.joyqueue.client.internal.consumer.container.MessageListenerContainerWrapper

addBatchListener(String, BatchMessageListener) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageListenerContainer

addBrokerNode(BrokerNode) - 类 中的方法org.joyqueue.client.internal.transport.ConnectionState

addConsumers() - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

addConsumers(Collection<String>, String) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

addInterceptor(ConsumerInterceptor) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

addInterceptor(ProducerInterceptor) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

addInterceptor(ProducerInterceptor) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

addInterceptor(ConsumerInterceptor) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

addInterceptor(ProducerInterceptor) - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

addInterceptor(ConsumerInterceptor) - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumerInterceptorManager

addInterceptor(ConsumerInterceptor) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

addInterceptor(ConsumerInterceptor) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

addInterceptor(ConsumerInterceptor) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

addInterceptor(ConsumerInterceptor) - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumer

addInterceptor(ProducerInterceptor) - 类 中的方法org.joyqueue.client.internal.producer.interceptor.ProducerInterceptorManager

addInterceptor(ProducerInterceptor) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

addInterceptor(ProducerInterceptor) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

addInterceptor(ProducerInterceptor) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

addInterceptor(ProducerInterceptor) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

addListener(FutureListener) - 类 中的方法io.openmessaging.joyqueue.producer.support.FutureAdapter

addListener(String, MessageListener) - 类 中的方法org.joyqueue.client.internal.consumer.container.DefaultMessageListenerContainer

addListener(String, MessageListener) - 类 中的方法org.joyqueue.client.internal.consumer.container.MessageListenerContainerWrapper

addListener(String, MessageListener) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageListenerContainer

addListener(BaseMessageListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageListenerManager

addListener(BaseMessageListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumer

addListener(EventListener<TransportEvent>) - 类 中的方法org.joyqueue.client.internal.transport.Client

addProducers() - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClient

addProducers(Collection<String>, String) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClient

addTopics(Collection<String>) - 类 中的方法org.joyqueue.client.internal.transport.ConnectionState

app(String) - 类 中的方法org.joyqueue.client.internal.trace.TraceBuilder

async(Command, long) - 类 中的方法org.joyqueue.client.internal.transport.Client

async(Command) - 类 中的方法org.joyqueue.client.internal.transport.Client

async(Command, long, CommandCallback) - 类 中的方法org.joyqueue.client.internal.transport.Client

async(Command, CommandCallback) - 类 中的方法org.joyqueue.client.internal.transport.Client

AsyncBatchProduceCallback - org.joyqueue.client.internal.producer.callback中的接口

AsyncBatchProduceCallback author: gaohaoxiang date: 2018/12/20

AsyncBatchProduceCallbackAdapter - org.joyqueue.client.internal.producer.callback中的类

AsyncBatchProduceCallbackAdapter author: gaohaoxiang date: 2018/12/27

AsyncBatchProduceCallbackAdapter(AsyncProduceCallback) - 类 的构造器org.joyqueue.client.internal.producer.callback.AsyncBatchProduceCallbackAdapter

AsyncBatchSendCallback - org.joyqueue.client.internal.producer.callback中的接口

AsyncBatchSendCallback author: gaohaoxiang date: 2018/12/20

asyncFetch(BrokerNode, String, String, int, long, long, long, FetchListener) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageFetcher

asyncFetch(BrokerNode, String, String, int, long, long, long, FetchListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

asyncFetch(BrokerNode, String, String, int, long, long, long, FetchListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

asyncFetchPartitionMessage(Map<String, Short>, String, int, long, CommandCallback) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

asyncFetchPartitionMessage(Table<String, Short, Long>, String, int, long, CommandCallback) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

asyncFetchTopicMessage(List<String>, String, int, long, long, long, CommandCallback) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

AsyncMultiBatchSendCallback - org.joyqueue.client.internal.producer.callback中的接口

AsyncMultiBatchSendCallback author: gaohaoxiang date: 2018/12/20

AsyncProduceCallback - org.joyqueue.client.internal.producer.callback中的接口

AsyncProduceCallback author: gaohaoxiang date: 2018/12/10

asyncProduceMessage(String, Map<String, ProduceMessageData>, long, CommandCallback) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClient

AsyncSendCallback - org.joyqueue.client.internal.producer.callback中的接口

AsyncSendCallback author: gaohaoxiang date: 2018/12/10

attributes() - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAdapter

attributes() - 类 中的方法io.openmessaging.joyqueue.MessagingAccessPointImpl

attributes() - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAdapter

B

BaseInterceptor - org.joyqueue.client.internal.common.interceptor中的接口

BaseInterceptor author: gaohaoxiang date: 2019/1/14

BaseMessageListener - org.joyqueue.client.internal.consumer中的接口

BaseMessageListener author: gaohaoxiang date: 2018/12/25

BATCH - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys

BATCH_BODY_LENGTH_LIMIT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys

BATCH_SIZE - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

batchCommitReply(Map<String, List<ConsumeReply>>, String, long) - 接口 中的方法org.joyqueue.client.internal.consumer.ConsumerIndexManager

batchCommitReply(Map<String, List<ConsumeReply>>, String, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultConsumerIndexManager

batchCommitReply(Map<String, List<ConsumeReply>>, String, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.LocalConsumerIndexManager

BatchConsumerInvoker - org.joyqueue.client.internal.consumer.support中的类

BatchConsumerInvoker author: gaohaoxiang date: 2019/1/11

BatchConsumerInvoker(ConsumerConfig, TopicMetadata, ConsumerPolicy, List<ConsumeMessage>, List<BatchMessageListener>) - 类 的构造器org.joyqueue.client.internal.consumer.support.BatchConsumerInvoker

batchFetch(BrokerNode, List<String>, String, int, long, long, long) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageFetcher

batchFetch(BrokerNode, List<String>, String, int, long, long, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

batchFetch(BrokerNode, List<String>, String, int, long, long, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

batchFetchAsync(BrokerNode, List<String>, String, int, long, long, long, BatchFetchListener) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageFetcher

batchFetchAsync(BrokerNode, List<String>, String, int, long, long, long, BatchFetchListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

batchFetchAsync(BrokerNode, List<String>, String, int, long, long, long, BatchFetchListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

batchFetchIndex(Map<String, List<Short>>, String, long) - 接口 中的方法org.joyqueue.client.internal.consumer.ConsumerIndexManager

batchFetchIndex(Map<String, List<Short>>, String, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultConsumerIndexManager

batchFetchIndex(Map<String, List<Short>>, String, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.LocalConsumerIndexManager

BatchFetchListener - org.joyqueue.client.internal.consumer.callback中的接口

BatchFetchListener author: gaohaoxiang date: 2018/12/10

batchFetchPartitions(BrokerNode, Map<String, Short>, String, int, long) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageFetcher

batchFetchPartitions(BrokerNode, Table<String, Short, Long>, String, int, long) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageFetcher

batchFetchPartitions(BrokerNode, Map<String, Short>, String, int, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

batchFetchPartitions(BrokerNode, Table<String, Short, Long>, String, int, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

batchFetchPartitions(BrokerNode, Map<String, Short>, String, int, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

batchFetchPartitions(BrokerNode, Table<String, Short, Long>, String, int, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

batchFetchPartitionsAsync(BrokerNode, Map<String, Short>, String, int, long, BatchPartitionFetchListener) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageFetcher

batchFetchPartitionsAsync(BrokerNode, Table<String, Short, Long>, String, int, long, BatchPartitionFetchListener) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageFetcher

batchFetchPartitionsAsync(BrokerNode, Map<String, Short>, String, int, long, BatchPartitionFetchListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

batchFetchPartitionsAsync(BrokerNode, Table<String, Short, Long>, String, int, long, BatchPartitionFetchListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

batchFetchPartitionsAsync(BrokerNode, Map<String, Short>, String, int, long, BatchPartitionFetchListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

batchFetchPartitionsAsync(BrokerNode, Table<String, Short, Long>, String, int, long, BatchPartitionFetchListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

BatchMessageListener - org.joyqueue.client.internal.consumer中的接口

BatchMessageListener author: gaohaoxiang date: 2018/12/25

BatchMessageListenerAdapter - io.openmessaging.joyqueue.consumer.support中的类

BatchMessageListenerAdapter author: gaohaoxiang date: 2019/2/20

BatchMessageListenerAdapter(BatchMessageListener) - 类 的构造器io.openmessaging.joyqueue.consumer.support.BatchMessageListenerAdapter

BatchMessageListenerContextAdapter - io.openmessaging.joyqueue.consumer.support中的类

BatchMessageListenerContextAdapter author: gaohaoxiang date: 2019/2/20

BatchMessageListenerContextAdapter() - 类 的构造器io.openmessaging.joyqueue.consumer.support.BatchMessageListenerContextAdapter

BatchPartitionFetchListener - org.joyqueue.client.internal.consumer.callback中的接口

BatchPartitionFetchListener author: gaohaoxiang date: 2018/12/10

batchReceive(short, long) - 接口 中的方法io.openmessaging.joyqueue.consumer.ExtensionConsumer

batchReceive(short, long, long) - 接口 中的方法io.openmessaging.joyqueue.consumer.ExtensionConsumer

batchReceive(long) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

batchReceive(short, long) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

batchReceive(short, long, long) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

batchReceive(short, long) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

batchReceive(short, long, long) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

batchReceive(long) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

batchSend(List<ProduceMessage>) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

batchSend(List<ProduceMessage>, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

batchSend(BrokerNode, String, String, String, List<ProduceMessage>, QosLevel, long, long) - 接口 中的方法org.joyqueue.client.internal.producer.MessageSender

batchSend(BrokerNode, String, String, Map<String, List<ProduceMessage>>, QosLevel, long, long) - 接口 中的方法org.joyqueue.client.internal.producer.MessageSender

batchSend(BrokerNode, String, String, String, List<ProduceMessage>, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

batchSend(BrokerNode, String, String, Map<String, List<ProduceMessage>>, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

batchSend(List<ProduceMessage>) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

batchSend(List<ProduceMessage>, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

batchSend(BrokerNode, String, String, String, List<ProduceMessage>, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

batchSend(BrokerNode, String, String, Map<String, List<ProduceMessage>>, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

batchSend(List<ProduceMessage>) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultTransactionMessageProducer

batchSend(List<ProduceMessage>, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultTransactionMessageProducer

batchSend(List<ProduceMessage>, String, long, TimeUnit, boolean, boolean, AsyncBatchProduceCallback) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

batchSend(List<ProduceMessage>) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

batchSend(List<ProduceMessage>, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

batchSend(List<ProduceMessage>) - 接口 中的方法org.joyqueue.client.internal.producer.TransactionMessageProducer

batchSend(List<ProduceMessage>, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.producer.TransactionMessageProducer

batchSendAsync(List<ProduceMessage>) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

batchSendAsync(List<ProduceMessage>, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

batchSendAsync(BrokerNode, String, String, String, List<ProduceMessage>, QosLevel, long, long, AsyncBatchSendCallback) - 接口 中的方法org.joyqueue.client.internal.producer.MessageSender

batchSendAsync(BrokerNode, String, String, String, List<ProduceMessage>, QosLevel, long, long) - 接口 中的方法org.joyqueue.client.internal.producer.MessageSender

batchSendAsync(BrokerNode, String, String, Map<String, List<ProduceMessage>>, QosLevel, long, long, AsyncMultiBatchSendCallback) - 接口 中的方法org.joyqueue.client.internal.producer.MessageSender

batchSendAsync(BrokerNode, String, String, Map<String, List<ProduceMessage>>, QosLevel, long, long) - 接口 中的方法org.joyqueue.client.internal.producer.MessageSender

batchSendAsync(BrokerNode, String, String, String, List<ProduceMessage>, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

batchSendAsync(BrokerNode, String, String, String, List<ProduceMessage>, QosLevel, long, long, AsyncBatchSendCallback) - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

batchSendAsync(BrokerNode, String, String, Map<String, List<ProduceMessage>>, QosLevel, long, long, AsyncMultiBatchSendCallback) - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

batchSendAsync(BrokerNode, String, String, Map<String, List<ProduceMessage>>, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

batchSendAsync(List<ProduceMessage>) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

batchSendAsync(List<ProduceMessage>, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

batchSendAsync(BrokerNode, String, String, String, List<ProduceMessage>, QosLevel, long, long, AsyncBatchSendCallback) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

batchSendAsync(BrokerNode, String, String, String, List<ProduceMessage>, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

batchSendAsync(BrokerNode, String, String, Map<String, List<ProduceMessage>>, QosLevel, long, long, AsyncMultiBatchSendCallback) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

batchSendAsync(BrokerNode, String, String, Map<String, List<ProduceMessage>>, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

batchSendAsync(List<ProduceMessage>) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

batchSendAsync(List<ProduceMessage>, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

batchSendOneway(List<ProduceMessage>) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

batchSendOneway(List<ProduceMessage>, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

batchSendOneway(BrokerNode, String, String, String, List<ProduceMessage>, QosLevel, long, long) - 接口 中的方法org.joyqueue.client.internal.producer.MessageSender

batchSendOneway(BrokerNode, String, String, Map<String, List<ProduceMessage>>, QosLevel, long, long) - 接口 中的方法org.joyqueue.client.internal.producer.MessageSender

batchSendOneway(BrokerNode, String, String, Map<String, List<ProduceMessage>>, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

batchSendOneway(BrokerNode, String, String, String, List<ProduceMessage>, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

batchSendOneway(List<ProduceMessage>) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

batchSendOneway(List<ProduceMessage>, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

batchSendOneway(BrokerNode, String, String, String, List<ProduceMessage>, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

batchSendOneway(BrokerNode, String, String, Map<String, List<ProduceMessage>>, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

batchSendOneway(List<ProduceMessage>) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

batchSendOneway(List<ProduceMessage>, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

begin(TraceContext) - 类 中的方法org.joyqueue.client.internal.trace.support.CompositeTrace

begin(TraceContext) - 类 中的方法org.joyqueue.client.internal.trace.support.NoneTrace

begin(TraceContext) - 类 中的方法org.joyqueue.client.internal.trace.support.TraceWrapper

begin(TraceContext) - 接口 中的方法org.joyqueue.client.internal.trace.Trace

begin(String, String, TraceType) - 类 中的方法org.joyqueue.client.internal.trace.TraceBuilder

begin() - 类 中的方法org.joyqueue.client.internal.trace.TraceBuilder

beginTransaction() - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

beginTransaction(long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

beginTransaction(String) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

beginTransaction(String, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

beginTransaction() - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

beginTransaction(long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

beginTransaction(String) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

beginTransaction(String, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

beginTransaction() - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

beginTransaction(long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

beginTransaction(String) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

beginTransaction(String, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

bindQueue(String) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

bindQueue(String, MessageListener) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

bindQueue(String, BatchMessageListener) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

bindQueue(String) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

bindQueue(String, MessageListener) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

bindQueue(String, BatchMessageListener) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

BODY_LENGTH_LIMIT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys

BROADCAST_GROUP - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

BROADCAST_INDEX_EXPIRE_TIME - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

BROADCAST_LOCAL_PATH - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

BROADCAST_PERSIST_INTERVAL - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

BroadcastMessagePoller - org.joyqueue.client.internal.consumer.support中的类

BroadcastMessagePoller author: gaohaoxiang date: 2018/12/14

BroadcastMessagePoller(ConsumerConfig, NameServerConfig, ClusterManager, ConsumerClientManager) - 类 的构造器org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

BrokerAssignment - org.joyqueue.client.internal.consumer.coordinator.domain中的类

BrokerAssignment author: gaohaoxiang date: 2018/12/11

BrokerAssignment() - 类 的构造器org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignment

BrokerAssignment(BrokerNode, PartitionAssignment) - 类 的构造器org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignment

BrokerAssignmentConverter - org.joyqueue.client.internal.consumer.converter中的类

BrokerAssignmentConverter author: gaohaoxiang date: 2018/12/17

BrokerAssignmentConverter() - 类 的构造器org.joyqueue.client.internal.consumer.converter.BrokerAssignmentConverter

BrokerAssignments - org.joyqueue.client.internal.consumer.coordinator.domain中的类

BrokerAssignments author: gaohaoxiang date: 2018/12/6

BrokerAssignments() - 类 的构造器org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignments

BrokerAssignments(List<BrokerAssignment>) - 类 的构造器org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignments

BrokerAssignmentsHolder - org.joyqueue.client.internal.consumer.coordinator.domain中的类

BrokerAssignmentsHolder author: gaohaoxiang date: 2018/12/11

BrokerAssignmentsHolder(BrokerAssignments, long) - 类 的构造器org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignmentsHolder

BrokerLoadBalance - org.joyqueue.client.internal.consumer中的接口

BrokerLoadBalance author: gaohaoxiang date: 2018/12/11

BrokerLoadBalanceManager - org.joyqueue.client.internal.consumer.support中的类

BrokerLoadBalanceManager author: gaohaoxiang date: 2019/1/3

BrokerLoadBalanceManager() - 类 的构造器org.joyqueue.client.internal.consumer.support.BrokerLoadBalanceManager

BrokerMessageConverter - org.joyqueue.client.internal.consumer.converter中的类

BrokerMessageConverter author: gaohaoxiang date: 2018/12/7

BrokerMessageConverter() - 类 的构造器org.joyqueue.client.internal.consumer.converter.BrokerMessageConverter

build(Client, TransportConfig, NameServerConfig) - 类 中的静态方法org.joyqueue.client.internal.cluster.ClusterClient

build(Client) - 类 中的静态方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

build(Client) - 类 中的静态方法org.joyqueue.client.internal.producer.transport.ProducerClient

buildAllBrokerAssignments(TopicMetadata) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.ConsumerCoordinator

buildAllBrokerAssignments(TopicMetadata) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

buildAllBrokerAssignments(TopicMetadata) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

buildCommitAckParams(Map<String, List<ConsumeReply>>, String) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultConsumerIndexManager

buildFetchIndexParams(Map<String, List<Short>>, String) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultConsumerIndexManager

buildFetchTopicMessageCommand(List<String>, String, int, long, long) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

buildPartitionTopicMessageCommand(Map<String, Short>, String, int) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

buildPartitionTopicMessageCommand(Table<String, Short, Long>, String, int) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

buildPollEmptyResult(PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

buildTraceCaller(TopicMetadata) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

BUSINESSID_LENGTH_LIMIT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys

C

CALLBACK_THREADS - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

cancel(boolean) - 类 中的方法io.openmessaging.joyqueue.producer.support.FutureAdapter

CHANNEL_MAX_IDLE_TIME - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

check(NameServerConfig) - 类 中的静态方法org.joyqueue.client.internal.nameserver.NameServerConfigChecker

check(TxFeedbackConfig) - 类 中的静态方法org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfigChecker

check(TransportConfig) - 类 中的静态方法org.joyqueue.client.internal.transport.config.TransportConfigChecker

checkAndConvertMessage(List<Message>) - 类 中的方法io.openmessaging.joyqueue.producer.support.ExtensionTransactionalResultAdapter

checkAndConvertMessage(List<Message>) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

checkMessage(ProduceMessage, ProducerConfig) - 类 中的静态方法org.joyqueue.client.internal.producer.checker.ProduceMessageChecker

checkMessages(List<ProduceMessage>, ProducerConfig) - 类 中的静态方法org.joyqueue.client.internal.producer.checker.ProduceMessageChecker

checkPrepare() - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultTransactionMessageProducer

checkState() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

checkState() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

checkState() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

checkState() - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

checkState() - 类 中的方法org.joyqueue.client.internal.producer.feedback.DefaultTxFeedbackManager

checkState() - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

checkState() - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

checkState() - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultTransactionMessageProducer

checkState() - 类 中的方法org.joyqueue.client.internal.transport.ClientManager

checkSubscribe() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

checkTopicMetadata(String) - 类 中的方法org.joyqueue.client.internal.producer.feedback.DefaultTxFeedbackManager

checkUnsubscribe() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

clearPartition(ProduceMessage) - 类 中的静态方法org.joyqueue.client.internal.producer.helper.ProducerHelper

clearPartitions(List<ProduceMessage>) - 类 中的静态方法org.joyqueue.client.internal.producer.helper.ProducerHelper

Client - org.joyqueue.client.internal.transport中的类

Client author: gaohaoxiang date: 2018/11/28

Client(BrokerNode, TransportConfig, TransportClient, NameServerConfig) - 类 的构造器org.joyqueue.client.internal.transport.Client

ClientConnectionInfo - org.joyqueue.client.internal.transport中的类

ClientConnectionInfo author: gaohaoxiang date: 2018/11/29

ClientConnectionInfo() - 类 的构造器org.joyqueue.client.internal.transport.ClientConnectionInfo

ClientConnectionListener - org.joyqueue.client.internal.transport中的类

ClientConnectionListener author: gaohaoxiang date: 2018/11/28

ClientConnectionListener(Transport, Client) - 类 的构造器org.joyqueue.client.internal.transport.ClientConnectionListener

ClientConnectionState - org.joyqueue.client.internal.transport中的类

ClientConnectionState author: gaohaoxiang date: 2018/12/3

ClientConnectionState(NameServerConfig, Client) - 类 的构造器org.joyqueue.client.internal.transport.ClientConnectionState

ClientConsts - org.joyqueue.client.internal中的类

ClientConsts author: gaohaoxiang date: 2019/3/5

ClientConsts() - 类 的构造器org.joyqueue.client.internal.ClientConsts

ClientException - org.joyqueue.client.internal.exception中的异常错误

ClientException author: gaohaoxiang date: 2018/11/29

ClientException() - 异常错误 的构造器org.joyqueue.client.internal.exception.ClientException

ClientException(String) - 异常错误 的构造器org.joyqueue.client.internal.exception.ClientException

ClientException(String, Throwable) - 异常错误 的构造器org.joyqueue.client.internal.exception.ClientException

ClientException(Throwable) - 异常错误 的构造器org.joyqueue.client.internal.exception.ClientException

ClientException(String, int) - 异常错误 的构造器org.joyqueue.client.internal.exception.ClientException

ClientException(String, int, Throwable) - 异常错误 的构造器org.joyqueue.client.internal.exception.ClientException

ClientGroup - org.joyqueue.client.internal.transport中的类

ClientGroup author: gaohaoxiang date: 2018/11/28

ClientGroup(BrokerNode, TransportConfig, TransportClient, NameServerConfig) - 类 的构造器org.joyqueue.client.internal.transport.ClientGroup

ClientGroupManager - org.joyqueue.client.internal.transport中的类

ClientGroupManager author: gaohaoxiang date: 2018/11/29

ClientGroupManager(TransportConfig) - 类 的构造器org.joyqueue.client.internal.transport.ClientGroupManager

ClientHeartbeatThread - org.joyqueue.client.internal.transport中的类

ClientHeartbeatThread author: gaohaoxiang date: 2019/1/7

ClientHeartbeatThread(TransportConfig, ClientGroupManager) - 类 的构造器org.joyqueue.client.internal.transport.ClientHeartbeatThread

ClientManager - org.joyqueue.client.internal.transport中的类

ClientManager author: gaohaoxiang date: 2018/11/28

ClientManager(TransportConfig, NameServerConfig) - 类 的构造器org.joyqueue.client.internal.transport.ClientManager

ClientState - org.joyqueue.client.internal.transport中的枚举

ClientState author: gaohaoxiang date: 2018/12/17

clone() - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

已过时。

close() - 类 中的方法org.joyqueue.client.internal.cluster.ClusterClient

close() - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

close() - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClient

closeClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClientManager

closeClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClientManager

closeClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.transport.ClientManager

closeClientGroup(ClientGroup) - 类 中的方法org.joyqueue.client.internal.transport.ClientGroupManager

closeClientGroup(BrokerNode) - 类 中的方法org.joyqueue.client.internal.transport.ClientGroupManager

ClusterClient - org.joyqueue.client.internal.cluster中的类

ProducerClient author: gaohaoxiang date: 2018/11/29

ClusterClient(Client, TransportConfig, NameServerConfig) - 类 的构造器org.joyqueue.client.internal.cluster.ClusterClient

ClusterClientManager - org.joyqueue.client.internal.cluster中的类

ClusterClientManager author: gaohaoxiang date: 2018/11/28

ClusterClientManager(TransportConfig, NameServerConfig) - 类 的构造器org.joyqueue.client.internal.cluster.ClusterClientManager

ClusterClientManagerFactory - org.joyqueue.client.internal.cluster中的类

ClusterClientManagerFactory author: gaohaoxiang date: 2018/12/27

ClusterClientManagerFactory() - 类 的构造器org.joyqueue.client.internal.cluster.ClusterClientManagerFactory

ClusterException - org.joyqueue.client.internal.cluster.exception中的异常错误

ClusterException author: gaohaoxiang date: 2018/12/3

ClusterException() - 异常错误 的构造器org.joyqueue.client.internal.cluster.exception.ClusterException

ClusterException(String) - 异常错误 的构造器org.joyqueue.client.internal.cluster.exception.ClusterException

ClusterException(String, Throwable) - 异常错误 的构造器org.joyqueue.client.internal.cluster.exception.ClusterException

ClusterException(Throwable) - 异常错误 的构造器org.joyqueue.client.internal.cluster.exception.ClusterException

ClusterException(String, int) - 异常错误 的构造器org.joyqueue.client.internal.cluster.exception.ClusterException

ClusterException(String, int, Throwable) - 异常错误 的构造器org.joyqueue.client.internal.cluster.exception.ClusterException

ClusterManager - org.joyqueue.client.internal.cluster中的类

ClusterManager author: gaohaoxiang date: 2018/11/28

ClusterManager(NameServerConfig, ClusterClientManager) - 类 的构造器org.joyqueue.client.internal.cluster.ClusterManager

ClusterManagerFactory - org.joyqueue.client.internal.cluster中的类

ClusterClientManagerFactory author: gaohaoxiang date: 2018/12/27

ClusterManagerFactory() - 类 的构造器org.joyqueue.client.internal.cluster.ClusterManagerFactory

ClusterManagerWrapper - org.joyqueue.client.internal.cluster中的类

ClusterManagerWrapper author: gaohaoxiang date: 2018/12/27

ClusterManagerWrapper(NameServerConfig, ClusterClientManager) - 类 的构造器org.joyqueue.client.internal.cluster.ClusterManagerWrapper

ClusterMetadata - org.joyqueue.client.internal.metadata.domain中的类

ClusterMetadata author: gaohaoxiang date: 2018/11/30

ClusterMetadata(Map<String, TopicMetadata>, Map<Integer, BrokerNode>) - 类 的构造器org.joyqueue.client.internal.metadata.domain.ClusterMetadata

ClusterMetadataConverter - org.joyqueue.client.internal.metadata.converter中的类

ClusterMetadataConverter author: gaohaoxiang date: 2018/12/3

ClusterMetadataConverter() - 类 的构造器org.joyqueue.client.internal.metadata.converter.ClusterMetadataConverter

commit() - 接口 中的方法io.openmessaging.joyqueue.producer.ExtensionTransactionalResult

commit() - 类 中的方法io.openmessaging.joyqueue.producer.support.ExtensionTransactionalResultAdapter

commit() - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionalContextAdapter

commit() - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionalResultAdapter

commit(BrokerNode, String, String, String, long) - 接口 中的方法org.joyqueue.client.internal.producer.MessageSender

commit(BrokerNode, String, String, String, long) - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

commit(BrokerNode, String, String, String, long) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

commit() - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultTransactionMessageProducer

commit() - 接口 中的方法org.joyqueue.client.internal.producer.TransactionMessageProducer

commitAck(Table<String, Short, List<CommitAckData>>, String, long) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

commitReply(String, List<ConsumeReply>, String, long) - 接口 中的方法org.joyqueue.client.internal.consumer.ConsumerIndexManager

commitReply(String, List<ConsumeReply>, String, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultConsumerIndexManager

commitReply(String, List<ConsumeReply>, String, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.LocalConsumerIndexManager

compare(Object, Object) - 类 中的方法org.joyqueue.client.internal.common.ordered.OrderedComparator

CompletableFutureAsyncBatchProduceCallback - org.joyqueue.client.internal.producer.callback中的类

CompletableFutureAsyncBatchProduceCallback author: gaohaoxiang date: 2019/7/25

CompletableFutureAsyncBatchProduceCallback(CompletableFuture<List<SendResult>>) - 类 的构造器org.joyqueue.client.internal.producer.callback.CompletableFutureAsyncBatchProduceCallback

CompletableFutureAsyncProduceCallback - org.joyqueue.client.internal.producer.callback中的类

CompletableFutureAsyncProduceCallback author: gaohaoxiang date: 2019/7/25

CompletableFutureAsyncProduceCallback(CompletableFuture<SendResult>) - 类 的构造器org.joyqueue.client.internal.producer.callback.CompletableFutureAsyncProduceCallback

CompletableFuturePollerListener - org.joyqueue.client.internal.consumer.support中的类

CompletableFuturePollerListener author: gaohaoxiang date: 2019/7/25

CompletableFuturePollerListener(CompletableFuture<List<ConsumeMessage>>) - 类 的构造器org.joyqueue.client.internal.consumer.support.CompletableFuturePollerListener

CompositeTrace - org.joyqueue.client.internal.trace.support中的类

CompositeTrace author: gaohaoxiang date: 2019/1/3

CompositeTrace(List<Trace>) - 类 的构造器org.joyqueue.client.internal.trace.support.CompositeTrace

CompositeTraceCaller - org.joyqueue.client.internal.trace.support中的类

CompositeTraceCaller author: gaohaoxiang date: 2019/1/3

CompositeTraceCaller(List<TraceCaller>) - 类 的构造器org.joyqueue.client.internal.trace.support.CompositeTraceCaller

COMPRESS - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys

compress(byte[], int, int, OutputStream) - 接口 中的方法org.joyqueue.client.internal.common.compress.Compressor

compress(byte[], String) - 类 中的静态方法org.joyqueue.client.internal.common.compress.CompressUtils

compress(byte[], Compressor) - 类 中的静态方法org.joyqueue.client.internal.common.compress.CompressUtils

compress(byte[], int, int, OutputStream, Compressor) - 类 中的静态方法org.joyqueue.client.internal.common.compress.CompressUtils

compress(byte[], int, int, OutputStream) - 类 中的方法org.joyqueue.client.internal.common.compress.support.SnappyCompressor

compress(byte[], int, int, OutputStream) - 类 中的方法org.joyqueue.client.internal.common.compress.support.ZlibCompressor

compress(BrokerMessage, boolean, int, String) - 类 中的静态方法org.joyqueue.client.internal.producer.converter.ProduceMessageConverter

COMPRESS_THRESHOLD - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys

COMPRESS_TYPE - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys

Compressor - org.joyqueue.client.internal.common.compress中的接口

Compressor author: gaohaoxiang date: 2019/1/2

CompressorManager - org.joyqueue.client.internal.common.compress中的类

CompressorManager author: gaohaoxiang date: 2019/1/2

CompressorManager() - 类 的构造器org.joyqueue.client.internal.common.compress.CompressorManager

COMPRESSORS - 接口 中的静态变量org.joyqueue.client.internal.Plugins

压缩插件

CompressUtils - org.joyqueue.client.internal.common.compress中的类

CompressUtils author: gaohaoxiang date: 2019/1/2

CompressUtils() - 类 的构造器org.joyqueue.client.internal.common.compress.CompressUtils

confirm(TopicName, String, String) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionStateCheckListenerAdapter

confirm(TopicName, String, String) - 接口 中的方法org.joyqueue.client.internal.producer.callback.TxFeedbackCallback

CONNECTIONS - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

ConnectionState - org.joyqueue.client.internal.transport中的类

ConnectionState author: gaohaoxiang date: 2019/2/12

ConnectionState() - 类 的构造器org.joyqueue.client.internal.transport.ConnectionState

ConsumeContext - org.joyqueue.client.internal.consumer.interceptor中的类

ConsumeContext author: gaohaoxiang date: 2019/1/11

ConsumeContext(String, String, NameServerConfig, List<ConsumeMessage>) - 类 的构造器org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

ConsumeMessage - org.joyqueue.client.internal.consumer.domain中的类

ConsumeMessage author: gaohaoxiang date: 2018/12/7

ConsumeMessage() - 类 的构造器org.joyqueue.client.internal.consumer.domain.ConsumeMessage

ConsumeMessage(TopicName, String, short, long, String, String, String, byte[], short, byte, long, byte, Map<String, String>) - 类 的构造器org.joyqueue.client.internal.consumer.domain.ConsumeMessage

ConsumeMessageConverter - org.joyqueue.client.internal.consumer.converter中的类

ConsumeMessageConverter author: gaohaoxiang date: 2019/1/11

ConsumeMessageConverter() - 类 的构造器org.joyqueue.client.internal.consumer.converter.ConsumeMessageConverter

CONSUMER_INTERCEPTOR - 接口 中的静态变量org.joyqueue.client.internal.Plugins

消费拦截器插件

ConsumerClient - org.joyqueue.client.internal.consumer.transport中的类

ConsumerClient author: gaohaoxiang date: 2018/11/29

ConsumerClient(Client) - 类 的构造器org.joyqueue.client.internal.consumer.transport.ConsumerClient

ConsumerClientConnectionListener - org.joyqueue.client.internal.consumer.transport中的类

ClientConnectionListener author: gaohaoxiang date: 2018/11/28

ConsumerClientConnectionListener(Transport, ConsumerClient) - 类 的构造器org.joyqueue.client.internal.consumer.transport.ConsumerClientConnectionListener

ConsumerClientGroup - org.joyqueue.client.internal.consumer.transport中的类

ConsumerClientGroup author: gaohaoxiang date: 2019/2/12

ConsumerClientGroup(ClientGroup) - 类 的构造器org.joyqueue.client.internal.consumer.transport.ConsumerClientGroup

ConsumerClientManager - org.joyqueue.client.internal.consumer.transport中的类

ConsumerClientManager author: gaohaoxiang date: 2018/11/28

ConsumerClientManager(TransportConfig, NameServerConfig) - 类 的构造器org.joyqueue.client.internal.consumer.transport.ConsumerClientManager

ConsumerClientManagerFactory - org.joyqueue.client.internal.consumer.transport中的类

ConsumerClientManagerFactory author: gaohaoxiang date: 2018/12/27

ConsumerClientManagerFactory() - 类 的构造器org.joyqueue.client.internal.consumer.transport.ConsumerClientManagerFactory

ConsumerConfig - org.joyqueue.client.internal.consumer.config中的类

ConsumerConfig author: gaohaoxiang date: 2018/12/7

ConsumerConfig() - 类 的构造器org.joyqueue.client.internal.consumer.config.ConsumerConfig

ConsumerConnectionState - org.joyqueue.client.internal.consumer.transport中的类

ConsumerConnectionState author: gaohaoxiang date: 2018/12/3

ConsumerConnectionState(ConsumerClient) - 类 的构造器org.joyqueue.client.internal.consumer.transport.ConsumerConnectionState

ConsumerCoordinator - org.joyqueue.client.internal.consumer.coordinator中的类

ConsumerCoordinator author: gaohaoxiang date: 2018/12/6

ConsumerCoordinator(ClusterClientManager) - 类 的构造器org.joyqueue.client.internal.consumer.coordinator.ConsumerCoordinator

ConsumeReply - org.joyqueue.client.internal.consumer.domain中的类

ConsumeReply author: gaohaoxiang date: 2018/12/12

ConsumeReply() - 类 的构造器org.joyqueue.client.internal.consumer.domain.ConsumeReply

ConsumeReply(short, long) - 类 的构造器org.joyqueue.client.internal.consumer.domain.ConsumeReply

ConsumeReply(short, long, RetryType) - 类 的构造器org.joyqueue.client.internal.consumer.domain.ConsumeReply

ConsumerException - org.joyqueue.client.internal.consumer.exception中的异常错误

ConsumerException author: gaohaoxiang date: 2018/12/20

ConsumerException() - 异常错误 的构造器org.joyqueue.client.internal.consumer.exception.ConsumerException

ConsumerException(String) - 异常错误 的构造器org.joyqueue.client.internal.consumer.exception.ConsumerException

ConsumerException(String, Throwable) - 异常错误 的构造器org.joyqueue.client.internal.consumer.exception.ConsumerException

ConsumerException(Throwable) - 异常错误 的构造器org.joyqueue.client.internal.consumer.exception.ConsumerException

ConsumerException(String, int) - 异常错误 的构造器org.joyqueue.client.internal.consumer.exception.ConsumerException

ConsumerException(String, int, Throwable) - 异常错误 的构造器org.joyqueue.client.internal.consumer.exception.ConsumerException

ConsumerImpl - io.openmessaging.joyqueue.consumer.support中的类

ConsumerImpl author: gaohaoxiang date: 2019/2/19

ConsumerImpl(MessageConsumer) - 类 的构造器io.openmessaging.joyqueue.consumer.support.ConsumerImpl

ConsumerIndex - io.openmessaging.joyqueue.consumer中的类

ConsumerIndex author: gaohaoxiang date: 2019/11/12

ConsumerIndex(long, long, long) - 类 的构造器io.openmessaging.joyqueue.consumer.ConsumerIndex

ConsumerIndexManager - org.joyqueue.client.internal.consumer中的接口

ConsumerIndexManager author: gaohaoxiang date: 2018/12/12

ConsumerInterceptor - org.joyqueue.client.internal.consumer.interceptor中的接口

ConsumerInterceptor author: gaohaoxiang date: 2019/1/11

ConsumerInterceptorAdapter - io.openmessaging.joyqueue.consumer.support中的类

ConsumerInterceptorAdapter author: gaohaoxiang date: 2019/2/20

ConsumerInterceptorAdapter(ConsumerInterceptor) - 类 的构造器io.openmessaging.joyqueue.consumer.support.ConsumerInterceptorAdapter

ConsumerInterceptorManager - org.joyqueue.client.internal.consumer.interceptor中的类

ConsumerInterceptorManager author: gaohaoxiang date: 2019/1/11

ConsumerInterceptorManager() - 类 的构造器org.joyqueue.client.internal.consumer.interceptor.ConsumerInterceptorManager

ConsumerInvocation - org.joyqueue.client.internal.consumer.interceptor中的类

ConsumerInvocation author: gaohaoxiang date: 2019/1/11

ConsumerInvocation(ConsumerConfig, String, NameServerConfig, List<ConsumeMessage>, ConsumerInterceptorManager, ConsumerInvoker) - 类 的构造器org.joyqueue.client.internal.consumer.interceptor.ConsumerInvocation

ConsumerInvoker - org.joyqueue.client.internal.consumer.interceptor中的接口

ConsumerInvoker author: gaohaoxiang date: 2019/1/11

ConsumerLocalIndexStore - org.joyqueue.client.internal.consumer.support中的类

ConsumerLocalIndexStore author: gaohaoxiang date: 2018/12/14

ConsumerLocalIndexStore(String, int) - 类 的构造器org.joyqueue.client.internal.consumer.support.ConsumerLocalIndexStore

ConsumerWrapper - io.openmessaging.joyqueue.support中的类

ConsumerWrapper author: gaohaoxiang date: 2019/5/14

ConsumerWrapper(ExtensionConsumer, MessageAccessPointHolder) - 类 的构造器io.openmessaging.joyqueue.support.ConsumerWrapper

containsAttribute(String) - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

containsAttribute(Object) - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

containsAttribute(String) - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

containsAttribute(Object) - 类 中的方法org.joyqueue.client.internal.producer.interceptor.ProduceContext

containsKey(String) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

containsKey(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

containsKey(String) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

containsKey(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

context() - 类 中的方法org.joyqueue.client.internal.trace.TraceBuilder

ContextAdapter - io.openmessaging.joyqueue.consumer.interceptor中的类

ContextAdapter author: gaohaoxiang date: 2019/3/1

ContextAdapter(ConsumeContext) - 类 的构造器io.openmessaging.joyqueue.consumer.interceptor.ContextAdapter

ContextAdapter - io.openmessaging.joyqueue.producer.interceptor中的类

ContextAdapter author: gaohaoxiang date: 2019/3/1

ContextAdapter(ProduceContext) - 类 的构造器io.openmessaging.joyqueue.producer.interceptor.ContextAdapter

ContextAttributeAdapter - io.openmessaging.joyqueue.consumer.interceptor中的类

ContextAttributeAdapter author: gaohaoxiang date: 2019/3/1

ContextAttributeAdapter(ConsumeContext) - 类 的构造器io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

ContextAttributeAdapter - io.openmessaging.joyqueue.producer.interceptor中的类

ContextAttributeAdapter author: gaohaoxiang date: 2019/3/1

ContextAttributeAdapter(ProduceContext) - 类 的构造器io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

convert(TopicMetadata) - 类 中的静态方法io.openmessaging.joyqueue.extension.TopicMetadataConverter

convert(List<SendResult>) - 类 中的静态方法io.openmessaging.joyqueue.producer.support.SendResultConverter

convert(SendResult) - 类 中的静态方法io.openmessaging.joyqueue.producer.support.SendResultConverter

convert(String, Table<String, Short, FetchPartitionMessageAckData>) - 类 中的静态方法org.joyqueue.client.internal.consumer.converter.BrokerMessageConverter

convert(String, Map<String, FetchTopicMessageAckData>) - 类 中的静态方法org.joyqueue.client.internal.consumer.converter.BrokerMessageConverter

convert(String, String, List<BrokerMessage>) - 类 中的静态方法org.joyqueue.client.internal.consumer.converter.BrokerMessageConverter

convert(String, String, BrokerMessage) - 类 中的静态方法org.joyqueue.client.internal.consumer.converter.BrokerMessageConverter

convert(BrokerMessage) - 接口 中的方法org.joyqueue.client.internal.consumer.converter.MessageConverter

convert(List<BrokerMessage>) - 类 中的方法org.joyqueue.client.internal.consumer.converter.MessageConvertSupport

convert(BrokerMessage) - 类 中的方法org.joyqueue.client.internal.consumer.converter.MessageConvertSupport

convert(FetchClusterResponse) - 类 中的静态方法org.joyqueue.client.internal.metadata.converter.ClusterMetadataConverter

convertBatch(String, String, BrokerMessage) - 类 中的静态方法org.joyqueue.client.internal.consumer.converter.BrokerMessageConverter

convertBatch(BrokerMessage) - 接口 中的方法org.joyqueue.client.internal.consumer.converter.MessageConverter

convertBatch(BrokerMessage) - 类 中的方法org.joyqueue.client.internal.consumer.converter.MessageConvertSupport

convertBrokerAssignments(TopicMetadata) - 类 中的静态方法org.joyqueue.client.internal.consumer.converter.BrokerAssignmentConverter

convertConsumeException(Throwable) - 类 中的静态方法io.openmessaging.joyqueue.config.ExceptionConverter

convertConsumerConfig(KeyValue) - 类 中的静态方法io.openmessaging.joyqueue.config.KeyValueConverter

convertConsumerConfig(NameServerConfig, KeyValue) - 类 中的静态方法io.openmessaging.joyqueue.config.KeyValueConverter

convertFeedbackConfig(KeyValue) - 类 中的静态方法io.openmessaging.joyqueue.config.KeyValueConverter

convertFeedbackConfig(NameServerConfig, KeyValue) - 类 中的静态方法io.openmessaging.joyqueue.config.KeyValueConverter

convertMessage(ConsumeMessage) - 类 中的静态方法io.openmessaging.joyqueue.consumer.message.MessageConverter

convertMessages(List<ConsumeMessage>) - 类 中的静态方法io.openmessaging.joyqueue.consumer.message.MessageConverter

convertNameServerConfig(KeyValue) - 类 中的静态方法io.openmessaging.joyqueue.config.KeyValueConverter

convertPartitionGroupMetadata(String, TopicPartitionGroup, Map<Integer, BrokerNode>) - 类 中的静态方法org.joyqueue.client.internal.metadata.converter.ClusterMetadataConverter

convertPartitionMetadata(String, TopicPartition, int, BrokerNode) - 类 中的静态方法org.joyqueue.client.internal.metadata.converter.ClusterMetadataConverter

convertProduceException(Throwable) - 类 中的静态方法io.openmessaging.joyqueue.config.ExceptionConverter

convertProducerConfig(KeyValue) - 类 中的静态方法io.openmessaging.joyqueue.config.KeyValueConverter

convertProducerConfig(NameServerConfig, KeyValue) - 类 中的静态方法io.openmessaging.joyqueue.config.KeyValueConverter

convertRuntimeException(Throwable) - 类 中的静态方法io.openmessaging.joyqueue.config.ExceptionConverter

convertToBatchBrokerMessage(String, String, List<ProduceMessage>, boolean, int, String) - 类 中的静态方法org.joyqueue.client.internal.producer.converter.ProduceMessageConverter

convertToBatchResultData(String, String, ProduceMessageAckData) - 类 中的静态方法org.joyqueue.client.internal.producer.converter.MessageSenderConverter

convertToBrokerMessage(String, String, ProduceMessage, boolean, int, String) - 类 中的静态方法org.joyqueue.client.internal.producer.converter.ProduceMessageConverter

convertToBrokerMessage(String, String, ProduceMessage) - 类 中的静态方法org.joyqueue.client.internal.producer.converter.ProduceMessageConverter

convertToBrokerMessages(String, String, List<ProduceMessage>, boolean, int, String, boolean) - 类 中的静态方法org.joyqueue.client.internal.producer.converter.ProduceMessageConverter

convertToBrokerMessages(String, String, List<ProduceMessage>, boolean, int, String) - 类 中的静态方法org.joyqueue.client.internal.producer.converter.ProduceMessageConverter

convertToClientConfig(TransportConfig) - 类 中的方法org.joyqueue.client.internal.transport.ClientManager

convertToCodeList(List<TopicMetadata>) - 类 中的静态方法org.joyqueue.client.internal.consumer.converter.TopicMetadataConverter

convertToFetchFeedbackData(String, String, FetchProduceFeedbackResponse) - 类 中的静态方法org.joyqueue.client.internal.producer.converter.MessageSenderConverter

convertToMap(List<TopicMetadata>) - 类 中的静态方法org.joyqueue.client.internal.consumer.converter.TopicMetadataConverter

convertTopicAssignments(TopicMetadata) - 类 中的静态方法org.joyqueue.client.internal.consumer.converter.BrokerAssignmentConverter

convertTopicMetadata(String, Topic, Map<Integer, BrokerNode>) - 类 中的静态方法org.joyqueue.client.internal.metadata.converter.ClusterMetadataConverter

convertToProduceMessageData(String, String, String, List<ProduceMessage>, QosLevel, long, boolean, int, String, boolean) - 类 中的静态方法org.joyqueue.client.internal.producer.converter.MessageSenderConverter

convertToReply(List<ConsumeMessage>, RetryType) - 类 中的静态方法org.joyqueue.client.internal.consumer.converter.ConsumeMessageConverter

convertTransportConfig(KeyValue) - 类 中的静态方法io.openmessaging.joyqueue.config.KeyValueConverter

CoordinatorManager - org.joyqueue.client.internal.consumer.coordinator中的类

CoordinatorManager author: gaohaoxiang date: 2018/12/4

CoordinatorManager(ClusterClientManager) - 类 的构造器org.joyqueue.client.internal.consumer.coordinator.CoordinatorManager

copy() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

copy() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

copy() - 类 中的方法org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfig

copy() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

create(String, String, String) - 类 中的静态方法org.joyqueue.client.internal.cluster.ClusterClientManagerFactory

create(String, String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.cluster.ClusterClientManagerFactory

create(NameServerConfig) - 类 中的静态方法org.joyqueue.client.internal.cluster.ClusterClientManagerFactory

create(NameServerConfig, TransportConfig) - 类 中的静态方法org.joyqueue.client.internal.cluster.ClusterClientManagerFactory

create(String, String, String) - 类 中的静态方法org.joyqueue.client.internal.cluster.ClusterManagerFactory

create(String, String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.cluster.ClusterManagerFactory

create(NameServerConfig) - 类 中的静态方法org.joyqueue.client.internal.cluster.ClusterManagerFactory

create(NameServerConfig, TransportConfig) - 类 中的静态方法org.joyqueue.client.internal.cluster.ClusterManagerFactory

create(NameServerConfig, ClusterClientManager) - 类 中的静态方法org.joyqueue.client.internal.cluster.ClusterManagerFactory

create(String, String, String) - 类 中的静态方法org.joyqueue.client.internal.consumer.container.MessageListenerContainerFactory

已过时。

create(String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.consumer.container.MessageListenerContainerFactory

已过时。

create(String, String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.consumer.container.MessageListenerContainerFactory

已过时。

create(ConsumerConfig, NameServerConfig) - 类 中的静态方法org.joyqueue.client.internal.consumer.container.MessageListenerContainerFactory

已过时。

create(ConsumerConfig, NameServerConfig, TransportConfig) - 类 中的静态方法org.joyqueue.client.internal.consumer.container.MessageListenerContainerFactory

已过时。

create(ConsumerConfig, NameServerConfig, ConsumerClientManager) - 类 中的静态方法org.joyqueue.client.internal.consumer.container.MessageListenerContainerFactory

已过时。

create(ConsumerConfig, NameServerConfig, TransportConfig, ConsumerClientManager) - 类 中的静态方法org.joyqueue.client.internal.consumer.container.MessageListenerContainerFactory

已过时。

create(ConsumerConfig, NameServerConfig, ClusterClientManager, ConsumerClientManager) - 类 中的静态方法org.joyqueue.client.internal.consumer.container.MessageListenerContainerFactory

已过时。

create(ConsumerConfig, NameServerConfig, ClusterManager, ClusterClientManager, ConsumerClientManager) - 类 中的静态方法org.joyqueue.client.internal.consumer.container.MessageListenerContainerFactory

已过时。

create(String, String, String) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageConsumerFactory

create(String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageConsumerFactory

create(String, String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageConsumerFactory

create(ConsumerConfig, NameServerConfig) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageConsumerFactory

create(ConsumerConfig, NameServerConfig, TransportConfig) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageConsumerFactory

create(ConsumerConfig, NameServerConfig, ConsumerClientManager) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageConsumerFactory

create(ConsumerConfig, NameServerConfig, TransportConfig, ConsumerClientManager) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageConsumerFactory

create(ConsumerConfig, NameServerConfig, ClusterClientManager, ConsumerClientManager) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageConsumerFactory

create(ConsumerConfig, NameServerConfig, ClusterManager, ClusterClientManager, ConsumerClientManager) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageConsumerFactory

create(String, String, String) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageFetcherFactory

create(String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageFetcherFactory

create(String, String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageFetcherFactory

create(NameServerConfig) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageFetcherFactory

create(NameServerConfig, FetcherConfig) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageFetcherFactory

create(TransportConfig, NameServerConfig, FetcherConfig) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageFetcherFactory

create(ConsumerClientManager, FetcherConfig) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessageFetcherFactory

create(String, String, String) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessagePollerFactory

create(String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessagePollerFactory

create(String, String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessagePollerFactory

create(ConsumerConfig, NameServerConfig) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessagePollerFactory

create(ConsumerConfig, NameServerConfig, TransportConfig) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessagePollerFactory

create(ConsumerConfig, NameServerConfig, ConsumerClientManager) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessagePollerFactory

create(ConsumerConfig, NameServerConfig, TransportConfig, ConsumerClientManager) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessagePollerFactory

create(ConsumerConfig, NameServerConfig, ClusterClientManager, ConsumerClientManager) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessagePollerFactory

create(ConsumerConfig, NameServerConfig, ClusterManager, ClusterClientManager, ConsumerClientManager) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessagePollerFactory

create(String, String, String) - 类 中的静态方法org.joyqueue.client.internal.consumer.transport.ConsumerClientManagerFactory

create(String, String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.consumer.transport.ConsumerClientManagerFactory

create(NameServerConfig) - 类 中的静态方法org.joyqueue.client.internal.consumer.transport.ConsumerClientManagerFactory

create(NameServerConfig, TransportConfig) - 类 中的静态方法org.joyqueue.client.internal.consumer.transport.ConsumerClientManagerFactory

create(String, String, String) - 类 中的静态方法org.joyqueue.client.internal.MessageAccessPointFactory

create(String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.MessageAccessPointFactory

create(String, String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.MessageAccessPointFactory

create(NameServerConfig, TransportConfig) - 类 中的静态方法org.joyqueue.client.internal.MessageAccessPointFactory

create(String, String, String) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageProducerFactory

create(String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageProducerFactory

create(String, String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageProducerFactory

create(ProducerConfig, NameServerConfig) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageProducerFactory

create(ProducerConfig, NameServerConfig, TransportConfig) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageProducerFactory

create(ProducerConfig, NameServerConfig, ProducerClientManager) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageProducerFactory

create(ProducerConfig, NameServerConfig, TransportConfig, ProducerClientManager) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageProducerFactory

create(ProducerConfig, NameServerConfig, ClusterClientManager, ProducerClientManager) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageProducerFactory

create(ProducerConfig, NameServerConfig, ClusterManager, ProducerClientManager) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageProducerFactory

create(String, String, String) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageSenderFactory

create(String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageSenderFactory

create(String, String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageSenderFactory

create(NameServerConfig) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageSenderFactory

create(NameServerConfig, SenderConfig) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageSenderFactory

create(NameServerConfig, TransportConfig, SenderConfig) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageSenderFactory

create(ProducerClientManager, SenderConfig) - 类 中的静态方法org.joyqueue.client.internal.producer.MessageSenderFactory

create(String, String, String) - 类 中的静态方法org.joyqueue.client.internal.producer.transport.ProducerClientManagerFactory

create(String, String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.producer.transport.ProducerClientManagerFactory

create(NameServerConfig) - 类 中的静态方法org.joyqueue.client.internal.producer.transport.ProducerClientManagerFactory

create(NameServerConfig, TransportConfig) - 类 中的静态方法org.joyqueue.client.internal.producer.transport.ProducerClientManagerFactory

create(String, String, String) - 类 中的静态方法org.joyqueue.client.internal.producer.TxFeedbackManagerFactory

create(String, String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.producer.TxFeedbackManagerFactory

create(TxFeedbackConfig, NameServerConfig) - 类 中的静态方法org.joyqueue.client.internal.producer.TxFeedbackManagerFactory

create(TxFeedbackConfig, NameServerConfig, TransportConfig) - 类 中的静态方法org.joyqueue.client.internal.producer.TxFeedbackManagerFactory

create(TxFeedbackConfig, NameServerConfig, ClusterManager) - 类 中的静态方法org.joyqueue.client.internal.producer.TxFeedbackManagerFactory

create(TxFeedbackConfig, NameServerConfig, TransportConfig, ClusterManager) - 类 中的静态方法org.joyqueue.client.internal.producer.TxFeedbackManagerFactory

create(TxFeedbackConfig, NameServerConfig, ClusterManager, ProducerClientManager) - 类 中的静态方法org.joyqueue.client.internal.producer.TxFeedbackManagerFactory

createBroadcastPoller(ConsumerConfig, NameServerConfig, ClusterManager, ConsumerClientManager) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessagePollerFactory

createClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.cluster.ClusterClientManager

createClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClientManager

createClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClientManager

createClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.transport.ClientManager

createConfig(String, String, String) - 类 中的静态方法org.joyqueue.client.internal.nameserver.helper.NameServerHelper

createConfig(String, String, String, String, String) - 类 中的静态方法org.joyqueue.client.internal.nameserver.helper.NameServerHelper

createConsumer() - 类 中的方法io.openmessaging.joyqueue.MessagingAccessPointImpl

createConsumer() - 接口 中的方法org.joyqueue.client.internal.MessageAccessPoint

createConsumer(String) - 接口 中的方法org.joyqueue.client.internal.MessageAccessPoint

createConsumer(ConsumerConfig) - 接口 中的方法org.joyqueue.client.internal.MessageAccessPoint

createConsumer() - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

createConsumer(String) - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

createConsumer(ConsumerConfig) - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

createMessage(String, String) - 接口 中的方法io.openmessaging.joyqueue.producer.extension.ExtensionMessageFactory

createMessage(String, byte[]) - 类 中的方法io.openmessaging.joyqueue.producer.message.ExtensionMessageFactoryImpl

createMessage(String, String) - 类 中的方法io.openmessaging.joyqueue.producer.message.ExtensionMessageFactoryImpl

createMessage(String, byte[]) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

createMessage(String, String) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

createMessage(String, byte[]) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

createMessage(String, String) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

createMessage(String, byte[]) - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

createMessage(String, String) - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

createMessageConsumer(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumer

createMessageFactory() - 类 中的方法io.openmessaging.joyqueue.MessagingAccessPointImpl

createPartitionPoller(ConsumerConfig, NameServerConfig, ClusterManager, ConsumerClientManager, ConsumerIndexManager) - 类 中的静态方法org.joyqueue.client.internal.consumer.MessagePollerFactory

createPoller() - 接口 中的方法org.joyqueue.client.internal.MessageAccessPoint

createPoller(String) - 接口 中的方法org.joyqueue.client.internal.MessageAccessPoint

createPoller(ConsumerConfig) - 接口 中的方法org.joyqueue.client.internal.MessageAccessPoint

createPoller() - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

createPoller(String) - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

createPoller(ConsumerConfig) - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

createProducer() - 类 中的方法io.openmessaging.joyqueue.MessagingAccessPointImpl

createProducer(TransactionStateCheckListener) - 类 中的方法io.openmessaging.joyqueue.MessagingAccessPointImpl

createProducer() - 接口 中的方法org.joyqueue.client.internal.MessageAccessPoint

createProducer(ProducerConfig) - 接口 中的方法org.joyqueue.client.internal.MessageAccessPoint

createProducer() - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

createProducer(ProducerConfig) - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

createTopicMessageConsumer(String) - 类 中的方法org.joyqueue.client.internal.consumer.container.DefaultMessageListenerContainer

currentState() - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

currentState() - 类 中的方法io.openmessaging.joyqueue.support.AbstractServiceLifecycle

currentState() - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

currentState() - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

D

decompress(byte[], int, int, OutputStream) - 接口 中的方法org.joyqueue.client.internal.common.compress.Compressor

decompress(byte[], String) - 类 中的静态方法org.joyqueue.client.internal.common.compress.CompressUtils

decompress(byte[], Compressor) - 类 中的静态方法org.joyqueue.client.internal.common.compress.CompressUtils

decompress(byte[], int, int, OutputStream, Compressor) - 类 中的静态方法org.joyqueue.client.internal.common.compress.CompressUtils

decompress(byte[], int, int, OutputStream) - 类 中的方法org.joyqueue.client.internal.common.compress.support.SnappyCompressor

decompress(byte[], int, int, OutputStream) - 类 中的方法org.joyqueue.client.internal.common.compress.support.ZlibCompressor

DefaultConsumerIndexManager - org.joyqueue.client.internal.consumer.support中的类

DefaultConsumerIndexManager author: gaohaoxiang date: 2018/12/12

DefaultConsumerIndexManager(ClusterManager, ConsumerClientManager) - 类 的构造器org.joyqueue.client.internal.consumer.support.DefaultConsumerIndexManager

DefaultMessageAccessPoint - org.joyqueue.client.internal.support中的类

DefaultMessageAccessPoint author: gaohaoxiang date: 2019/2/19

DefaultMessageAccessPoint(NameServerConfig, TransportConfig) - 类 的构造器org.joyqueue.client.internal.support.DefaultMessageAccessPoint

DefaultMessageConsumer - org.joyqueue.client.internal.consumer.support中的类

DefaultMessageConsumer author: gaohaoxiang date: 2019/1/10

DefaultMessageConsumer(ConsumerConfig, NameServerConfig, ClusterManager, ClusterClientManager, ConsumerClientManager) - 类 的构造器org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

DefaultMessageFetcher - org.joyqueue.client.internal.consumer.support中的类

DefaultMessageFetcher author: gaohaoxiang date: 2018/12/7

DefaultMessageFetcher(ConsumerClientManager, FetcherConfig) - 类 的构造器org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

DefaultMessageListenerContainer - org.joyqueue.client.internal.consumer.container中的类

DefaultMessageListenerContainer author: gaohaoxiang date: 2018/12/25

DefaultMessageListenerContainer(ConsumerConfig, NameServerConfig, ClusterManager, ClusterClientManager, ConsumerClientManager) - 类 的构造器org.joyqueue.client.internal.consumer.container.DefaultMessageListenerContainer

DefaultMessagePoller - org.joyqueue.client.internal.consumer.support中的类

DefaultMessagePoller author: gaohaoxiang date: 2018/12/11

DefaultMessagePoller(ConsumerConfig, NameServerConfig, ClusterManager, ClusterClientManager, ConsumerClientManager) - 类 的构造器org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

DefaultMessageProducer - org.joyqueue.client.internal.producer.support中的类

DefaultMessageProducer author: gaohaoxiang date: 2018/12/10

DefaultMessageProducer(ProducerConfig, NameServerConfig, ClusterManager, ProducerClientManager) - 类 的构造器org.joyqueue.client.internal.producer.support.DefaultMessageProducer

DefaultMessageSender - org.joyqueue.client.internal.producer.support中的类

DefaultMessageSender author: gaohaoxiang date: 2018/12/10

DefaultMessageSender(ProducerClientManager, SenderConfig) - 类 的构造器org.joyqueue.client.internal.producer.support.DefaultMessageSender

DefaultTransactionMessageProducer - org.joyqueue.client.internal.producer.support中的类

DefaultTransactionMessageProducer author: gaohaoxiang date: 2018/12/20

DefaultTransactionMessageProducer(String, long, TimeUnit, long, ProducerConfig, NameServerConfig, ClusterManager, MessageSender, MessageProducerInner) - 类 的构造器org.joyqueue.client.internal.producer.support.DefaultTransactionMessageProducer

DefaultTxFeedbackManager - org.joyqueue.client.internal.producer.feedback中的类

TxFeedbackManager author: gaohaoxiang date: 2018/12/24

DefaultTxFeedbackManager(TxFeedbackConfig, NameServerConfig, ClusterManager, MessageSender) - 类 的构造器org.joyqueue.client.internal.producer.feedback.DefaultTxFeedbackManager

dispatch() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumerDispatcher

dispatch() - 类 中的方法org.joyqueue.client.internal.producer.feedback.TxFeedbackDispatcher

dispatchPartitions(List<ProduceMessage>, TopicMetadata, List<PartitionMetadata>, PartitionSelector) - 类 中的静态方法org.joyqueue.client.internal.producer.helper.ProducerHelper

dispatchPartitions(List<ProduceMessage>, TopicMetadata, List<PartitionMetadata>) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

dispatchPartitions(List<ProduceMessage>, TopicMetadata, List<PartitionMetadata>, List<PartitionMetadata>) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

doAddListener(String, BaseMessageListener) - 类 中的方法org.joyqueue.client.internal.consumer.container.DefaultMessageListenerContainer

doBatchDispatch(TopicMetadata, ConsumerPolicy, List<ConsumeMessage>, List<BatchMessageListener>) - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumerDispatcher

doBatchSend(List<ProduceMessage>, long, TimeUnit, boolean, AsyncBatchProduceCallback) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

doBatchSend(List<ProduceMessage>, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultTransactionMessageProducer

doBatchSend(List<ProduceMessage>, String, long, TimeUnit, boolean, boolean, AsyncBatchProduceCallback) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

doBatchSend(List<ProduceMessage>, TopicMetadata, PartitionMetadata, List<PartitionMetadata>, String, long, TimeUnit, boolean, boolean, AsyncBatchProduceCallback) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

doBatchSendInternal(List<ProduceMessage>, TopicMetadata, PartitionMetadata, List<PartitionMetadata>, String, long, TimeUnit, boolean, boolean, AsyncBatchProduceCallback) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

doConfirm(BrokerNode, TopicMetadata, FeedbackData) - 类 中的方法org.joyqueue.client.internal.producer.feedback.TxFeedbackDispatcher

doDispatch(TopicMetadata, ConsumerPolicy, List<ConsumeMessage>) - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumerDispatcher

doFeedback(TopicMetadata, BrokerNode) - 类 中的方法org.joyqueue.client.internal.producer.feedback.TxFeedbackDispatcher

doFetchPartition(BrokerNode, TopicMetadata, short, long, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

doFetchTopic(BrokerNode, TopicMetadata, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

doGetClient() - 类 中的方法org.joyqueue.client.internal.transport.ClientGroup

doGetOrCreateClient() - 类 中的方法org.joyqueue.client.internal.cluster.ClusterClientManager

doGetOrCreateClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.transport.ClientManager

doGetOrCreateClientGroup(BrokerNode) - 类 中的方法org.joyqueue.client.internal.transport.ClientManager

doHandleAddConsumers(List<String>, String) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerConnectionState

doHandleAddProducers(List<String>, String) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerConnectionState

doHandleNotification(AddConnectionResponse) - 类 中的方法org.joyqueue.client.internal.transport.ClientConnectionState

doHandleRemoveConsumers(List<String>, String) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerConnectionState

doHandleRemoveProducers(List<String>, String) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerConnectionState

doHeartbeat(ClientGroup) - 类 中的方法org.joyqueue.client.internal.transport.ClientHeartbeatThread

doHeartbeat(Client) - 类 中的方法org.joyqueue.client.internal.transport.ClientHeartbeatThread

doNotify() - 类 中的方法io.openmessaging.joyqueue.producer.support.FutureAdapter

doOnceDispatch(TopicMetadata, ConsumerPolicy, List<ConsumeMessage>, List<MessageListener>) - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumerDispatcher

doPersist(File) - 类 中的方法org.joyqueue.client.internal.consumer.support.ConsumerLocalIndexStore

doPoll(String, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

doPoll(String, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

doPollPartition(String, short, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

doPollPartition(String, short, long, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

doPollPartition(String, short, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

doPollPartition(String, short, long, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

doPollPartitionInternal(BrokerNode, String, short, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

doPollPartitionInternal(BrokerNode, String, short, long, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

doPrepare(PartitionMetadata) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultTransactionMessageProducer

doProcessCreateMessage(String) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

doRead(File) - 类 中的方法org.joyqueue.client.internal.consumer.support.ConsumerLocalIndexStore

doSchedule() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumerScheduler

doSend(ProduceMessage, long, TimeUnit, boolean, AsyncProduceCallback) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

doSendBatchMessage(BrokerNode, String, String, List<ProduceMessage>, String, QosLevel, long, long, boolean, AsyncBatchProduceCallback) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

doStart() - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

doStart() - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

doStart() - 类 中的方法org.joyqueue.client.internal.cluster.ClusterClientManager

doStart() - 类 中的方法org.joyqueue.client.internal.cluster.ClusterManager

doStart() - 类 中的方法org.joyqueue.client.internal.cluster.ClusterManagerWrapper

doStart() - 类 中的方法org.joyqueue.client.internal.consumer.container.DefaultMessageListenerContainer

doStart() - 类 中的方法org.joyqueue.client.internal.consumer.container.MessageListenerContainerWrapper

doStart() - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.ConsumerCoordinator

doStart() - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

doStart() - 类 中的方法org.joyqueue.client.internal.consumer.support.ConsumerLocalIndexStore

doStart() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

doStart() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

doStart() - 类 中的方法org.joyqueue.client.internal.consumer.support.LocalConsumerIndexManager

doStart() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

doStart() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

doStart() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

doStart() - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

doStart() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumer

doStart() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumerScheduler

doStart() - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClientManager

doStart() - 类 中的方法org.joyqueue.client.internal.producer.feedback.DefaultTxFeedbackManager

doStart() - 类 中的方法org.joyqueue.client.internal.producer.feedback.TxFeedbackManagerWrapper

doStart() - 类 中的方法org.joyqueue.client.internal.producer.feedback.TxFeedbackScheduler

doStart() - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

doStart() - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

doStart() - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

doStart() - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClientManager

doStart() - 类 中的方法org.joyqueue.client.internal.transport.Client

doStart() - 类 中的方法org.joyqueue.client.internal.transport.ClientGroup

doStart() - 类 中的方法org.joyqueue.client.internal.transport.ClientManager

doStop() - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

doStop() - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

doStop() - 类 中的方法org.joyqueue.client.internal.cluster.ClusterClientManager

doStop() - 类 中的方法org.joyqueue.client.internal.cluster.ClusterManager

doStop() - 类 中的方法org.joyqueue.client.internal.cluster.ClusterManagerWrapper

doStop() - 类 中的方法org.joyqueue.client.internal.cluster.MetadataUpdater

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.container.DefaultMessageListenerContainer

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.container.MessageListenerContainerWrapper

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.ConsumerCoordinator

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.support.ConsumerLocalIndexStore

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.support.LocalConsumerIndexManager

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumer

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumerScheduler

doStop() - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClientManager

doStop() - 类 中的方法org.joyqueue.client.internal.producer.feedback.DefaultTxFeedbackManager

doStop() - 类 中的方法org.joyqueue.client.internal.producer.feedback.TxFeedbackManagerWrapper

doStop() - 类 中的方法org.joyqueue.client.internal.producer.feedback.TxFeedbackScheduler

doStop() - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

doStop() - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

doStop() - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

doStop() - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

doStop() - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClientManager

doStop() - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

doStop() - 类 中的方法org.joyqueue.client.internal.transport.Client

doStop() - 类 中的方法org.joyqueue.client.internal.transport.ClientGroup

doStop() - 类 中的方法org.joyqueue.client.internal.transport.ClientGroupManager

doStop() - 类 中的方法org.joyqueue.client.internal.transport.ClientManager

doSubscribeListener(String, BaseMessageListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

E

EmptyMessageReceipt - io.openmessaging.joyqueue.message中的类

EmptyMessageReceipt author: gaohaoxiang date: 2019/3/1

EmptyMessageReceipt() - 类 的构造器io.openmessaging.joyqueue.message.EmptyMessageReceipt

end() - 类 中的方法org.joyqueue.client.internal.trace.support.CompositeTraceCaller

end() - 类 中的方法org.joyqueue.client.internal.trace.support.NoneTraceCaller

end() - 接口 中的方法org.joyqueue.client.internal.trace.TraceCaller

equals(Object) - 类 中的方法io.openmessaging.joyqueue.consumer.support.BatchMessageListenerAdapter

equals(Object) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerInterceptorAdapter

equals(Object) - 类 中的方法io.openmessaging.joyqueue.consumer.support.MessageListenerAdapter

equals(Object) - 类 中的方法io.openmessaging.joyqueue.extension.QueueMetaDataAdapter

equals(Object) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerInterceptorAdapter

equals(Object) - 类 中的方法org.joyqueue.client.internal.cluster.TopicAndApp

equals(Object) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignment

equals(Object) - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

equals(Object) - 类 中的方法org.joyqueue.client.internal.metadata.domain.PartitionMetadata

error() - 类 中的方法org.joyqueue.client.internal.trace.support.CompositeTraceCaller

error() - 类 中的方法org.joyqueue.client.internal.trace.support.NoneTraceCaller

error() - 接口 中的方法org.joyqueue.client.internal.trace.TraceCaller

ExceptionConverter - io.openmessaging.joyqueue.config中的类

ClientExceptionConverter author: gaohaoxiang date: 2019/2/19

ExceptionConverter() - 类 的构造器io.openmessaging.joyqueue.config.ExceptionConverter

ExtensionAdapter - io.openmessaging.joyqueue.consumer.extension中的类

ExtensionAdapter author: gaohaoxiang date: 2019/3/1

ExtensionAdapter(MessageConsumer) - 类 的构造器io.openmessaging.joyqueue.consumer.extension.ExtensionAdapter

ExtensionAdapter - io.openmessaging.joyqueue.producer.extension中的类

ExtensionAdapter author: gaohaoxiang date: 2019/3/1

ExtensionAdapter(MessageProducer) - 类 的构造器io.openmessaging.joyqueue.producer.extension.ExtensionAdapter

ExtensionConsumer - io.openmessaging.joyqueue.consumer中的接口

ExtensionConsumer author: gaohaoxiang date: 2019/3/4

extensionHeader() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageAdapter

ExtensionHeader - io.openmessaging.joyqueue.producer.message中的接口

ExtensionHeader author: gaohaoxiang date: 2019/3/20

extensionHeader() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageAdapter

ExtensionMessage - io.openmessaging.joyqueue.message中的接口

ExtensionMessage author: gaohaoxiang date: 2019/7/1

ExtensionMessageFactory - io.openmessaging.joyqueue.producer.extension中的接口

ExtensionMessageFactory author: gaohaoxiang date: 2019/7/1

ExtensionMessageFactoryImpl - io.openmessaging.joyqueue.producer.message中的类

ExtensionMessageFactoryImpl author: gaohaoxiang date: 2019/3/1

ExtensionMessageFactoryImpl() - 类 的构造器io.openmessaging.joyqueue.producer.message.ExtensionMessageFactoryImpl

ExtensionProducer - io.openmessaging.joyqueue.producer中的接口

ExtensionProducer author: gaohaoxiang date: 2019/3/4

ExtensionTransactionalResult - io.openmessaging.joyqueue.producer中的接口

ExtensionTransactionalResult author: gaohaoxiang date: 2019/3/4

ExtensionTransactionalResultAdapter - io.openmessaging.joyqueue.producer.support中的类

ExtensionTransactionalResultAdapter author: gaohaoxiang date: 2019/3/4

ExtensionTransactionalResultAdapter(MessageProducer) - 类 的构造器io.openmessaging.joyqueue.producer.support.ExtensionTransactionalResultAdapter

ExtensionTransactionalResultAdapter(String, MessageProducer) - 类 的构造器io.openmessaging.joyqueue.producer.support.ExtensionTransactionalResultAdapter

F

FAILOVER - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

FAILOVER - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys

FeedbackData - org.joyqueue.client.internal.producer.domain中的类

FeedbackData author: gaohaoxiang date: 2018/12/24

FeedbackData() - 类 的构造器org.joyqueue.client.internal.producer.domain.FeedbackData

FeedbackData(String, String, String) - 类 的构造器org.joyqueue.client.internal.producer.domain.FeedbackData

fetch(BrokerNode, String, String, int, long, long, long) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageFetcher

fetch(BrokerNode, String, String, int, long, long, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

fetch(BrokerNode, String, String, int, long, long, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

FETCH_INTERVAL - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTxFeedbackBuiltinKeys

FETCH_PARTITION_NONE_INDEX - 类 中的静态变量org.joyqueue.client.internal.consumer.support.MessagePollerInner

FETCH_SIZE - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTxFeedbackBuiltinKeys

fetchAllBrokerAssignments(TopicMetadata, String) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.ConsumerCoordinator

fetchAssignedPartition(List<FetchAssignedPartitionData>, String) - 类 中的方法org.joyqueue.client.internal.cluster.ClusterClient

fetchAssignedPartition(BrokerNode, String, String, boolean, long) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.CoordinatorManager

fetchBrokerAssignment(TopicMetadata, String, long) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.ConsumerCoordinator

fetchBrokerAssignment(TopicMetadata, String, long) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.PartitionAssignmentManager

fetchBrokerAssignment(TopicMetadata) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

fetchCluster(List<String>, String) - 类 中的方法org.joyqueue.client.internal.cluster.ClusterClient

FetcherConfig - org.joyqueue.client.internal.consumer.config中的类

FetcherConfig author: gaohaoxiang date: 2019/2/11

FetcherConfig() - 类 的构造器org.joyqueue.client.internal.consumer.config.FetcherConfig

fetchFeedback(BrokerNode, String, String, TxStatus, int, long, long) - 接口 中的方法org.joyqueue.client.internal.producer.MessageSender

fetchFeedback(BrokerNode, String, String, TxStatus, int, long, long) - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

fetchFeedback(BrokerNode, String, String, TxStatus, int, long, long) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

fetchFeedback(String, String, TxStatus, int, long, long) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClient

FetchFeedbackData - org.joyqueue.client.internal.producer.domain中的类

FetchFeedbackData author: gaohaoxiang date: 2018/12/24

FetchFeedbackData() - 类 的构造器org.joyqueue.client.internal.producer.domain.FetchFeedbackData

fetchIndex(String, String, short, long) - 接口 中的方法org.joyqueue.client.internal.consumer.ConsumerIndexManager

fetchIndex(short) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

fetchIndex(String, short) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

fetchIndex(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

fetchIndex(String, String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.ConsumerLocalIndexStore

fetchIndex(String, String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultConsumerIndexManager

fetchIndex(short) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

fetchIndex(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

fetchIndex(String, String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.LocalConsumerIndexManager

fetchIndex(short) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

fetchIndex(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

fetchIndex(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

fetchIndex(Map<String, List<Short>>, String, long) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

FetchIndexData - org.joyqueue.client.internal.consumer.domain中的类

FetchIndexData author: gaohaoxiang date: 2018/12/14

FetchIndexData(JoyQueueCode) - 类 的构造器org.joyqueue.client.internal.consumer.domain.FetchIndexData

FetchIndexData(long, long, long, JoyQueueCode) - 类 的构造器org.joyqueue.client.internal.consumer.domain.FetchIndexData

FetchListener - org.joyqueue.client.internal.consumer.callback中的接口

BatchFetchListener author: gaohaoxiang date: 2018/12/10

FetchMessageData - org.joyqueue.client.internal.consumer.domain中的类

FetchMessageData author: gaohaoxiang date: 2018/12/13

FetchMessageData() - 类 的构造器org.joyqueue.client.internal.consumer.domain.FetchMessageData

FetchMessageData(JoyQueueCode) - 类 的构造器org.joyqueue.client.internal.consumer.domain.FetchMessageData

FetchMessageData(List<ConsumeMessage>, JoyQueueCode) - 类 的构造器org.joyqueue.client.internal.consumer.domain.FetchMessageData

fetchMetadata(String, String) - 类 中的方法org.joyqueue.client.internal.metadata.MetadataManager

fetchMetadata(List<String>, String) - 类 中的方法org.joyqueue.client.internal.metadata.MetadataManager

fetchPartition(BrokerNode, String, String, short, int, long) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageFetcher

fetchPartition(BrokerNode, String, String, short, long, int, long) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageFetcher

fetchPartition(BrokerNode, String, String, short, int, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

fetchPartition(BrokerNode, String, String, short, long, int, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

fetchPartition(BrokerNode, String, String, short, int, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

fetchPartition(BrokerNode, String, String, short, long, int, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

fetchPartition(BrokerNode, String, short, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

fetchPartition(BrokerNode, TopicMetadata, short, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

fetchPartition(BrokerNode, String, short, long, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

fetchPartition(BrokerNode, TopicMetadata, short, long, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

fetchPartitionAssignment(TopicMetadata, String, long) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.PartitionAssignmentManager

fetchPartitionAsync(BrokerNode, String, String, short, int, long, PartitionFetchListener) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageFetcher

fetchPartitionAsync(BrokerNode, String, String, short, long, int, long, PartitionFetchListener) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageFetcher

fetchPartitionAsync(BrokerNode, String, String, short, int, long, PartitionFetchListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

fetchPartitionAsync(BrokerNode, String, String, short, long, int, long, PartitionFetchListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

fetchPartitionAsync(BrokerNode, String, String, short, int, long, PartitionFetchListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

fetchPartitionAsync(BrokerNode, String, String, short, long, int, long, PartitionFetchListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

fetchPartitionMessage(Map<String, Short>, String, int, long) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

fetchPartitionMessage(Table<String, Short, Long>, String, int, long) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

fetchTopic(BrokerNode, String, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

fetchTopic(BrokerNode, TopicMetadata, int, long, TimeUnit, PollerListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

fetchTopicMessage(List<String>, String, int, long, long, long) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

fetchTopicMetadata(List<String>, String) - 类 中的方法org.joyqueue.client.internal.cluster.ClusterManager

fetchTopicMetadata(String, String) - 类 中的方法org.joyqueue.client.internal.cluster.ClusterManager

fetchTopicMetadataList(List<String>, String) - 类 中的方法org.joyqueue.client.internal.cluster.ClusterManager

filterBlackList(List<PartitionMetadata>, List<PartitionMetadata>) - 类 中的静态方法org.joyqueue.client.internal.producer.helper.ProducerHelper

filterMessage(ConsumeMessage) - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

filterNotAvailableBrokers(BrokerAssignments) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

filterNotAvailableBrokers(List<BrokerNode>) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

filterRegionBrokers(TopicMetadata, BrokerAssignments) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

findCoordinator(String, String) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.CoordinatorManager

findCoordinators(List<String>, String) - 类 中的方法org.joyqueue.client.internal.cluster.ClusterClient

findCoordinators(List<String>, String) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.ConsumerCoordinator

findCoordinators(List<String>, String) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.CoordinatorManager

forceUpdateTopicMetadata(String, String) - 类 中的方法org.joyqueue.client.internal.cluster.ClusterManager

forceUpdateTopicMetadata(List<String>, String) - 类 中的方法org.joyqueue.client.internal.cluster.ClusterManager

FutureAdapter<V> - io.openmessaging.joyqueue.producer.support中的类

FutureAdapter author: gaohaoxiang date: 2019/2/20

FutureAdapter() - 类 的构造器io.openmessaging.joyqueue.producer.support.FutureAdapter

G

get() - 类 中的方法io.openmessaging.joyqueue.producer.support.FutureAdapter

get(long) - 类 中的方法io.openmessaging.joyqueue.producer.support.FutureAdapter

getAckTimeout() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getAddress() - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

getAndCheckTopicMetadata(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

getAndCheckTopicMetadata(String) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

getApp() - 类 中的方法org.joyqueue.client.internal.cluster.TopicAndApp

getApp() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getApp() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

getApp() - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

getApp() - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

getApp() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

getApp() - 类 中的方法org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfig

getApp() - 类 中的方法org.joyqueue.client.internal.producer.interceptor.ProduceContext

getApp() - 类 中的方法org.joyqueue.client.internal.trace.TraceContext

getAppFullName() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getApps() - 类 中的方法org.joyqueue.client.internal.transport.ConnectionState

getAssignments() - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignments

getAttribute(String) - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

getAttribute(Object) - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

getAttribute() - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

getAttribute(String) - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

getAttribute(Object) - 类 中的方法org.joyqueue.client.internal.producer.interceptor.ProduceContext

getAttribute() - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClient

getAttribute() - 类 中的方法org.joyqueue.client.internal.transport.Client

getAttributes() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

getAttributes() - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

getAttributes() - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

getAttributes() - 类 中的方法org.joyqueue.client.internal.producer.interceptor.ProduceContext

getBatchBodyLengthLimit() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

getBatchListeners() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageListenerManager

getBatchSize() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getBindQueue() - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

getBindQueue() - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

getBody() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

getBody() - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

getBodyBytes() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

getBodyBytes() - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

getBodyLengthLimit() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

getBoolean(String) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

getBoolean(String, boolean) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

getBoolean(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

getBoolean(String, boolean) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

getBoolean(String) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

getBoolean(String, boolean) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

getBoolean(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

getBoolean(String, boolean) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

getBornHost() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

getBornHost() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

getBornTimestamp() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

getBornTimestamp() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

getBroadcastGroup() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getBroadcastIndexExpireTime() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getBroadcastLocalPath() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getBroadcastPersistInterval() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getBroker() - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignment

getBroker(int) - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

getBrokerAssignments() - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignmentsHolder

getBrokerLoadBalance(String, String) - 类 中的方法org.joyqueue.client.internal.consumer.support.BrokerLoadBalanceManager

getBrokerLoadBalance(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

getBrokerNode(int) - 类 中的方法org.joyqueue.client.internal.metadata.domain.ClusterMetadata

getBrokerNodes() - 类 中的方法org.joyqueue.client.internal.transport.ConnectionState

getBrokerPartitionGroups(int) - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

getBrokerPartitions(int) - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

getBrokerPartitions(TopicMetadata, List<BrokerNode>) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

getBrokers() - 类 中的方法org.joyqueue.client.internal.metadata.domain.ClusterMetadata

getBrokers() - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

getBrokers() - 类 中的方法org.joyqueue.client.internal.metadata.domain.UnmodifiableTopicMetadata

已过时。

getBusinessId() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

getBusinessId() - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

getBusinessIdLengthLimit() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

getCallbackThreads() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

getChannelMaxIdleTime() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

getClient() - 类 中的方法org.joyqueue.client.internal.cluster.ClusterClient

getClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.cluster.ClusterClientManager

getClient() - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

getClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClientManager

getClient() - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClient

getClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClientManager

getClient() - 类 中的方法org.joyqueue.client.internal.transport.ClientGroup

getClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.transport.ClientManager

getClientGroup(BrokerNode) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClientManager

getClientGroup(BrokerNode) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClientManager

getClientGroup(BrokerNode) - 类 中的方法org.joyqueue.client.internal.transport.ClientGroupManager

getClientGroup(BrokerNode, Callable<ClientGroup>) - 类 中的方法org.joyqueue.client.internal.transport.ClientGroupManager

getClientGroup(BrokerNode) - 类 中的方法org.joyqueue.client.internal.transport.ClientManager

getClients() - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClientGroup

getClients() - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClientGroup

getClients() - 类 中的方法org.joyqueue.client.internal.transport.ClientGroup

getClusterClientManager() - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

getClusterManager() - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

getCode() - 类 中的方法org.joyqueue.client.internal.cluster.domain.TopicMetadataHolder

getCode() - 类 中的方法org.joyqueue.client.internal.consumer.domain.FetchIndexData

getCode() - 类 中的方法org.joyqueue.client.internal.consumer.domain.FetchMessageData

getCode() - 异常错误 中的方法org.joyqueue.client.internal.exception.ClientException

getCode() - 异常错误 中的方法org.joyqueue.client.internal.exception.SecurityException

getCode() - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

getCode() - 类 中的方法org.joyqueue.client.internal.producer.domain.FetchFeedbackData

getCode() - 类 中的方法org.joyqueue.client.internal.producer.domain.SendBatchResultData

getCode() - 类 中的方法org.joyqueue.client.internal.producer.domain.SendPrepareResult

getCode() - 类 中的方法org.joyqueue.client.internal.producer.domain.SendResultData

getCompression() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

getCompression() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

getCompressor(String) - 类 中的静态方法org.joyqueue.client.internal.common.compress.CompressorManager

getCompressThreshold() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

getCompressThreshold() - 类 中的方法org.joyqueue.client.internal.producer.config.SenderConfig

getCompressType() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

getCompressType() - 类 中的方法org.joyqueue.client.internal.producer.config.SenderConfig

getConnectionId() - 类 中的方法org.joyqueue.client.internal.transport.ClientConnectionInfo

getConnectionInfo() - 类 中的方法org.joyqueue.client.internal.transport.Client

getConnectionInfo() - 类 中的方法org.joyqueue.client.internal.transport.ClientConnectionState

getConnections() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

getConsumerClientManager() - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

getConsumerPolicy() - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

getCorrelationId() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

getCorrelationId() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

getCreateTime() - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignmentsHolder

getCreateTime() - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.PartitionAssignmentHolder

getCreateTime() - 类 中的方法org.joyqueue.client.internal.consumer.domain.LocalIndexData

getData() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageAdapter

getData() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageAdapter

getData() - 类 中的方法org.joyqueue.client.internal.producer.domain.FetchFeedbackData

getDelayTime() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

getDelayTime() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

getDeliveryCount() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

getDeliveryCount() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

getDestination() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

getDestination() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

getDouble(String) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

getDouble(String, double) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

getDouble(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

getDouble(String, double) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

getDouble(String) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

getDouble(String, double) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

getDouble(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

getDouble(String, double) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

getDurability() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

getDurability() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

getExpireTime() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

getExpireTime() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

getExtension() - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

getExtension() - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

getExtension() - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

getExtension() - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

getExtension() - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

getFetchInterval() - 类 中的方法org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfig

getFetchSize() - 类 中的方法org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfig

getFilteredMessages() - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

getFlag() - 接口 中的方法io.openmessaging.joyqueue.producer.message.ExtensionHeader

getFlag() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

getFlag() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

getFlag() - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

getGcd(int, int) - 类 中的方法org.joyqueue.client.internal.producer.support.WeightedRoundRobinPartitionSelector

getGroup() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getGroups() - 类 中的方法org.joyqueue.client.internal.transport.ClientGroupManager

getHeartbeatInterval() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

getHeartbeatMaxIdleTime() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

getHeartbeatTimeout() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

getId() - 类 中的方法org.joyqueue.client.internal.metadata.domain.PartitionGroupMetadata

getId() - 类 中的方法org.joyqueue.client.internal.metadata.domain.PartitionMetadata

getIdleInterval() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getIndex() - 类 中的方法io.openmessaging.joyqueue.consumer.ConsumerIndex

getIndex(short) - 接口 中的方法io.openmessaging.joyqueue.consumer.ExtensionConsumer

getIndex(short) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

getIndex(short) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

getIndex() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

getIndex() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeReply

getIndex() - 类 中的方法org.joyqueue.client.internal.consumer.domain.FetchIndexData

getIndex() - 类 中的方法org.joyqueue.client.internal.consumer.domain.LocalIndexData

getIndex() - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceResult

getIndex() - 类 中的方法org.joyqueue.client.internal.producer.domain.SendResult

已过时。

getInstance() - 类 中的静态方法org.joyqueue.client.internal.common.ordered.OrderedComparator

getInstance() - 类 中的静态方法org.joyqueue.client.internal.trace.support.NoneTrace

getInstance() - 类 中的静态方法org.joyqueue.client.internal.trace.support.NoneTraceCaller

getInstance() - 类 中的静态方法org.joyqueue.client.internal.trace.support.TraceWrapper

getInt(KeyValue, String, int) - 类 中的静态方法io.openmessaging.joyqueue.config.KeyValueHelper

getInt(String) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

getInt(String, int) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

getInt(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

getInt(String, int) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

getInt(String) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

getInt(String, int) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

getInt(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

getInt(String, int) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

getInterceptors() - 类 中的静态方法org.joyqueue.client.internal.consumer.interceptor.GlobalConsumerInterceptorManager

getInterceptors() - 类 中的静态方法org.joyqueue.client.internal.producer.interceptor.GlobalProducerInterceptorManager

getInterval() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getInterval() - 类 中的方法org.joyqueue.client.internal.trace.TraceContext

getIoThreads() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

getLastUseTime() - 类 中的方法org.joyqueue.client.internal.transport.Client

getLastUseTime() - 类 中的方法org.joyqueue.client.internal.transport.ClientConnectionState

getLeader() - 类 中的方法org.joyqueue.client.internal.metadata.domain.PartitionGroupMetadata

getLeader() - 类 中的方法org.joyqueue.client.internal.metadata.domain.PartitionMetadata

getLeftIndex() - 类 中的方法io.openmessaging.joyqueue.consumer.ConsumerIndex

getLeftIndex() - 类 中的方法org.joyqueue.client.internal.consumer.domain.FetchIndexData

getListeners() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageListenerManager

getLoadBalanceType() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getLong(String) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

getLong(String, long) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

getLong(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

getLong(String, long) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

getLong(String) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

getLong(String, long) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

getLong(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

getLong(String, long) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

getLongPollTimeout() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getLongPollTimeout() - 类 中的方法org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfig

getMaxAsync() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

getMaxGcd(List<PartitionMetadata>) - 类 中的方法org.joyqueue.client.internal.producer.support.WeightedRoundRobinPartitionSelector

getMaxOneway() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

getMaxWeight(List<PartitionMetadata>) - 类 中的方法org.joyqueue.client.internal.producer.support.WeightedRoundRobinPartitionSelector

getMessage() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageReceiptAdapter

getMessageAccessPoint() - 类 中的方法io.openmessaging.joyqueue.support.MessageAccessPointHolder

getMessageFilter() - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

getMessageId() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

getMessageId() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

getMessageKey() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

getMessageKey() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

getMessagePoller() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumer

getMessageReceipt() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageAdapter

getMessageReceipt() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageAdapter

getMessages() - 类 中的方法org.joyqueue.client.internal.consumer.domain.FetchMessageData

getMessages() - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

getMessages() - 类 中的方法org.joyqueue.client.internal.producer.interceptor.ProduceContext

getNameserver() - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

getNameserver() - 类 中的方法org.joyqueue.client.internal.producer.interceptor.ProduceContext

getNamespace() - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

getNamespace() - 类 中的方法org.joyqueue.client.internal.trace.TraceContext

getNearbyBrokers() - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

getNode() - 类 中的方法org.joyqueue.client.internal.transport.ClientGroup

getOffset() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

getOffset() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

getOmsConsumerInterceptor() - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerInterceptorAdapter

getOmsMessage() - 类 中的方法io.openmessaging.joyqueue.producer.message.OMSProduceMessage

getOmsProducerInterceptor() - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerInterceptorAdapter

getOrConvertMessages(ConsumeContext) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerInterceptorAdapter

getOrCreateAddedTopicSet(String) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerConnectionState

getOrCreateAddedTopicSet(String) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerConnectionState

getOrCreateClient() - 类 中的方法org.joyqueue.client.internal.cluster.ClusterClientManager

getOrCreateClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.cluster.ClusterClientManager

getOrCreateClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClientManager

getOrCreateClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClientManager

getOrCreateClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.transport.ClientManager

getOrCreateMessageAccessPointHolder() - 类 中的方法io.openmessaging.joyqueue.MessagingAccessPointImpl

getOrCreateOMSContext(ConsumeContext) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerInterceptorAdapter

getOrCreateOMSContext(ProduceContext) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerInterceptorAdapter

getOrder() - 接口 中的方法org.joyqueue.client.internal.common.ordered.Ordered

getOrder() - 类 中的方法org.joyqueue.client.internal.trace.interceptor.TraceConsumerInterceptor

getOrder() - 类 中的方法org.joyqueue.client.internal.trace.interceptor.TraceProducerInterceptor

getPartition() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

getPartition() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeReply

getPartition(short) - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

getPartition() - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

getPartition() - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceResult

getPartition() - 类 中的方法org.joyqueue.client.internal.producer.domain.SendResult

getPartitionAssignment() - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignment

getPartitionAssignment() - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.PartitionAssignmentHolder

getPartitionGroup(int) - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

getPartitionGroupId() - 类 中的方法org.joyqueue.client.internal.metadata.domain.PartitionMetadata

getPartitionGroups() - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

getPartitionGroups() - 类 中的方法org.joyqueue.client.internal.metadata.domain.UnmodifiableTopicMetadata

已过时。

getPartitionKey() - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

getPartitions() - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.PartitionAssignment

getPartitions() - 类 中的方法org.joyqueue.client.internal.metadata.domain.PartitionGroupMetadata

getPartitions() - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

getPartitions() - 类 中的方法org.joyqueue.client.internal.metadata.domain.UnmodifiableTopicMetadata

已过时。

getPartitionSelector(String, String) - 类 中的方法org.joyqueue.client.internal.producer.support.PartitionSelectorManager

getPartiton() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

getPartiton() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

getPollTimeout() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getPriority() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

getPriority() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

getPriority() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

getPriority() - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

getProduceMessage() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageAdapter

getProducerClientManager() - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

getProducerPolicy() - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

getProduceTimeout() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

getQosLevel() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

getQueueMetaData(String) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

getQueueMetaData(String) - 类 中的方法io.openmessaging.joyqueue.extension.AbstractExtensionAdapter

getQueueMetaData(String) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

getQueueMetaData(String) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

getQueueMetaData(String) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

getQueueMetaData(String) - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

getRegion() - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

getRegionBrokers(TopicMetadata) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

getResult() - 类 中的方法org.joyqueue.client.internal.producer.domain.SendBatchResultData

getResult() - 类 中的方法org.joyqueue.client.internal.producer.domain.SendResultData

getRetryPolicy() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

getRetryPolicy() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

getRetryType() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeReply

getRightIndex() - 类 中的方法io.openmessaging.joyqueue.consumer.ConsumerIndex

getRightIndex() - 类 中的方法org.joyqueue.client.internal.consumer.domain.FetchIndexData

getSelectorType() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

getSendTimeout() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

getSessionTimeout() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getShort(String) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

getShort(String, short) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

getShort(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

getShort(String, short) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

getShort(String) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

getShort(String, short) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

getShort(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

getShort(String, short) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

getSocketBufferSize() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

getSoLinger() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

getSortedInterceptors() - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumerInterceptorManager

getSortedInterceptors() - 类 中的方法org.joyqueue.client.internal.producer.interceptor.ProducerInterceptorManager

getSoTimeout() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

getSource() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

getStartTime() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

getStartTime() - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceResult

getStartTime() - 类 中的方法org.joyqueue.client.internal.producer.domain.SendResult

getStartTime() - 类 中的方法org.joyqueue.client.internal.trace.TraceContext

getState() - 类 中的方法org.joyqueue.client.internal.cluster.ClusterClient

getState() - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

getState() - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClient

getState() - 类 中的方法org.joyqueue.client.internal.transport.Client

getStatus() - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionalContextAdapter

getStoreHost() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

getStoreHost() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

getStoreTimestamp() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

getStoreTimestamp() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

getString(KeyValue, String, String) - 类 中的静态方法io.openmessaging.joyqueue.config.KeyValueHelper

getString(String) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

getString(String, String) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

getString(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

getString(String, String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

getString(String) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

getString(String, String) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

getString(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

getString(String, String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

getStringData() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageAdapter

getStringData() - 接口 中的方法io.openmessaging.joyqueue.message.ExtensionMessage

getStringData() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageAdapter

getTempMetadataInterval() - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

getThread() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getThrowable() - 类 中的方法io.openmessaging.joyqueue.producer.support.FutureAdapter

getTimeout() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

getTimeout() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

getTimeout() - 类 中的方法org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfig

getToken() - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

getTopic() - 类 中的方法org.joyqueue.client.internal.cluster.domain.TopicMetadataHolder

getTopic() - 类 中的方法org.joyqueue.client.internal.cluster.TopicAndApp

getTopic() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

getTopic() - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

getTopic(String) - 类 中的方法org.joyqueue.client.internal.metadata.domain.ClusterMetadata

getTopic() - 类 中的方法org.joyqueue.client.internal.metadata.domain.PartitionMetadata

getTopic() - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

getTopic() - 类 中的方法org.joyqueue.client.internal.producer.domain.FeedbackData

getTopic() - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

getTopic() - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceResult

getTopic() - 类 中的方法org.joyqueue.client.internal.producer.domain.SendResult

getTopic() - 类 中的方法org.joyqueue.client.internal.producer.interceptor.ProduceContext

getTopic() - 类 中的方法org.joyqueue.client.internal.trace.TraceContext

getTopicFullName(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

getTopicFullName(String, NameServerConfig) - 类 中的静态方法org.joyqueue.client.internal.nameserver.helper.NameServerHelper

getTopicFullName(String) - 类 中的方法org.joyqueue.client.internal.producer.feedback.DefaultTxFeedbackManager

getTopicFullName(String) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

getTopicMap(String) - 类 中的方法org.joyqueue.client.internal.cluster.MetadataCacheManager

getTopicMetadata(String) - 类 中的方法io.openmessaging.joyqueue.consumer.extension.ExtensionAdapter

getTopicMetadata(String) - 类 中的方法io.openmessaging.joyqueue.extension.AbstractExtensionAdapter

getTopicMetadata() - 类 中的方法io.openmessaging.joyqueue.extension.QueueMetaDataAdapter

getTopicMetadata(String) - 类 中的方法io.openmessaging.joyqueue.producer.extension.ExtensionAdapter

getTopicMetadata() - 类 中的方法org.joyqueue.client.internal.cluster.domain.TopicMetadataHolder

getTopicMetadata(String, String) - 类 中的方法org.joyqueue.client.internal.cluster.MetadataCacheManager

getTopicMetadata(String) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

getTopicMetadata(String) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

getTopicMetadata(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

getTopicMetadata(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

getTopicMetadata(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

getTopicMetadata(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

getTopicMetadata(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

getTopicMetadata(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

getTopicMetadata(String) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

getTopicMetadata(String) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

getTopicMetadata(String) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

getTopics(String) - 类 中的方法org.joyqueue.client.internal.cluster.MetadataCacheManager

getTopics() - 类 中的方法org.joyqueue.client.internal.cluster.TopicAndApp

getTopics() - 类 中的方法org.joyqueue.client.internal.metadata.domain.ClusterMetadata

getTopics() - 类 中的方法org.joyqueue.client.internal.transport.ConnectionState

getTrace(String) - 类 中的静态方法org.joyqueue.client.internal.trace.TraceManager

getTraceId() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

getTraceId() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

getTraces() - 类 中的方法org.joyqueue.client.internal.trace.support.CompositeTrace

getTraces() - 类 中的静态方法org.joyqueue.client.internal.trace.TraceManager

getTransactionId() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

getTransactionId() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

getTransactionId() - 类 中的方法org.joyqueue.client.internal.producer.domain.FeedbackData

getTransactionTimeout() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

getTransport() - 类 中的方法org.joyqueue.client.internal.transport.Client

getTxFeedbackManager(TxFeedbackConfig) - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

getTxId() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

getTxId() - 类 中的方法org.joyqueue.client.internal.producer.domain.FeedbackData

getTxId() - 类 中的方法org.joyqueue.client.internal.producer.domain.SendPrepareResult

getType() - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

getType() - 类 中的方法org.joyqueue.client.internal.trace.TraceContext

getType() - 枚举 中的方法org.joyqueue.client.internal.trace.TraceType

getUpdateMetadataInterval() - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

getUpdateMetadataQueueSize() - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

getUpdateMetadataThread() - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

getUpdateTime() - 类 中的方法org.joyqueue.client.internal.consumer.domain.LocalIndexData

getValue() - 类 中的方法io.openmessaging.joyqueue.producer.support.FutureAdapter

GlobalConsumerInterceptorManager - org.joyqueue.client.internal.consumer.interceptor中的类

GlobalConsumerInterceptorManager author: gaohaoxiang date: 2019/1/11

GlobalConsumerInterceptorManager() - 类 的构造器org.joyqueue.client.internal.consumer.interceptor.GlobalConsumerInterceptorManager

GlobalProducerInterceptorManager - org.joyqueue.client.internal.producer.interceptor中的类

GlobalProducerInterceptorManager author: gaohaoxiang date: 2019/1/11

GlobalProducerInterceptorManager() - 类 的构造器org.joyqueue.client.internal.producer.interceptor.GlobalProducerInterceptorManager

GROUP - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

H

handleAddConnection() - 类 中的方法org.joyqueue.client.internal.transport.Client

handleAddConnection() - 类 中的方法org.joyqueue.client.internal.transport.ClientConnectionState

handleAddConsumers(BrokerNode, Collection<String>, String, ConsumerClient) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

handleAddConsumers() - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerConnectionState

handleAddConsumers(Collection<String>, String) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerConnectionState

handleAddProducers(BrokerNode, Collection<String>, String, ProducerClient) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

handleAddProducers() - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerConnectionState

handleAddProducers(Collection<String>, String) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerConnectionState

handleConsumeException(Throwable) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

handleDisconnection() - 类 中的方法org.joyqueue.client.internal.transport.Client

handleDisconnection() - 类 中的方法org.joyqueue.client.internal.transport.ClientConnectionState

handleFetchMessageData(String, String, FetchMessageData) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

handleNotification(AddConnectionResponse) - 类 中的方法org.joyqueue.client.internal.transport.ClientConnectionState

handleProduceException(Throwable) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

handleRemoveConsumers() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

handleRemoveConsumers(BrokerNode, Set<String>, Set<String>) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

handleRemoveConsumers(Collection<String>, String) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerConnectionState

handleRemoveConsumers() - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerConnectionState

handleRemoveProducers() - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

handleRemoveProducers(BrokerNode, Set<String>, Set<String>) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

handleRemoveProducers(Collection<String>, String) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerConnectionState

handleRemoveProducers() - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerConnectionState

handleSendBatchResultData(String, String, SendBatchResultData) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

hashCode() - 类 中的方法io.openmessaging.joyqueue.consumer.support.BatchMessageListenerAdapter

hashCode() - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerInterceptorAdapter

hashCode() - 类 中的方法io.openmessaging.joyqueue.consumer.support.MessageListenerAdapter

hashCode() - 类 中的方法io.openmessaging.joyqueue.extension.QueueMetaDataAdapter

hashCode() - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerInterceptorAdapter

hashCode() - 类 中的方法org.joyqueue.client.internal.cluster.TopicAndApp

hashCode() - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignment

hashCode() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

hashCode() - 类 中的方法org.joyqueue.client.internal.metadata.domain.PartitionMetadata

hashPartition(ProduceMessage, TopicMetadata, List<PartitionMetadata>) - 类 中的方法org.joyqueue.client.internal.producer.support.AbstractPartitionSelector

header() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageAdapter

header() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageAdapter

heartbeat(long) - 类 中的方法org.joyqueue.client.internal.transport.Client

HEARTBEAT_INTERVAL - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

HEARTBEAT_TIMEOUT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

HIGHEST_PRECEDENCE - 接口 中的静态变量org.joyqueue.client.internal.common.ordered.Ordered

I

IDLE_INTERVAL - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

IgnoreAckException - org.joyqueue.client.internal.consumer.exception中的异常错误

IgnoreAckException author: gaohaoxiang date: 2019/2/20

IgnoreAckException() - 异常错误 的构造器org.joyqueue.client.internal.consumer.exception.IgnoreAckException

initClient(BrokerNode, TransportConfig, TransportClient) - 类 中的方法org.joyqueue.client.internal.transport.ClientGroup

initPersistPathFile(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.ConsumerLocalIndexStore

INTERVAL - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

invoke() - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumerInvocation

invoke(ConsumeContext) - 接口 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumerInvoker

invoke(ConsumeContext) - 类 中的方法org.joyqueue.client.internal.consumer.support.BatchConsumerInvoker

invoke(ConsumeContext) - 类 中的方法org.joyqueue.client.internal.consumer.support.OnceConsumerInvoker

invoke() - 类 中的方法org.joyqueue.client.internal.producer.interceptor.ProducerInvocation

invoke(ProduceContext) - 接口 中的方法org.joyqueue.client.internal.producer.interceptor.ProducerInvoker

io.openmessaging.joyqueue - 程序包 io.openmessaging.joyqueue

io.openmessaging.joyqueue.config - 程序包 io.openmessaging.joyqueue.config

io.openmessaging.joyqueue.consumer - 程序包 io.openmessaging.joyqueue.consumer

io.openmessaging.joyqueue.consumer.extension - 程序包 io.openmessaging.joyqueue.consumer.extension

io.openmessaging.joyqueue.consumer.interceptor - 程序包 io.openmessaging.joyqueue.consumer.interceptor

io.openmessaging.joyqueue.consumer.message - 程序包 io.openmessaging.joyqueue.consumer.message

io.openmessaging.joyqueue.consumer.support - 程序包 io.openmessaging.joyqueue.consumer.support

io.openmessaging.joyqueue.domain - 程序包 io.openmessaging.joyqueue.domain

io.openmessaging.joyqueue.extension - 程序包 io.openmessaging.joyqueue.extension

io.openmessaging.joyqueue.message - 程序包 io.openmessaging.joyqueue.message

io.openmessaging.joyqueue.producer - 程序包 io.openmessaging.joyqueue.producer

io.openmessaging.joyqueue.producer.extension - 程序包 io.openmessaging.joyqueue.producer.extension

io.openmessaging.joyqueue.producer.interceptor - 程序包 io.openmessaging.joyqueue.producer.interceptor

io.openmessaging.joyqueue.producer.message - 程序包 io.openmessaging.joyqueue.producer.message

io.openmessaging.joyqueue.producer.support - 程序包 io.openmessaging.joyqueue.producer.support

io.openmessaging.joyqueue.support - 程序包 io.openmessaging.joyqueue.support

IO_THREADS - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

isAck() - 类 中的方法io.openmessaging.joyqueue.consumer.support.BatchMessageListenerContextAdapter

isAck() - 类 中的方法io.openmessaging.joyqueue.consumer.support.MessageListenerContextAdapter

isAllAvailable() - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

isBatch() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

isBatch() - 类 中的方法org.joyqueue.client.internal.producer.config.SenderConfig

isBindQueue() - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

isBindQueue() - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

isCancelled() - 类 中的方法io.openmessaging.joyqueue.producer.support.FutureAdapter

isCompress() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

isCompress() - 类 中的方法org.joyqueue.client.internal.producer.config.SenderConfig

isDone() - 类 中的方法io.openmessaging.joyqueue.producer.support.FutureAdapter

isEmpty() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageListenerManager

isEnable() - 枚举 中的方法org.joyqueue.client.internal.trace.TraceType

isExpired(long) - 类 中的方法org.joyqueue.client.internal.cluster.domain.TopicMetadataHolder

isExpired() - 类 中的方法org.joyqueue.client.internal.cluster.domain.TopicMetadataHolder

isExpired(long) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignmentsHolder

isExpired(long) - 类 中的方法org.joyqueue.client.internal.consumer.domain.LocalIndexData

isExpired(LocalIndexData) - 类 中的方法org.joyqueue.client.internal.consumer.support.LocalConsumerIndexManager

isFailover() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

isFailover() - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

isFailover(List<ProduceMessage>) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

isFilteredMessage(ConsumeMessage) - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

isKeepAlive() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

isListenSuspended() - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

isListenSuspended() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

isListenSuspended() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

isLoadBalance() - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

isNonBlockOneway() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

isSubscribed() - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

isSubscribed() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

isSubscribed() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

isSuspend() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumer

isSuspend() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumerScheduler

isSuspended() - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

isSuspended() - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

isTcpNoDelay() - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

J

JoyQueueBuiltinKeys - io.openmessaging.joyqueue中的接口

JoyQueueBuiltinKeys author: gaohaoxiang date: 2019/2/19

JoyQueueConsumerBuiltinKeys - io.openmessaging.joyqueue.domain中的接口

JoyQueueConsumerBuiltinKeys author: gaohaoxiang date: 2019/2/19

JoyQueueNameServerBuiltinKeys - io.openmessaging.joyqueue.domain中的接口

JoyQueueNameServerBuiltinKeys author: gaohaoxiang date: 2019/2/19

JoyQueueOMSConsts - io.openmessaging.joyqueue中的类

JoyQueueOMSConsts author: gaohaoxiang date: 2019/2/18

JoyQueueOMSConsts() - 类 的构造器io.openmessaging.joyqueue.JoyQueueOMSConsts

JoyQueueProducerBuiltinKeys - io.openmessaging.joyqueue.domain中的接口

JoyQueueProducerBuiltinKeys author: gaohaoxiang date: 2019/2/19

JoyQueueTransportBuiltinKeys - io.openmessaging.joyqueue.domain中的接口

JoyQueueTransportBuiltinKeys author: gaohaoxiang date: 2019/2/19

JoyQueueTxFeedbackBuiltinKeys - io.openmessaging.joyqueue.domain中的接口

JoyQueueTxFeedbackBuiltinKeys author: gaohaoxiang date: 2019/2/19

K

KEEPALIVE - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

keySet() - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

keySet() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

keySet() - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

keySet() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

KeyValueConverter - io.openmessaging.joyqueue.config中的类

KeyValueConverter author: gaohaoxiang date: 2019/2/19

KeyValueConverter() - 类 的构造器io.openmessaging.joyqueue.config.KeyValueConverter

KeyValueHelper - io.openmessaging.joyqueue.config中的类

KeyValueHelper author: gaohaoxiang date: 2019/3/11

KeyValueHelper() - 类 的构造器io.openmessaging.joyqueue.config.KeyValueHelper

L

LOADBALANCE - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

loadBalance(BrokerAssignments) - 接口 中的方法org.joyqueue.client.internal.consumer.BrokerLoadBalance

loadBalance(BrokerAssignments) - 类 中的方法org.joyqueue.client.internal.consumer.support.RandomBrokerLoadBalance

loadBalance(BrokerAssignments) - 类 中的方法org.joyqueue.client.internal.consumer.support.RoundRobinBrokerLoadBalance

LOADBALANCE - 接口 中的静态变量org.joyqueue.client.internal.Plugins

负载均衡插件

LOADBALANCE_TYPE - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

loadConverters() - 类 中的方法org.joyqueue.client.internal.consumer.converter.MessageConvertSupport

loadInterceptors() - 类 中的静态方法org.joyqueue.client.internal.consumer.interceptor.GlobalConsumerInterceptorManager

loadInterceptors() - 类 中的静态方法org.joyqueue.client.internal.producer.interceptor.GlobalProducerInterceptorManager

loadTraces() - 类 中的静态方法org.joyqueue.client.internal.trace.TraceManager

LocalConsumerIndexManager - org.joyqueue.client.internal.consumer.support中的类

LocalConsumerIndexManager author: gaohaoxiang date: 2018/12/14

LocalConsumerIndexManager(ConsumerConfig, ConsumerIndexManager) - 类 的构造器org.joyqueue.client.internal.consumer.support.LocalConsumerIndexManager

LocalIndexData - org.joyqueue.client.internal.consumer.domain中的类

LocalIndexData author: gaohaoxiang date: 2018/12/14

LocalIndexData() - 类 的构造器org.joyqueue.client.internal.consumer.domain.LocalIndexData

LocalIndexData(long, long, long) - 类 的构造器org.joyqueue.client.internal.consumer.domain.LocalIndexData

logger - 类 中的变量io.openmessaging.joyqueue.MessagingAccessPointImpl

logger - 类 中的静态变量org.joyqueue.client.internal.ClientConsts

logger - 类 中的静态变量org.joyqueue.client.internal.cluster.ClusterManager

logger - 类 中的静态变量org.joyqueue.client.internal.cluster.MetadataUpdater

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.container.DefaultMessageListenerContainer

logger - 类 中的变量org.joyqueue.client.internal.consumer.converter.MessageConvertSupport

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.coordinator.ConsumerCoordinator

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.coordinator.CoordinatorManager

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.coordinator.PartitionAssignmentManager

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.support.BatchConsumerInvoker

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.support.ConsumerLocalIndexStore

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.support.DefaultConsumerIndexManager

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.support.LocalConsumerIndexManager

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.support.MessagePollerInner

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.support.OnceConsumerInvoker

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.support.TopicMessageConsumer

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.support.TopicMessageConsumerDispatcher

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.support.TopicMessageConsumerScheduler

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.transport.ConsumerClient

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.transport.ConsumerClientManager

logger - 类 中的静态变量org.joyqueue.client.internal.consumer.transport.ConsumerConnectionState

logger - 类 中的静态变量org.joyqueue.client.internal.metadata.MetadataManager

logger - 类 中的静态变量org.joyqueue.client.internal.producer.converter.ProduceMessageConverter

logger - 类 中的静态变量org.joyqueue.client.internal.producer.feedback.DefaultTxFeedbackManager

logger - 类 中的静态变量org.joyqueue.client.internal.producer.feedback.TxFeedbackDispatcher

logger - 类 中的静态变量org.joyqueue.client.internal.producer.feedback.TxFeedbackScheduler

logger - 类 中的静态变量org.joyqueue.client.internal.producer.support.DefaultMessageProducer

logger - 类 中的静态变量org.joyqueue.client.internal.producer.support.DefaultMessageSender

logger - 类 中的静态变量org.joyqueue.client.internal.producer.support.DefaultTransactionMessageProducer

logger - 类 中的静态变量org.joyqueue.client.internal.producer.support.MessageProducerInner

logger - 类 中的静态变量org.joyqueue.client.internal.producer.transport.ProducerClientManager

logger - 类 中的静态变量org.joyqueue.client.internal.producer.transport.ProducerConnectionState

logger - 类 中的静态变量org.joyqueue.client.internal.transport.Client

logger - 类 中的静态变量org.joyqueue.client.internal.transport.ClientConnectionState

logger - 类 中的静态变量org.joyqueue.client.internal.transport.ClientGroupManager

logger - 类 中的静态变量org.joyqueue.client.internal.transport.ClientHeartbeatThread

logger - 类 中的静态变量org.joyqueue.client.internal.transport.ClientManager

LONGPOLL_TIMEOUT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

LONGPOLL_TIMEOUT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTxFeedbackBuiltinKeys

LOWEST_PRECEDENCE - 接口 中的静态变量org.joyqueue.client.internal.common.ordered.Ordered

M

MAX_ASYNC - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

MAX_ONEWAY - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

maybeStop() - 类 中的方法io.openmessaging.joyqueue.support.MessageAccessPointHolder

MESSAGE_CONVERTER - 接口 中的静态变量org.joyqueue.client.internal.Plugins

消息转换扩展点

MessageAccessPoint - org.joyqueue.client.internal中的接口

MessageAccessPoint author: gaohaoxiang date: 2019/2/19

MessageAccessPointFactory - org.joyqueue.client.internal中的类

MessageAccessPointFactory author: gaohaoxiang date: 2019/2/19

MessageAccessPointFactory() - 类 的构造器org.joyqueue.client.internal.MessageAccessPointFactory

MessageAccessPointHolder - io.openmessaging.joyqueue.support中的类

MessageAccessPointHolder author: gaohaoxiang date: 2019/5/14

MessageAccessPointHolder(MessageAccessPoint) - 类 的构造器io.openmessaging.joyqueue.support.MessageAccessPointHolder

MessageAdapter - io.openmessaging.joyqueue.consumer.message中的类

MessageAdapter author: gaohaoxiang date: 2019/3/1

MessageAdapter(ConsumeMessage) - 类 的构造器io.openmessaging.joyqueue.consumer.message.MessageAdapter

MessageAdapter - io.openmessaging.joyqueue.producer.message中的类

MessageAdapter author: gaohaoxiang date: 2019/3/1

MessageAdapter(ProduceMessage) - 类 的构造器io.openmessaging.joyqueue.producer.message.MessageAdapter

MessageConsumer - org.joyqueue.client.internal.consumer中的接口

MessageConsumer author: gaohaoxiang date: 2019/1/10

MessageConsumerFactory - org.joyqueue.client.internal.consumer中的类

MessageConsumerFactory author: gaohaoxiang date: 2019/1/10

MessageConsumerFactory() - 类 的构造器org.joyqueue.client.internal.consumer.MessageConsumerFactory

MessageConsumerWrapper - org.joyqueue.client.internal.consumer.support中的类

MessageConsumerWrapper author: gaohaoxiang date: 2019/1/10

MessageConsumerWrapper(ConsumerConfig, NameServerConfig, ClusterManager, ClusterClientManager, ConsumerClientManager, MessageConsumer) - 类 的构造器org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

MessageConverter - io.openmessaging.joyqueue.consumer.message中的类

MessageConverter author: gaohaoxiang date: 2019/2/19

MessageConverter() - 类 的构造器io.openmessaging.joyqueue.consumer.message.MessageConverter

MessageConverter - org.joyqueue.client.internal.consumer.converter中的接口

MessageConverter author: gaohaoxiang date: 2019/4/3

MessageConvertSupport - org.joyqueue.client.internal.consumer.converter中的类

MessageConvertSupport author: gaohaoxiang date: 2019/4/3

MessageConvertSupport() - 类 的构造器org.joyqueue.client.internal.consumer.converter.MessageConvertSupport

MessageExtensionHeaderAdapter - io.openmessaging.joyqueue.consumer.message中的类

MessageExtensionAdapter author: gaohaoxiang date: 2019/3/1

MessageExtensionHeaderAdapter(ConsumeMessage) - 类 的构造器io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

MessageExtensionHeaderAdapter - io.openmessaging.joyqueue.producer.message中的类

MessageExtensionAdapter author: gaohaoxiang date: 2019/3/1

MessageExtensionHeaderAdapter(ProduceMessage) - 类 的构造器io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

messageFactory() - 类 中的方法io.openmessaging.joyqueue.MessagingAccessPointImpl

MessageFetcher - org.joyqueue.client.internal.consumer中的接口

MessageFetcher author: gaohaoxiang date: 2018/12/7

MessageFetcherFactory - org.joyqueue.client.internal.consumer中的类

MessageFetcherFactory author: gaohaoxiang date: 2018/12/27

MessageFetcherFactory() - 类 的构造器org.joyqueue.client.internal.consumer.MessageFetcherFactory

MessageFetcherWrapper - org.joyqueue.client.internal.consumer.support中的类

MessageFetcherWrapper author: gaohaoxiang date: 2018/12/27

MessageFetcherWrapper(ConsumerClientManager, MessageFetcher) - 类 的构造器org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

MessageHeaderAdapter - io.openmessaging.joyqueue.consumer.message中的类

MessageHeaderAdapter author: gaohaoxiang date: 2019/3/1

MessageHeaderAdapter(ConsumeMessage) - 类 的构造器io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

MessageHeaderAdapter - io.openmessaging.joyqueue.producer.message中的类

MessageHeaderAdapter author: gaohaoxiang date: 2019/3/1

MessageHeaderAdapter(ProduceMessage) - 类 的构造器io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

messageId() - 类 中的方法io.openmessaging.joyqueue.producer.support.SendResultAdapter

messageId() - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionalResultAdapter

MessageListener - org.joyqueue.client.internal.consumer中的接口

MessageListener author: gaohaoxiang date: 2018/12/25

MessageListenerAdapter - io.openmessaging.joyqueue.consumer.support中的类

MessageListenerAdapter author: gaohaoxiang date: 2019/2/20

MessageListenerAdapter(MessageListener) - 类 的构造器io.openmessaging.joyqueue.consumer.support.MessageListenerAdapter

MessageListenerContainer - org.joyqueue.client.internal.consumer中的接口

MessageListenerContainer author: gaohaoxiang date: 2018/12/25

MessageListenerContainerFactory - org.joyqueue.client.internal.consumer.container中的类

已过时。

MessageListenerContainerFactory() - 类 的构造器org.joyqueue.client.internal.consumer.container.MessageListenerContainerFactory

已过时。

MessageListenerContainerWrapper - org.joyqueue.client.internal.consumer.container中的类

author: gaohaoxiang date: 2018/12/27

MessageListenerContainerWrapper(ConsumerConfig, NameServerConfig, ClusterManager, ClusterClientManager, ConsumerClientManager, MessageListenerContainer) - 类 的构造器org.joyqueue.client.internal.consumer.container.MessageListenerContainerWrapper

MessageListenerContextAdapter - io.openmessaging.joyqueue.consumer.support中的类

MessageListenerContextAdapter author: gaohaoxiang date: 2019/2/20

MessageListenerContextAdapter() - 类 的构造器io.openmessaging.joyqueue.consumer.support.MessageListenerContextAdapter

MessageListenerManager - org.joyqueue.client.internal.consumer.support中的类

MessageListenerManager author: gaohaoxiang date: 2018/12/25

MessageListenerManager() - 类 的构造器org.joyqueue.client.internal.consumer.support.MessageListenerManager

MessagePoller - org.joyqueue.client.internal.consumer中的接口

MessagePoller author: gaohaoxiang date: 2018/12/11

MessagePollerFactory - org.joyqueue.client.internal.consumer中的类

MessagePollerFactory author: gaohaoxiang date: 2018/12/27

MessagePollerFactory() - 类 的构造器org.joyqueue.client.internal.consumer.MessagePollerFactory

MessagePollerInner - org.joyqueue.client.internal.consumer.support中的类

MessagePollerInner author: gaohaoxiang date: 2019/1/4

MessagePollerInner(ConsumerConfig, NameServerConfig, ClusterManager, ConsumerClientManager, MessageFetcher) - 类 的构造器org.joyqueue.client.internal.consumer.support.MessagePollerInner

MessagePollerWrapper - org.joyqueue.client.internal.consumer.support中的类

MessagePollerWrapper author: gaohaoxiang date: 2018/12/27

MessagePollerWrapper(ConsumerConfig, NameServerConfig, ClusterManager, ClusterClientManager, ConsumerClientManager, MessagePoller) - 类 的构造器org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

MessageProducer - org.joyqueue.client.internal.producer中的接口

MessageProducer author: gaohaoxiang date: 2018/12/10

MessageProducerFactory - org.joyqueue.client.internal.producer中的类

MessageProducerFactory author: gaohaoxiang date: 2018/12/27

MessageProducerFactory() - 类 的构造器org.joyqueue.client.internal.producer.MessageProducerFactory

MessageProducerInner - org.joyqueue.client.internal.producer.support中的类

MessageProducerInner author: gaohaoxiang date: 2019/1/4

MessageProducerInner(ProducerConfig, NameServerConfig, MessageSender, ClusterManager, ProducerClientManager) - 类 的构造器org.joyqueue.client.internal.producer.support.MessageProducerInner

MessageProducerInner(ProducerConfig, NameServerConfig, MessageSender, ClusterManager, ProducerClientManager, ProducerInterceptorManager) - 类 的构造器org.joyqueue.client.internal.producer.support.MessageProducerInner

MessageProducerWrapper - org.joyqueue.client.internal.producer.support中的类

MessageProducerWrapper author: gaohaoxiang date: 2018/12/27

MessageProducerWrapper(ClusterManager, ProducerClientManager, MessageProducer) - 类 的构造器org.joyqueue.client.internal.producer.support.MessageProducerWrapper

MessagePropertiesAdapter - io.openmessaging.joyqueue.consumer.message中的类

MessagePropertiesAdapter author: gaohaoxiang date: 2019/3/1

MessagePropertiesAdapter(ConsumeMessage) - 类 的构造器io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

MessagePropertiesAdapter - io.openmessaging.joyqueue.producer.message中的类

MessagePropertiesAdapter author: gaohaoxiang date: 2019/3/1

MessagePropertiesAdapter(ProduceMessage) - 类 的构造器io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

MessageReceiptAdapter - io.openmessaging.joyqueue.consumer.message中的类

MessageReceiptAdapter author: gaohaoxiang date: 2019/3/1

MessageReceiptAdapter(ConsumeMessage) - 类 的构造器io.openmessaging.joyqueue.consumer.message.MessageReceiptAdapter

MessageSender - org.joyqueue.client.internal.producer中的接口

MessageSender author: gaohaoxiang date: 2018/12/10

MessageSenderConverter - org.joyqueue.client.internal.producer.converter中的类

MessageSenderConverter author: gaohaoxiang date: 2018/12/28

MessageSenderConverter() - 类 的构造器org.joyqueue.client.internal.producer.converter.MessageSenderConverter

MessageSenderFactory - org.joyqueue.client.internal.producer中的类

MessageSenderFactory author: gaohaoxiang date: 2018/12/27

MessageSenderFactory() - 类 的构造器org.joyqueue.client.internal.producer.MessageSenderFactory

MessageSenderWrapper - org.joyqueue.client.internal.producer中的类

MessageSenderWrapper author: gaohaoxiang date: 2018/12/27

MessageSenderWrapper(ProducerClientManager, MessageSender) - 类 的构造器org.joyqueue.client.internal.producer.MessageSenderWrapper

MessagingAccessPointImpl - io.openmessaging.joyqueue中的类

MessagingAccessPointImpl author: gaohaoxiang date: 2019/2/18

MessagingAccessPointImpl(KeyValue) - 类 的构造器io.openmessaging.joyqueue.MessagingAccessPointImpl

METADATA_TEMP_INTERVAL - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueNameServerBuiltinKeys

METADATA_UPDATE_INTERVAL - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueNameServerBuiltinKeys

METADATA_UPDATE_QUEUE_SIZE - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueNameServerBuiltinKeys

METADATA_UPDATE_THREAD - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueNameServerBuiltinKeys

MetadataCacheManager - org.joyqueue.client.internal.cluster中的类

MetadataCacheManager author: gaohaoxiang date: 2018/12/12

MetadataCacheManager(NameServerConfig) - 类 的构造器org.joyqueue.client.internal.cluster.MetadataCacheManager

MetadataException - org.joyqueue.client.internal.metadata.exception中的异常错误

MetadataException author: gaohaoxiang date: 2018/12/3

MetadataException() - 异常错误 的构造器org.joyqueue.client.internal.metadata.exception.MetadataException

MetadataException(String) - 异常错误 的构造器org.joyqueue.client.internal.metadata.exception.MetadataException

MetadataException(String, Throwable) - 异常错误 的构造器org.joyqueue.client.internal.metadata.exception.MetadataException

MetadataException(Throwable) - 异常错误 的构造器org.joyqueue.client.internal.metadata.exception.MetadataException

MetadataException(String, int) - 异常错误 的构造器org.joyqueue.client.internal.metadata.exception.MetadataException

MetadataException(String, int, Throwable) - 异常错误 的构造器org.joyqueue.client.internal.metadata.exception.MetadataException

MetadataManager - org.joyqueue.client.internal.metadata中的类

MetadataManager author: gaohaoxiang date: 2018/11/28

MetadataManager(ClusterClientManager) - 类 的构造器org.joyqueue.client.internal.metadata.MetadataManager

MetadataUpdater - org.joyqueue.client.internal.cluster中的类

MetadataUpdater author: gaohaoxiang date: 2019/1/2

MetadataUpdater(NameServerConfig, MetadataManager, MetadataCacheManager) - 类 的构造器org.joyqueue.client.internal.cluster.MetadataUpdater

N

NAME - 类 中的静态变量org.joyqueue.client.internal.common.compress.support.SnappyCompressor

NAME - 类 中的静态变量org.joyqueue.client.internal.common.compress.support.ZlibCompressor

NAME - 类 中的静态变量org.joyqueue.client.internal.consumer.support.RandomBrokerLoadBalance

NAME - 类 中的静态变量org.joyqueue.client.internal.consumer.support.RoundRobinBrokerLoadBalance

NAME - 类 中的静态变量org.joyqueue.client.internal.producer.support.WeightedRoundRobinPartitionSelector

NameServerConfig - org.joyqueue.client.internal.nameserver中的类

NameServerConfig author: gaohaoxiang date: 2018/11/29

NameServerConfig() - 类 的构造器org.joyqueue.client.internal.nameserver.NameServerConfig

NameServerConfigChecker - org.joyqueue.client.internal.nameserver中的类

NameServerConfigChecker author: gaohaoxiang date: 2019/2/19

NameServerConfigChecker() - 类 的构造器org.joyqueue.client.internal.nameserver.NameServerConfigChecker

NameServerHelper - org.joyqueue.client.internal.nameserver.helper中的类

NameServerHelper author: gaohaoxiang date: 2018/12/20

NameServerHelper() - 类 的构造器org.joyqueue.client.internal.nameserver.helper.NameServerHelper

NAMESPACE - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueNameServerBuiltinKeys

namespace(String) - 类 中的方法org.joyqueue.client.internal.trace.TraceBuilder

NeedRetryException - org.joyqueue.client.internal.producer.exception中的异常错误

RetryException author: gaohaoxiang date: 2018/12/26

NeedRetryException() - 异常错误 的构造器org.joyqueue.client.internal.producer.exception.NeedRetryException

NeedRetryException(String) - 异常错误 的构造器org.joyqueue.client.internal.producer.exception.NeedRetryException

NeedRetryException(String, Throwable) - 异常错误 的构造器org.joyqueue.client.internal.producer.exception.NeedRetryException

NeedRetryException(Throwable) - 异常错误 的构造器org.joyqueue.client.internal.producer.exception.NeedRetryException

NeedRetryException(String, int) - 异常错误 的构造器org.joyqueue.client.internal.producer.exception.NeedRetryException

NeedRetryException(String, int, Throwable) - 异常错误 的构造器org.joyqueue.client.internal.producer.exception.NeedRetryException

newInstance() - 类 中的静态方法org.joyqueue.client.internal.trace.TraceBuilder

newTopicMessageConsumer(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

newTopicMetadataHolder(String, TopicMetadata) - 类 中的方法org.joyqueue.client.internal.cluster.MetadataCacheManager

nextPartition(ProduceMessage, TopicMetadata, List<PartitionMetadata>) - 类 中的方法org.joyqueue.client.internal.producer.support.AbstractPartitionSelector

nextPartition(ProduceMessage, TopicMetadata, List<PartitionMetadata>) - 类 中的方法org.joyqueue.client.internal.producer.support.WeightedRoundRobinPartitionSelector

NONBLOCK_ONEWAY - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

NONE_ACK_TIMEOUT - 类 中的静态变量org.joyqueue.client.internal.consumer.config.ConsumerConfig

NONE_BATCH_SIZE - 类 中的静态变量org.joyqueue.client.internal.consumer.config.ConsumerConfig

NONE_BROADCAST_INDEX_EXPIRE_TIME - 类 中的静态变量org.joyqueue.client.internal.consumer.config.ConsumerConfig

NONE_PARTITION - 类 中的静态变量org.joyqueue.client.internal.producer.domain.ProduceMessage

NONE_PARTITION_KEY - 类 中的静态变量org.joyqueue.client.internal.producer.domain.ProduceMessage

NONE_PRODUCE_TIMEOUT - 类 中的静态变量org.joyqueue.client.internal.producer.config.ProducerConfig

NoneTrace - org.joyqueue.client.internal.trace.support中的类

NoneTrace author: gaohaoxiang date: 2019/1/3

NoneTrace() - 类 的构造器org.joyqueue.client.internal.trace.support.NoneTrace

NoneTraceCaller - org.joyqueue.client.internal.trace.support中的类

NoneTraceCaller author: gaohaoxiang date: 2019/1/3

NoneTraceCaller() - 类 的构造器org.joyqueue.client.internal.trace.support.NoneTraceCaller

O

OMSProduceMessage - io.openmessaging.joyqueue.producer.message中的类

OMSProduceMessage author: gaohaoxiang date: 2019/3/1

OMSProduceMessage() - 类 的构造器io.openmessaging.joyqueue.producer.message.OMSProduceMessage

OnceConsumerInvoker - org.joyqueue.client.internal.consumer.support中的类

OnceConsumerInvoker author: gaohaoxiang date: 2019/1/11

OnceConsumerInvoker(ConsumerConfig, TopicMetadata, ConsumerPolicy, List<ConsumeMessage>, List<MessageListener>) - 类 的构造器org.joyqueue.client.internal.consumer.support.OnceConsumerInvoker

onEvent(TransportEvent) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClientConnectionListener

onEvent(TransportEvent) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClientConnectionListener

onEvent(TransportEvent) - 类 中的方法org.joyqueue.client.internal.transport.ClientConnectionListener

oneway(Command, long) - 类 中的方法org.joyqueue.client.internal.transport.Client

onException(Throwable) - 接口 中的方法org.joyqueue.client.internal.consumer.callback.BatchFetchListener

onException(Throwable) - 接口 中的方法org.joyqueue.client.internal.consumer.callback.BatchPartitionFetchListener

onException(Throwable) - 接口 中的方法org.joyqueue.client.internal.consumer.callback.FetchListener

onException(String, short, long, Throwable) - 接口 中的方法org.joyqueue.client.internal.consumer.callback.PartitionConsumerListener

onException(Throwable) - 接口 中的方法org.joyqueue.client.internal.consumer.callback.PartitionFetchListener

onException(Throwable) - 接口 中的方法org.joyqueue.client.internal.consumer.callback.PollerListener

onException(Throwable) - 类 中的方法org.joyqueue.client.internal.consumer.support.CompletableFuturePollerListener

onException(List<ProduceMessage>, Throwable) - 接口 中的方法org.joyqueue.client.internal.producer.callback.AsyncBatchProduceCallback

onException(List<ProduceMessage>, Throwable) - 类 中的方法org.joyqueue.client.internal.producer.callback.AsyncBatchProduceCallbackAdapter

onException(List<ProduceMessage>, Throwable) - 接口 中的方法org.joyqueue.client.internal.producer.callback.AsyncBatchSendCallback

onException(Map<String, List<ProduceMessage>>, Throwable) - 接口 中的方法org.joyqueue.client.internal.producer.callback.AsyncMultiBatchSendCallback

onException(ProduceMessage, Throwable) - 接口 中的方法org.joyqueue.client.internal.producer.callback.AsyncProduceCallback

onException(ProduceMessage, Throwable) - 接口 中的方法org.joyqueue.client.internal.producer.callback.AsyncSendCallback

onException(List<ProduceMessage>, Throwable) - 类 中的方法org.joyqueue.client.internal.producer.callback.CompletableFutureAsyncBatchProduceCallback

onException(ProduceMessage, Throwable) - 类 中的方法org.joyqueue.client.internal.producer.callback.CompletableFutureAsyncProduceCallback

onMessage(List<ConsumeMessage>) - 类 中的方法io.openmessaging.joyqueue.consumer.support.BatchMessageListenerAdapter

onMessage(ConsumeMessage) - 类 中的方法io.openmessaging.joyqueue.consumer.support.MessageListenerAdapter

onMessage(List<ConsumeMessage>) - 接口 中的方法org.joyqueue.client.internal.consumer.BatchMessageListener

onMessage(Map<String, FetchMessageData>) - 接口 中的方法org.joyqueue.client.internal.consumer.callback.BatchFetchListener

onMessage(Table<String, Short, FetchMessageData>) - 接口 中的方法org.joyqueue.client.internal.consumer.callback.BatchPartitionFetchListener

onMessage(FetchMessageData) - 接口 中的方法org.joyqueue.client.internal.consumer.callback.FetchListener

onMessage(FetchMessageData) - 接口 中的方法org.joyqueue.client.internal.consumer.callback.PartitionConsumerListener

onMessage(FetchMessageData) - 接口 中的方法org.joyqueue.client.internal.consumer.callback.PartitionFetchListener

onMessage(List<ConsumeMessage>) - 接口 中的方法org.joyqueue.client.internal.consumer.callback.PollerListener

onMessage(ConsumeMessage) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageListener

onMessage(List<ConsumeMessage>) - 类 中的方法org.joyqueue.client.internal.consumer.support.CompletableFuturePollerListener

onSuccess(List<ProduceMessage>, List<SendResult>) - 接口 中的方法org.joyqueue.client.internal.producer.callback.AsyncBatchProduceCallback

onSuccess(List<ProduceMessage>, List<SendResult>) - 类 中的方法org.joyqueue.client.internal.producer.callback.AsyncBatchProduceCallbackAdapter

onSuccess(List<ProduceMessage>, SendBatchResultData) - 接口 中的方法org.joyqueue.client.internal.producer.callback.AsyncBatchSendCallback

onSuccess(Map<String, List<ProduceMessage>>, Map<String, SendBatchResultData>) - 接口 中的方法org.joyqueue.client.internal.producer.callback.AsyncMultiBatchSendCallback

onSuccess(ProduceMessage, SendResult) - 接口 中的方法org.joyqueue.client.internal.producer.callback.AsyncProduceCallback

onSuccess(ProduceMessage, SendResultData) - 接口 中的方法org.joyqueue.client.internal.producer.callback.AsyncSendCallback

onSuccess(List<ProduceMessage>, List<SendResult>) - 类 中的方法org.joyqueue.client.internal.producer.callback.CompletableFutureAsyncBatchProduceCallback

onSuccess(ProduceMessage, SendResult) - 类 中的方法org.joyqueue.client.internal.producer.callback.CompletableFutureAsyncProduceCallback

Ordered - org.joyqueue.client.internal.common.ordered中的接口

排序 author: gaohaoxiang date: 2018/8/27

OrderedComparator - org.joyqueue.client.internal.common.ordered中的类

OrderedComparator author: gaohaoxiang date: 2019/1/11

OrderedComparator() - 类 的构造器org.joyqueue.client.internal.common.ordered.OrderedComparator

OrderedSorter - org.joyqueue.client.internal.common.ordered中的类

OrderedSorter author: gaohaoxiang date: 2019/1/11

OrderedSorter() - 类 的构造器org.joyqueue.client.internal.common.ordered.OrderedSorter

org.joyqueue.client.internal - 程序包 org.joyqueue.client.internal

org.joyqueue.client.internal.cluster - 程序包 org.joyqueue.client.internal.cluster

org.joyqueue.client.internal.cluster.domain - 程序包 org.joyqueue.client.internal.cluster.domain

org.joyqueue.client.internal.cluster.exception - 程序包 org.joyqueue.client.internal.cluster.exception

org.joyqueue.client.internal.common.compress - 程序包 org.joyqueue.client.internal.common.compress

org.joyqueue.client.internal.common.compress.support - 程序包 org.joyqueue.client.internal.common.compress.support

org.joyqueue.client.internal.common.interceptor - 程序包 org.joyqueue.client.internal.common.interceptor

org.joyqueue.client.internal.common.ordered - 程序包 org.joyqueue.client.internal.common.ordered

org.joyqueue.client.internal.consumer - 程序包 org.joyqueue.client.internal.consumer

org.joyqueue.client.internal.consumer.callback - 程序包 org.joyqueue.client.internal.consumer.callback

org.joyqueue.client.internal.consumer.config - 程序包 org.joyqueue.client.internal.consumer.config

org.joyqueue.client.internal.consumer.container - 程序包 org.joyqueue.client.internal.consumer.container

org.joyqueue.client.internal.consumer.converter - 程序包 org.joyqueue.client.internal.consumer.converter

org.joyqueue.client.internal.consumer.coordinator - 程序包 org.joyqueue.client.internal.consumer.coordinator

org.joyqueue.client.internal.consumer.coordinator.domain - 程序包 org.joyqueue.client.internal.consumer.coordinator.domain

org.joyqueue.client.internal.consumer.domain - 程序包 org.joyqueue.client.internal.consumer.domain

org.joyqueue.client.internal.consumer.exception - 程序包 org.joyqueue.client.internal.consumer.exception

org.joyqueue.client.internal.consumer.interceptor - 程序包 org.joyqueue.client.internal.consumer.interceptor

org.joyqueue.client.internal.consumer.support - 程序包 org.joyqueue.client.internal.consumer.support

org.joyqueue.client.internal.consumer.transport - 程序包 org.joyqueue.client.internal.consumer.transport

org.joyqueue.client.internal.exception - 程序包 org.joyqueue.client.internal.exception

org.joyqueue.client.internal.metadata - 程序包 org.joyqueue.client.internal.metadata

org.joyqueue.client.internal.metadata.converter - 程序包 org.joyqueue.client.internal.metadata.converter

org.joyqueue.client.internal.metadata.domain - 程序包 org.joyqueue.client.internal.metadata.domain

org.joyqueue.client.internal.metadata.exception - 程序包 org.joyqueue.client.internal.metadata.exception

org.joyqueue.client.internal.nameserver - 程序包 org.joyqueue.client.internal.nameserver

org.joyqueue.client.internal.nameserver.helper - 程序包 org.joyqueue.client.internal.nameserver.helper

org.joyqueue.client.internal.producer - 程序包 org.joyqueue.client.internal.producer

org.joyqueue.client.internal.producer.callback - 程序包 org.joyqueue.client.internal.producer.callback

org.joyqueue.client.internal.producer.checker - 程序包 org.joyqueue.client.internal.producer.checker

org.joyqueue.client.internal.producer.config - 程序包 org.joyqueue.client.internal.producer.config

org.joyqueue.client.internal.producer.converter - 程序包 org.joyqueue.client.internal.producer.converter

org.joyqueue.client.internal.producer.domain - 程序包 org.joyqueue.client.internal.producer.domain

org.joyqueue.client.internal.producer.exception - 程序包 org.joyqueue.client.internal.producer.exception

org.joyqueue.client.internal.producer.feedback - 程序包 org.joyqueue.client.internal.producer.feedback

org.joyqueue.client.internal.producer.feedback.config - 程序包 org.joyqueue.client.internal.producer.feedback.config

org.joyqueue.client.internal.producer.helper - 程序包 org.joyqueue.client.internal.producer.helper

org.joyqueue.client.internal.producer.interceptor - 程序包 org.joyqueue.client.internal.producer.interceptor

org.joyqueue.client.internal.producer.support - 程序包 org.joyqueue.client.internal.producer.support

org.joyqueue.client.internal.producer.transport - 程序包 org.joyqueue.client.internal.producer.transport

org.joyqueue.client.internal.support - 程序包 org.joyqueue.client.internal.support

org.joyqueue.client.internal.trace - 程序包 org.joyqueue.client.internal.trace

org.joyqueue.client.internal.trace.interceptor - 程序包 org.joyqueue.client.internal.trace.interceptor

org.joyqueue.client.internal.trace.support - 程序包 org.joyqueue.client.internal.trace.support

org.joyqueue.client.internal.transport - 程序包 org.joyqueue.client.internal.transport

org.joyqueue.client.internal.transport.config - 程序包 org.joyqueue.client.internal.transport.config

P

PACKAGE_VERSION - 类 中的静态变量org.joyqueue.client.internal.ClientConsts

PARTITION_SELECTOR - 接口 中的静态变量org.joyqueue.client.internal.Plugins

partition 选择器

PartitionAdapter - io.openmessaging.joyqueue.extension中的类

PartitionAdapter author: gaohaoxiang date: 2019/3/1

PartitionAdapter(PartitionMetadata) - 类 的构造器io.openmessaging.joyqueue.extension.PartitionAdapter

PartitionAssignment - org.joyqueue.client.internal.consumer.coordinator.domain中的类

getPartitionAssignment author: gaohaoxiang date: 2018/12/6

PartitionAssignment() - 类 的构造器org.joyqueue.client.internal.consumer.coordinator.domain.PartitionAssignment

PartitionAssignment(List<Short>) - 类 的构造器org.joyqueue.client.internal.consumer.coordinator.domain.PartitionAssignment

PartitionAssignmentHolder - org.joyqueue.client.internal.consumer.coordinator.domain中的类

PartitionAssignmentHolder author: gaohaoxiang date: 2018/12/11

PartitionAssignmentHolder(PartitionAssignment, long) - 类 的构造器org.joyqueue.client.internal.consumer.coordinator.domain.PartitionAssignmentHolder

PartitionAssignmentManager - org.joyqueue.client.internal.consumer.coordinator中的类

PartitionAssignmentManager author: gaohaoxiang date: 2018/12/11

PartitionAssignmentManager(ClusterClientManager, CoordinatorManager) - 类 的构造器org.joyqueue.client.internal.consumer.coordinator.PartitionAssignmentManager

PartitionConsumerListener - org.joyqueue.client.internal.consumer.callback中的接口

BatchPartitionFetchListener author: gaohaoxiang date: 2018/12/10

PartitionFetchListener - org.joyqueue.client.internal.consumer.callback中的接口

BatchPartitionFetchListener author: gaohaoxiang date: 2018/12/10

PartitionGroupMetadata - org.joyqueue.client.internal.metadata.domain中的类

PartitionGroupMetadata author: gaohaoxiang date: 2018/12/3

PartitionGroupMetadata(int, BrokerNode, Map<Short, PartitionMetadata>) - 类 的构造器org.joyqueue.client.internal.metadata.domain.PartitionGroupMetadata

partitionId() - 类 中的方法io.openmessaging.joyqueue.extension.PartitionAdapter

PartitionMessagePoller - org.joyqueue.client.internal.consumer.support中的类

PartitionMessagePoller author: gaohaoxiang date: 2018/12/14

PartitionMessagePoller(ConsumerConfig, NameServerConfig, ClusterManager, ConsumerClientManager, ConsumerIndexManager) - 类 的构造器org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

PartitionMetadata - org.joyqueue.client.internal.metadata.domain中的类

PartitionMetadata author: gaohaoxiang date: 2018/12/3

PartitionMetadata(short, int, String, BrokerNode) - 类 的构造器org.joyqueue.client.internal.metadata.domain.PartitionMetadata

partitions() - 类 中的方法io.openmessaging.joyqueue.extension.QueueMetaDataAdapter

PartitionSelector - org.joyqueue.client.internal.producer中的接口

PartitionSelector author: gaohaoxiang date: 2018/12/10

PartitionSelectorManager - org.joyqueue.client.internal.producer.support中的类

PartitionSelectorManager author: gaohaoxiang date: 2019/1/3

PartitionSelectorManager() - 类 的构造器org.joyqueue.client.internal.producer.support.PartitionSelectorManager

partitonHost() - 类 中的方法io.openmessaging.joyqueue.extension.PartitionAdapter

persist() - 类 中的方法org.joyqueue.client.internal.consumer.support.ConsumerLocalIndexStore

Plugins - org.joyqueue.client.internal中的接口

poll() - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

poll(long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

poll(String) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

poll(String, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

poll(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

poll(String, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

poll() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

poll(long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

poll(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

poll(String, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

poll() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

poll(long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

poll(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

poll(String, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

poll(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

poll(String, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

POLL_TIMEOUT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

pollAsync() - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollAsync(long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollAsync(String) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollAsync(String, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollAsync(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollAsync(String, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollAsync() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollAsync(long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollAsync(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollAsync(String, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollAsync() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollAsync(long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollAsync(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollAsync(String, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollAsync(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

pollAsync(String, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

PollerListener - org.joyqueue.client.internal.consumer.callback中的接口

BatchFetchListener author: gaohaoxiang date: 2018/12/10

pollOnce() - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollOnce(long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollOnce(String) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollOnce(String, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollOnce(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollOnce(String, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollOnce() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollOnce(long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollOnce(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollOnce(String, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollOnce() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollOnce(long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollOnce(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollOnce(String, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollOnce(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

pollOnce(String, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

pollPartition(short) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollPartition(short, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollPartition(short, long) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollPartition(short, long, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollPartition(String, short) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollPartition(String, short, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollPartition(String, short, long) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollPartition(String, short, long, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollPartition(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollPartition(String, short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollPartition(String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollPartition(String, short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollPartition(short) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollPartition(short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollPartition(short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollPartition(short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollPartition(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollPartition(String, short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollPartition(String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollPartition(String, short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollPartition(short) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollPartition(short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollPartition(short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollPartition(short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollPartition(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollPartition(String, short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollPartition(String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollPartition(String, short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollPartition(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

pollPartition(String, short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

pollPartition(String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

pollPartition(String, short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

pollPartitionAsync(short) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollPartitionAsync(short, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollPartitionAsync(short, long) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollPartitionAsync(short, long, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollPartitionAsync(String, short) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollPartitionAsync(String, short, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollPartitionAsync(String, short, long) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollPartitionAsync(String, short, long, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollPartitionAsync(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollPartitionAsync(String, short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollPartitionAsync(String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollPartitionAsync(String, short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollPartitionAsync(short) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollPartitionAsync(short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollPartitionAsync(short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollPartitionAsync(short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollPartitionAsync(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollPartitionAsync(String, short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollPartitionAsync(String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollPartitionAsync(String, short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollPartitionAsync(short) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollPartitionAsync(short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollPartitionAsync(short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollPartitionAsync(short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollPartitionAsync(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollPartitionAsync(String, short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollPartitionAsync(String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollPartitionAsync(String, short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollPartitionAsync(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

pollPartitionAsync(String, short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

pollPartitionAsync(String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

pollPartitionAsync(String, short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

pollPartitionOnce(short) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollPartitionOnce(short, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollPartitionOnce(short, long) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollPartitionOnce(short, long, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

pollPartitionOnce(String, short) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollPartitionOnce(String, short, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollPartitionOnce(String, short, long) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollPartitionOnce(String, short, long, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

pollPartitionOnce(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollPartitionOnce(String, short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollPartitionOnce(String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollPartitionOnce(String, short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

pollPartitionOnce(short) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollPartitionOnce(short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollPartitionOnce(short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollPartitionOnce(short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

pollPartitionOnce(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollPartitionOnce(String, short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollPartitionOnce(String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollPartitionOnce(String, short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

pollPartitionOnce(short) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollPartitionOnce(short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollPartitionOnce(short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollPartitionOnce(short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

pollPartitionOnce(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollPartitionOnce(String, short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollPartitionOnce(String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollPartitionOnce(String, short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

pollPartitionOnce(String, short) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

pollPartitionOnce(String, short, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

pollPartitionOnce(String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

pollPartitionOnce(String, short, long, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

postConsume(ConsumeContext, List<ConsumeReply>) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerInterceptorAdapter

postConsume(ConsumeContext, List<ConsumeReply>) - 接口 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumerInterceptor

postConsume(ConsumeContext, List<ConsumeReply>) - 类 中的方法org.joyqueue.client.internal.trace.interceptor.TraceConsumerInterceptor

postSend(ProduceContext, List<SendResult>) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerInterceptorAdapter

postSend(ProduceContext, List<SendResult>) - 接口 中的方法org.joyqueue.client.internal.producer.interceptor.ProducerInterceptor

postSend(ProduceContext, List<SendResult>) - 类 中的方法org.joyqueue.client.internal.trace.interceptor.TraceProducerInterceptor

preConsume(ConsumeContext) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerInterceptorAdapter

preConsume(ConsumeContext) - 接口 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumerInterceptor

preConsume(ConsumeContext) - 类 中的方法org.joyqueue.client.internal.trace.interceptor.TraceConsumerInterceptor

prepare() - 接口 中的方法io.openmessaging.joyqueue.producer.ExtensionProducer

prepare(String) - 接口 中的方法io.openmessaging.joyqueue.producer.ExtensionProducer

prepare(String) - 类 中的方法io.openmessaging.joyqueue.producer.support.ExtensionTransactionalResultAdapter

prepare(Message) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

prepare() - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

prepare(String) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

prepare(Message, String, MessageProducer) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionalResultAdapter

prepare(Message) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

prepare(String) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

prepare() - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

prepare() - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

prepare(String) - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

prepare(Message) - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

prepare(BrokerNode, String, String, String, long, long, long) - 接口 中的方法org.joyqueue.client.internal.producer.MessageSender

prepare(BrokerNode, String, String, String, long, long, long) - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

prepare(BrokerNode, String, String, String, long, long, long) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

preSend(ProduceContext) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerInterceptorAdapter

preSend(ProduceContext) - 接口 中的方法org.joyqueue.client.internal.producer.interceptor.ProducerInterceptor

preSend(ProduceContext) - 类 中的方法org.joyqueue.client.internal.trace.interceptor.TraceProducerInterceptor

printLog - 类 中的静态变量org.joyqueue.client.internal.cluster.MetadataUpdater

printLog() - 类 中的方法org.joyqueue.client.internal.cluster.MetadataUpdater

printLogInterval - 类 中的静态变量org.joyqueue.client.internal.cluster.MetadataUpdater

PRODUCE_TIMEOUT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys

ProduceContext - org.joyqueue.client.internal.producer.interceptor中的类

ProduceContext author: gaohaoxiang date: 2019/1/11

ProduceContext(String, String, NameServerConfig, List<ProduceMessage>) - 类 的构造器org.joyqueue.client.internal.producer.interceptor.ProduceContext

ProduceMessage - org.joyqueue.client.internal.producer.domain中的类

ProduceMessageRequest author: gaohaoxiang date: 2018/12/10

ProduceMessage() - 类 的构造器org.joyqueue.client.internal.producer.domain.ProduceMessage

ProduceMessage(String, String) - 类 的构造器org.joyqueue.client.internal.producer.domain.ProduceMessage

ProduceMessage(String, String, String) - 类 的构造器org.joyqueue.client.internal.producer.domain.ProduceMessage

ProduceMessage(String, String, String, String) - 类 的构造器org.joyqueue.client.internal.producer.domain.ProduceMessage

produceMessage(String, Map<String, ProduceMessageData>, long) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClient

ProduceMessageChecker - org.joyqueue.client.internal.producer.checker中的类

ProduceMessageChecker author: gaohaoxiang date: 2018/12/20

ProduceMessageChecker() - 类 的构造器org.joyqueue.client.internal.producer.checker.ProduceMessageChecker

produceMessageCommit(String, String, String, long) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClient

ProduceMessageConverter - org.joyqueue.client.internal.producer.converter中的类

ProduceMessageConverter author: gaohaoxiang date: 2018/12/20

ProduceMessageConverter() - 类 的构造器org.joyqueue.client.internal.producer.converter.ProduceMessageConverter

produceMessageOneway(String, Map<String, ProduceMessageData>, long) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClient

produceMessagePrepare(String, String, long, String, long, long) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClient

produceMessageRollback(String, String, String, long) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClient

PRODUCER_INTERCEPTOR - 接口 中的静态变量org.joyqueue.client.internal.Plugins

发送过拦截器插件

ProducerClient - org.joyqueue.client.internal.producer.transport中的类

ProducerClient author: gaohaoxiang date: 2018/11/29

ProducerClient(Client) - 类 的构造器org.joyqueue.client.internal.producer.transport.ProducerClient

ProducerClientConnectionListener - org.joyqueue.client.internal.producer.transport中的类

ClientConnectionListener author: gaohaoxiang date: 2018/11/28

ProducerClientConnectionListener(Transport, ProducerClient) - 类 的构造器org.joyqueue.client.internal.producer.transport.ProducerClientConnectionListener

ProducerClientGroup - org.joyqueue.client.internal.producer.transport中的类

ProducerClientGroup author: gaohaoxiang date: 2019/2/12

ProducerClientGroup(ClientGroup) - 类 的构造器org.joyqueue.client.internal.producer.transport.ProducerClientGroup

ProducerClientManager - org.joyqueue.client.internal.producer.transport中的类

ProducerClientManager author: gaohaoxiang date: 2018/11/28

ProducerClientManager(TransportConfig, NameServerConfig) - 类 的构造器org.joyqueue.client.internal.producer.transport.ProducerClientManager

ProducerClientManagerFactory - org.joyqueue.client.internal.producer.transport中的类

ProducerClientManagerFactory author: gaohaoxiang date: 2018/12/27

ProducerClientManagerFactory() - 类 的构造器org.joyqueue.client.internal.producer.transport.ProducerClientManagerFactory

ProducerConfig - org.joyqueue.client.internal.producer.config中的类

ProducerConfig author: gaohaoxiang date: 2018/12/10

ProducerConfig() - 类 的构造器org.joyqueue.client.internal.producer.config.ProducerConfig

ProducerConnectionState - org.joyqueue.client.internal.producer.transport中的类

ProducerConnectionState author: gaohaoxiang date: 2018/12/3

ProducerConnectionState(ProducerClient) - 类 的构造器org.joyqueue.client.internal.producer.transport.ProducerConnectionState

ProduceResult - org.joyqueue.client.internal.producer.domain中的类

ProduceResult author: gaohaoxiang date: 2018/12/10

ProduceResult(String, short, long, long) - 类 的构造器org.joyqueue.client.internal.producer.domain.ProduceResult

ProducerException - org.joyqueue.client.internal.producer.exception中的异常错误

ProducerException author: gaohaoxiang date: 2018/12/20

ProducerException() - 异常错误 的构造器org.joyqueue.client.internal.producer.exception.ProducerException

ProducerException(String) - 异常错误 的构造器org.joyqueue.client.internal.producer.exception.ProducerException

ProducerException(String, Throwable) - 异常错误 的构造器org.joyqueue.client.internal.producer.exception.ProducerException

ProducerException(Throwable) - 异常错误 的构造器org.joyqueue.client.internal.producer.exception.ProducerException

ProducerException(String, int) - 异常错误 的构造器org.joyqueue.client.internal.producer.exception.ProducerException

ProducerException(String, int, Throwable) - 异常错误 的构造器org.joyqueue.client.internal.producer.exception.ProducerException

ProducerHelper - org.joyqueue.client.internal.producer.helper中的类

ProducerHelper author: gaohaoxiang date: 2018/12/26

ProducerHelper() - 类 的构造器org.joyqueue.client.internal.producer.helper.ProducerHelper

ProducerImpl - io.openmessaging.joyqueue.producer.support中的类

ProducerImpl author: gaohaoxiang date: 2019/2/19

ProducerImpl(MessageProducer, ExtensionMessageFactory) - 类 的构造器io.openmessaging.joyqueue.producer.support.ProducerImpl

ProducerInterceptor - org.joyqueue.client.internal.producer.interceptor中的接口

ProducerInterceptor author: gaohaoxiang date: 2019/1/11

ProducerInterceptorAdapter - io.openmessaging.joyqueue.producer.support中的类

ProducerInterceptorAdapter author: gaohaoxiang date: 2019/2/19

ProducerInterceptorAdapter(ProducerInterceptor) - 类 的构造器io.openmessaging.joyqueue.producer.support.ProducerInterceptorAdapter

ProducerInterceptorManager - org.joyqueue.client.internal.producer.interceptor中的类

ProducerInterceptorManager author: gaohaoxiang date: 2019/1/11

ProducerInterceptorManager() - 类 的构造器org.joyqueue.client.internal.producer.interceptor.ProducerInterceptorManager

ProducerInvocation - org.joyqueue.client.internal.producer.interceptor中的类

ProducerInvocation author: gaohaoxiang date: 2019/1/11

ProducerInvocation(ProducerConfig, NameServerConfig, TopicMetadata, List<ProduceMessage>, ProducerInterceptorManager, ProducerInvoker) - 类 的构造器org.joyqueue.client.internal.producer.interceptor.ProducerInvocation

ProducerInvoker - org.joyqueue.client.internal.producer.interceptor中的接口

ProducerInvoker author: gaohaoxiang date: 2019/1/11

ProducerWrapper - io.openmessaging.joyqueue.support中的类

ProducerWrapper author: gaohaoxiang date: 2019/5/14

ProducerWrapper(ExtensionProducer, MessageAccessPointHolder) - 类 的构造器io.openmessaging.joyqueue.support.ProducerWrapper

properties() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageAdapter

properties() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageAdapter

put(String, boolean) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

put(String, short) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

put(String, int) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

put(String, long) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

put(String, double) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

put(String, String) - 类 中的方法io.openmessaging.joyqueue.consumer.interceptor.ContextAttributeAdapter

put(String, boolean) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

put(String, short) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

put(String, int) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

put(String, long) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

put(String, double) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

put(String, String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessagePropertiesAdapter

put(String, boolean) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

put(String, short) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

put(String, int) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

put(String, long) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

put(String, double) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

put(String, String) - 类 中的方法io.openmessaging.joyqueue.producer.interceptor.ContextAttributeAdapter

put(String, boolean) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

put(String, short) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

put(String, int) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

put(String, long) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

put(String, double) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

put(String, String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessagePropertiesAdapter

putAttribute(Object, Object) - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

putAttribute(String, String) - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

putAttribute(Object, Object) - 类 中的方法org.joyqueue.client.internal.producer.interceptor.ProduceContext

putTopicMetadata(String, String, TopicMetadata) - 类 中的方法org.joyqueue.client.internal.cluster.MetadataCacheManager

putTopicMetadata(Map<String, TopicMetadata>, String) - 类 中的方法org.joyqueue.client.internal.cluster.MetadataCacheManager

Q

QOSLEVEL - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys

QueueMetaDataAdapter - io.openmessaging.joyqueue.extension中的类

QueueMetaDataAdapter author: gaohaoxiang date: 2019/3/1

QueueMetaDataAdapter(TopicMetadata) - 类 的构造器io.openmessaging.joyqueue.extension.QueueMetaDataAdapter

queueName() - 类 中的方法io.openmessaging.joyqueue.extension.QueueMetaDataAdapter

R

RandomBrokerLoadBalance - org.joyqueue.client.internal.consumer.support中的类

RandomBrokerLoadBalance author: gaohaoxiang date: 2018/12/12

RandomBrokerLoadBalance() - 类 的构造器org.joyqueue.client.internal.consumer.support.RandomBrokerLoadBalance

receive(short, long) - 接口 中的方法io.openmessaging.joyqueue.consumer.ExtensionConsumer

receive(short, long, long) - 接口 中的方法io.openmessaging.joyqueue.consumer.ExtensionConsumer

receive(long) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

receive(short, long) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

receive(short, long, long) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

receive(short, long) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

receive(short, long, long) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

receive(long) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

reject(ConsumeContext) - 接口 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumerInvoker

reject(ConsumeContext) - 类 中的方法org.joyqueue.client.internal.consumer.support.BatchConsumerInvoker

reject(ConsumeContext) - 类 中的方法org.joyqueue.client.internal.consumer.support.OnceConsumerInvoker

reject(ProduceContext) - 接口 中的方法org.joyqueue.client.internal.producer.interceptor.ProducerInvoker

removeAttribute(Object) - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

removeAttribute(Object) - 类 中的方法org.joyqueue.client.internal.producer.interceptor.ProduceContext

removeConsumers(Collection<String>, String) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClient

removeInterceptor(ConsumerInterceptor) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

removeInterceptor(ProducerInterceptor) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

removeInterceptor(ProducerInterceptor) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

removeInterceptor(ConsumerInterceptor) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

removeInterceptor(ProducerInterceptor) - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

removeInterceptor(ConsumerInterceptor) - 类 中的方法org.joyqueue.client.internal.consumer.interceptor.ConsumerInterceptorManager

removeInterceptor(ConsumerInterceptor) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

removeInterceptor(ConsumerInterceptor) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

removeInterceptor(ConsumerInterceptor) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

removeInterceptor(ConsumerInterceptor) - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumer

removeInterceptor(ProducerInterceptor) - 类 中的方法org.joyqueue.client.internal.producer.interceptor.ProducerInterceptorManager

removeInterceptor(ProducerInterceptor) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

removeInterceptor(ProducerInterceptor) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

removeInterceptor(ProducerInterceptor) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

removeInterceptor(ProducerInterceptor) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

removeListener(BaseMessageListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageListenerManager

removeListener(BaseMessageListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumer

removeListener(EventListener<TransportEvent>) - 类 中的方法org.joyqueue.client.internal.transport.Client

removeProducers(Collection<String>, String) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClient

removeTransactionCallback(String) - 接口 中的方法org.joyqueue.client.internal.MessageAccessPoint

removeTransactionCallback(String) - 类 中的方法org.joyqueue.client.internal.producer.feedback.DefaultTxFeedbackManager

removeTransactionCallback(String) - 类 中的方法org.joyqueue.client.internal.producer.feedback.TxFeedbackManagerWrapper

removeTransactionCallback(String) - 接口 中的方法org.joyqueue.client.internal.producer.TxFeedbackManager

removeTransactionCallback(String) - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

reply(List<ConsumeReply>) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

reply(String, List<ConsumeReply>) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

reply(String, List<ConsumeReply>) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

reply(List<ConsumeReply>) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

reply(String, List<ConsumeReply>) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

reply(List<ConsumeReply>) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

reply(String, List<ConsumeReply>) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

reply(String, List<ConsumeReply>) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

replyOnce(ConsumeReply) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

replyOnce(String, ConsumeReply) - 接口 中的方法org.joyqueue.client.internal.consumer.MessagePoller

replyOnce(String, ConsumeReply) - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

replyOnce(ConsumeReply) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

replyOnce(String, ConsumeReply) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

replyOnce(ConsumeReply) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

replyOnce(String, ConsumeReply) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerWrapper

replyOnce(String, ConsumeReply) - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

resetIndex(String, String, short, long) - 接口 中的方法org.joyqueue.client.internal.consumer.ConsumerIndexManager

resetIndex(String, String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultConsumerIndexManager

resetIndex(String, String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.LocalConsumerIndexManager

resourceManager() - 类 中的方法io.openmessaging.joyqueue.MessagingAccessPointImpl

resume() - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

resume() - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

resume() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumer

resume() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumerScheduler

resumeListen() - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

resumeListen() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

resumeListen() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

RETRIES - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys

RETRIES - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

rollback() - 接口 中的方法io.openmessaging.joyqueue.producer.ExtensionTransactionalResult

rollback() - 类 中的方法io.openmessaging.joyqueue.producer.support.ExtensionTransactionalResultAdapter

rollback() - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionalContextAdapter

rollback() - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionalResultAdapter

rollback(BrokerNode, String, String, String, long) - 接口 中的方法org.joyqueue.client.internal.producer.MessageSender

rollback(BrokerNode, String, String, String, long) - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

rollback(BrokerNode, String, String, String, long) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

rollback() - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultTransactionMessageProducer

rollback() - 接口 中的方法org.joyqueue.client.internal.producer.TransactionMessageProducer

RoundRobinBrokerLoadBalance - org.joyqueue.client.internal.consumer.support中的类

RoundRobinBrokerLoadBalance author: gaohaoxiang date: 2018/12/11

RoundRobinBrokerLoadBalance() - 类 的构造器org.joyqueue.client.internal.consumer.support.RoundRobinBrokerLoadBalance

run() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumerScheduler

run() - 类 中的方法org.joyqueue.client.internal.transport.ClientHeartbeatThread

S

saveIndex(String, String, short, long) - 类 中的方法org.joyqueue.client.internal.consumer.support.ConsumerLocalIndexStore

SecurityException - org.joyqueue.client.internal.exception中的异常错误

SecurityException author: gaohaoxiang date: 2019/1/16

SecurityException() - 异常错误 的构造器org.joyqueue.client.internal.exception.SecurityException

SecurityException(String) - 异常错误 的构造器org.joyqueue.client.internal.exception.SecurityException

SecurityException(String, Throwable) - 异常错误 的构造器org.joyqueue.client.internal.exception.SecurityException

SecurityException(Throwable) - 异常错误 的构造器org.joyqueue.client.internal.exception.SecurityException

SecurityException(String, int) - 异常错误 的构造器org.joyqueue.client.internal.exception.SecurityException

SecurityException(String, int, Throwable) - 异常错误 的构造器org.joyqueue.client.internal.exception.SecurityException

select(ProduceMessage, TopicMetadata, List<PartitionMetadata>) - 接口 中的方法org.joyqueue.client.internal.producer.PartitionSelector

select(ProduceMessage, TopicMetadata, List<PartitionMetadata>) - 类 中的方法org.joyqueue.client.internal.producer.support.AbstractPartitionSelector

selectClient() - 类 中的方法org.joyqueue.client.internal.transport.ClientGroup

SELECTOR_TYPE - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys

selectPartition(ProduceMessage, TopicMetadata, List<PartitionMetadata>) - 类 中的方法org.joyqueue.client.internal.producer.support.AbstractPartitionSelector

send(Message) - 接口 中的方法io.openmessaging.joyqueue.producer.ExtensionTransactionalResult

send(List<Message>) - 接口 中的方法io.openmessaging.joyqueue.producer.ExtensionTransactionalResult

send(Message) - 类 中的方法io.openmessaging.joyqueue.producer.support.ExtensionTransactionalResultAdapter

send(List<Message>) - 类 中的方法io.openmessaging.joyqueue.producer.support.ExtensionTransactionalResultAdapter

send(Message) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

send(List<Message>) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

send(Message) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

send(List<Message>) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

send(Message) - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

send(List<Message>) - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

send(ProduceMessage) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

send(ProduceMessage, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

send(BrokerNode, String, String, String, ProduceMessage, QosLevel, long, long) - 接口 中的方法org.joyqueue.client.internal.producer.MessageSender

send(BrokerNode, String, String, String, ProduceMessage, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

send(ProduceMessage) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

send(ProduceMessage, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

send(BrokerNode, String, String, String, ProduceMessage, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

send(ProduceMessage) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultTransactionMessageProducer

send(ProduceMessage, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultTransactionMessageProducer

send(ProduceMessage, String, long, TimeUnit, boolean, boolean, AsyncProduceCallback) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

send(ProduceMessage) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

send(ProduceMessage, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

send(ProduceMessage) - 接口 中的方法org.joyqueue.client.internal.producer.TransactionMessageProducer

send(ProduceMessage, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.producer.TransactionMessageProducer

SEND_TIMEOUT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

sendAsync(Message) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

sendAsync(List<Message>) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

sendAsync(Message) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

sendAsync(List<Message>) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

sendAsync(Message) - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

sendAsync(List<Message>) - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

sendAsync(ProduceMessage) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

sendAsync(ProduceMessage, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

sendAsync(BrokerNode, String, String, String, ProduceMessage, QosLevel, long, long, AsyncSendCallback) - 接口 中的方法org.joyqueue.client.internal.producer.MessageSender

sendAsync(BrokerNode, String, String, String, ProduceMessage, QosLevel, long, long, AsyncSendCallback) - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

sendAsync(ProduceMessage) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

sendAsync(ProduceMessage, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

sendAsync(BrokerNode, String, String, String, ProduceMessage, QosLevel, long, long, AsyncSendCallback) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

sendAsync(ProduceMessage) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

sendAsync(ProduceMessage, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

SendBatchResultData - org.joyqueue.client.internal.producer.domain中的类

SendBatchResultData author: gaohaoxiang date: 2018/12/20

SendBatchResultData() - 类 的构造器org.joyqueue.client.internal.producer.domain.SendBatchResultData

SenderConfig - org.joyqueue.client.internal.producer.config中的类

SenderConfig author: gaohaoxiang date: 2019/2/11

SenderConfig() - 类 的构造器org.joyqueue.client.internal.producer.config.SenderConfig

SenderConfig(boolean, int, String, boolean) - 类 的构造器org.joyqueue.client.internal.producer.config.SenderConfig

sendOneway(Message) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

sendOneway(List<Message>) - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerImpl

sendOneway(Message) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

sendOneway(List<Message>) - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

sendOneway(Message) - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

sendOneway(List<Message>) - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

sendOneway(ProduceMessage) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

sendOneway(ProduceMessage, long, TimeUnit) - 接口 中的方法org.joyqueue.client.internal.producer.MessageProducer

sendOneway(BrokerNode, String, String, String, ProduceMessage, QosLevel, long, long) - 接口 中的方法org.joyqueue.client.internal.producer.MessageSender

sendOneway(BrokerNode, String, String, String, ProduceMessage, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.MessageSenderWrapper

sendOneway(ProduceMessage) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

sendOneway(ProduceMessage, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

sendOneway(BrokerNode, String, String, String, ProduceMessage, QosLevel, long, long) - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageSender

sendOneway(ProduceMessage) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

sendOneway(ProduceMessage, long, TimeUnit) - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerWrapper

SendPrepareResult - org.joyqueue.client.internal.producer.domain中的类

SendPrepareResult author: gaohaoxiang date: 2018/12/10

SendPrepareResult() - 类 的构造器org.joyqueue.client.internal.producer.domain.SendPrepareResult

SendPrepareResult(String, JoyQueueCode) - 类 的构造器org.joyqueue.client.internal.producer.domain.SendPrepareResult

SendResult - org.joyqueue.client.internal.producer.domain中的类

ProduceResult author: gaohaoxiang date: 2018/12/10

SendResult(String, short, long, long) - 类 的构造器org.joyqueue.client.internal.producer.domain.SendResult

SendResultAdapter - io.openmessaging.joyqueue.producer.support中的类

SendResultAdapter author: gaohaoxiang date: 2019/2/19

SendResultAdapter(SendResult) - 类 的构造器io.openmessaging.joyqueue.producer.support.SendResultAdapter

SendResultConverter - io.openmessaging.joyqueue.producer.support中的类

SendResultConverter author: gaohaoxiang date: 2019/2/20

SendResultConverter() - 类 的构造器io.openmessaging.joyqueue.producer.support.SendResultConverter

SendResultData - org.joyqueue.client.internal.producer.domain中的类

SendResultData author: gaohaoxiang date: 2018/12/20

SendResultData() - 类 的构造器org.joyqueue.client.internal.producer.domain.SendResultData

serializeBody(ProduceMessage) - 类 中的静态方法org.joyqueue.client.internal.producer.converter.ProduceMessageConverter

SESSION_TIMEOUT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

setAckTimeout(long) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setAddress(String) - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

setApp(String) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setApp(String) - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

setApp(String) - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

setApp(String) - 类 中的方法org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfig

setAssignments(List<BrokerAssignment>) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignments

setAttributes(Map<String, String>) - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

setBatch(boolean) - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

setBatch(boolean) - 类 中的方法org.joyqueue.client.internal.producer.config.SenderConfig

setBatchBodyLengthLimit(int) - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

setBatchSize(int) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setBody(String) - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

setBodyBytes(byte[]) - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

setBodyLengthLimit(int) - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

setBornHost(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

setBornHost(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

setBornTimestamp(long) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

setBornTimestamp(long) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

setBroadcastGroup(String) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setBroadcastIndexExpireTime(int) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setBroadcastLocalPath(String) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setBroadcastPersistInterval(int) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setBroker(BrokerNode) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignment

setBrokerAssignments(BrokerAssignments) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignmentsHolder

setBusinessId(String) - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

setBusinessIdLengthLimit(int) - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

setCallbackThreads(int) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setChannelMaxIdleTime(int) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setCode(JoyQueueCode) - 类 中的方法org.joyqueue.client.internal.consumer.domain.FetchIndexData

setCode(JoyQueueCode) - 类 中的方法org.joyqueue.client.internal.consumer.domain.FetchMessageData

setCode(JoyQueueCode) - 类 中的方法org.joyqueue.client.internal.producer.domain.FetchFeedbackData

setCode(JoyQueueCode) - 类 中的方法org.joyqueue.client.internal.producer.domain.SendBatchResultData

setCode(JoyQueueCode) - 类 中的方法org.joyqueue.client.internal.producer.domain.SendPrepareResult

setCode(JoyQueueCode) - 类 中的方法org.joyqueue.client.internal.producer.domain.SendResultData

setCompress(boolean) - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

setCompress(boolean) - 类 中的方法org.joyqueue.client.internal.producer.config.SenderConfig

setCompression(short) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

setCompression(short) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

setCompressThreshold(int) - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

setCompressThreshold(int) - 类 中的方法org.joyqueue.client.internal.producer.config.SenderConfig

setCompressType(String) - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

setCompressType(String) - 类 中的方法org.joyqueue.client.internal.producer.config.SenderConfig

setConnectionId(String) - 类 中的方法org.joyqueue.client.internal.transport.ClientConnectionInfo

setConnections(int) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setCorrelationId(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

setCorrelationId(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

setCreateTime(long) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignmentsHolder

setCreateTime(long) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.PartitionAssignmentHolder

setCreateTime(long) - 类 中的方法org.joyqueue.client.internal.consumer.domain.LocalIndexData

setData(byte[]) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageAdapter

setData(byte[]) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageAdapter

setData(List<FeedbackData>) - 类 中的方法org.joyqueue.client.internal.producer.domain.FetchFeedbackData

setDelayTime(long) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

setDelayTime(long) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

setDeliveryCount(int) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

setDeliveryCount(int) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

setDestination(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

setDestination(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

setDurability(short) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

setDurability(short) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

setEnable(boolean) - 枚举 中的方法org.joyqueue.client.internal.trace.TraceType

setExpireTime(long) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

setExpireTime(long) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

setFailover(boolean) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setFailover(boolean) - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

setFetchInterval(int) - 类 中的方法org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfig

setFetchSize(int) - 类 中的方法org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfig

setFlag(short) - 接口 中的方法io.openmessaging.joyqueue.producer.message.ExtensionHeader

setFlag(short) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

setFlag(short) - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

setGroup(String) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setHeartbeatInterval(int) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setHeartbeatMaxIdleTime(int) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setHeartbeatTimeout(int) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setIdleInterval(long) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setIndex(long) - 类 中的方法io.openmessaging.joyqueue.consumer.ConsumerIndex

setIndex(long) - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeReply

setIndex(long) - 类 中的方法org.joyqueue.client.internal.consumer.domain.FetchIndexData

setIndex(long) - 类 中的方法org.joyqueue.client.internal.consumer.domain.LocalIndexData

setInterval(long) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setIoThreads(int) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setKeepAlive(boolean) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setLeftIndex(long) - 类 中的方法io.openmessaging.joyqueue.consumer.ConsumerIndex

setLeftIndex(long) - 类 中的方法org.joyqueue.client.internal.consumer.domain.FetchIndexData

setLoadBalance(boolean) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setLoadBalanceType(String) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setLongPollTimeout(long) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setLongPollTimeout(long) - 类 中的方法org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfig

setMaxAsync(int) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setMaxOneway(int) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setMessageId(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

setMessageId(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

setMessageKey(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

setMessageKey(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

setMessages(List<ConsumeMessage>) - 类 中的方法org.joyqueue.client.internal.consumer.domain.FetchMessageData

setNamespace(String) - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

setNonBlockOneway(boolean) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setOffset(long) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

setOffset(long) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

setOmsMessage(Message) - 类 中的方法io.openmessaging.joyqueue.producer.message.OMSProduceMessage

setPartition(int) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

setPartition(int) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

setPartition(short) - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeReply

setPartition(short) - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

setPartitionAssignment(PartitionAssignment) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignment

setPartitionAssignment(PartitionAssignment) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.PartitionAssignmentHolder

setPartitionKey(String) - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

setPartitions(List<Short>) - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.PartitionAssignment

setPartitions(List<ProduceMessage>, short) - 类 中的静态方法org.joyqueue.client.internal.producer.helper.ProducerHelper

setPollTimeout(long) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setPriority(short) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageHeaderAdapter

setPriority(short) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageHeaderAdapter

setPriority(byte) - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

setProduceTimeout(long) - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

setQosLevel(QosLevel) - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

setRegion(String) - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

setResult(List<SendResult>) - 类 中的方法org.joyqueue.client.internal.producer.domain.SendBatchResultData

setResult(SendResult) - 类 中的方法org.joyqueue.client.internal.producer.domain.SendResultData

setRetryPolicy(RetryPolicy) - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

setRetryPolicy(RetryPolicy) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setRetryType(RetryType) - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeReply

setRightIndex(long) - 类 中的方法io.openmessaging.joyqueue.consumer.ConsumerIndex

setRightIndex(long) - 类 中的方法org.joyqueue.client.internal.consumer.domain.FetchIndexData

setSelectorType(String) - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

setSendTimeout(int) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setSessionTimeout(long) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setSocketBufferSize(int) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setSoLinger(int) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setSoTimeout(int) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setStoreHost(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

setStoreHost(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

setStoreTimestamp(long) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

setStoreTimestamp(long) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

setStringData(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageAdapter

setStringData(String) - 接口 中的方法io.openmessaging.joyqueue.message.ExtensionMessage

setStringData(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageAdapter

setTcpNoDelay(boolean) - 类 中的方法org.joyqueue.client.internal.transport.config.TransportConfig

setTempMetadataInterval(int) - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

setThread(int) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setThrowable(Throwable) - 类 中的方法io.openmessaging.joyqueue.producer.support.FutureAdapter

setTimeout(long) - 类 中的方法org.joyqueue.client.internal.consumer.config.ConsumerConfig

setTimeout(long) - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

setTimeout(long) - 类 中的方法org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfig

setToken(String) - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

setTopic(String) - 类 中的方法org.joyqueue.client.internal.producer.domain.FeedbackData

setTopic(String) - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

setTopicMetadata(Map<String, TopicMetadata>, String) - 类 中的方法org.joyqueue.client.internal.cluster.MetadataCacheManager

setTraceId(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

setTraceId(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

setTransactionCallback(String, TxFeedbackCallback) - 接口 中的方法org.joyqueue.client.internal.MessageAccessPoint

setTransactionCallback(String, TxFeedbackConfig, TxFeedbackCallback) - 接口 中的方法org.joyqueue.client.internal.MessageAccessPoint

setTransactionCallback(String, TxFeedbackCallback) - 类 中的方法org.joyqueue.client.internal.producer.feedback.DefaultTxFeedbackManager

setTransactionCallback(String, TxFeedbackCallback) - 类 中的方法org.joyqueue.client.internal.producer.feedback.TxFeedbackManagerWrapper

setTransactionCallback(String, TxFeedbackCallback) - 接口 中的方法org.joyqueue.client.internal.producer.TxFeedbackManager

setTransactionCallback(String, TxFeedbackCallback) - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

setTransactionCallback(String, TxFeedbackConfig, TxFeedbackCallback) - 类 中的方法org.joyqueue.client.internal.support.DefaultMessageAccessPoint

setTransactionId(String) - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

setTransactionId(String) - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

setTransactionId(String) - 类 中的方法org.joyqueue.client.internal.producer.domain.FeedbackData

setTransactionTimeout(long) - 类 中的方法org.joyqueue.client.internal.producer.config.ProducerConfig

setTxId(String) - 类 中的方法org.joyqueue.client.internal.producer.domain.FeedbackData

setTxId(String) - 类 中的方法org.joyqueue.client.internal.producer.domain.SendPrepareResult

setUpdateMetadataInterval(int) - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

setUpdateMetadataQueueSize(int) - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

setUpdateMetadataThread(int) - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

setUpdateTime(long) - 类 中的方法org.joyqueue.client.internal.consumer.domain.LocalIndexData

setValue(Object) - 类 中的方法io.openmessaging.joyqueue.producer.support.FutureAdapter

SnappyCompressor - org.joyqueue.client.internal.common.compress.support中的类

SnappyCompressor author: gaohaoxiang date: 2019/4/2

SnappyCompressor() - 类 的构造器org.joyqueue.client.internal.common.compress.support.SnappyCompressor

SO_LINGER - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

SO_TIMEOUT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

SOCKET_BUFFER_SIZE - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

sort(List<T>) - 类 中的静态方法org.joyqueue.client.internal.common.ordered.OrderedSorter

start() - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

start() - 类 中的方法io.openmessaging.joyqueue.support.AbstractServiceLifecycle

start() - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

start() - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

startConsumer() - 类 中的方法io.openmessaging.joyqueue.support.MessageAccessPointHolder

startProducer() - 类 中的方法io.openmessaging.joyqueue.support.MessageAccessPointHolder

startTime(long) - 类 中的方法org.joyqueue.client.internal.trace.TraceBuilder

stop() - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

stop() - 类 中的方法io.openmessaging.joyqueue.support.AbstractServiceLifecycle

stop() - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

stop() - 类 中的方法io.openmessaging.joyqueue.support.ProducerWrapper

stopConsumer() - 类 中的方法io.openmessaging.joyqueue.support.MessageAccessPointHolder

stopProducer() - 类 中的方法io.openmessaging.joyqueue.support.MessageAccessPointHolder

subscribe(String) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

subscribe(String, MessageListener) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

subscribe(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

subscribe(String, MessageListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

subscribe(String) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

subscribe(String, MessageListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

subscribeBatch(String, BatchMessageListener) - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

subscribeBatch(String, BatchMessageListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

subscribeBatch(String, BatchMessageListener) - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

subscription() - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

subscription() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

subscription() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

success(MessageReceipt...) - 类 中的方法io.openmessaging.joyqueue.consumer.support.BatchMessageListenerContextAdapter

suspend() - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

suspend(long) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

suspend() - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

suspend(long) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

suspend() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumer

suspend() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumerScheduler

suspendListen() - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

suspendListen() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

suspendListen() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

sync(Command, long) - 类 中的方法org.joyqueue.client.internal.transport.Client

sync(Command) - 类 中的方法org.joyqueue.client.internal.transport.Client

T

TCP_NO_DELAY - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTransportBuiltinKeys

THREAD - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

throwCheckException(String) - 类 中的静态方法org.joyqueue.client.internal.producer.checker.ProduceMessageChecker

TIMEOUT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueConsumerBuiltinKeys

TIMEOUT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys

TIMEOUT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueTxFeedbackBuiltinKeys

topic(String) - 类 中的方法org.joyqueue.client.internal.trace.TraceBuilder

TopicAndApp - org.joyqueue.client.internal.cluster中的类

TopicAndApp() - 类 的构造器org.joyqueue.client.internal.cluster.TopicAndApp

TopicAndApp(String, String) - 类 的构造器org.joyqueue.client.internal.cluster.TopicAndApp

TopicAndApp(List<String>, String) - 类 的构造器org.joyqueue.client.internal.cluster.TopicAndApp

TopicMessageConsumer - org.joyqueue.client.internal.consumer.support中的类

TopicMessageConsumerGroup author: gaohaoxiang date: 2018/12/25

TopicMessageConsumer(String, ConsumerConfig, NameServerConfig, ClusterManager, ClusterClientManager, ConsumerClientManager) - 类 的构造器org.joyqueue.client.internal.consumer.support.TopicMessageConsumer

TopicMessageConsumer(String, ConsumerConfig, NameServerConfig, ClusterManager, ClusterClientManager, ConsumerClientManager, ConsumerInterceptorManager) - 类 的构造器org.joyqueue.client.internal.consumer.support.TopicMessageConsumer

TopicMessageConsumerDispatcher - org.joyqueue.client.internal.consumer.support中的类

TopicMessageConsumerDispatcher author: gaohaoxiang date: 2018/12/25

TopicMessageConsumerDispatcher(String, ConsumerConfig, NameServerConfig, MessagePoller, MessageListenerManager, ConsumerInterceptorManager) - 类 的构造器org.joyqueue.client.internal.consumer.support.TopicMessageConsumerDispatcher

TopicMessageConsumerScheduler - org.joyqueue.client.internal.consumer.support中的类

TopicMessageConsumerScheduler author: gaohaoxiang date: 2018/12/25

TopicMessageConsumerScheduler(String, ConsumerConfig, MessagePoller, TopicMessageConsumerDispatcher) - 类 的构造器org.joyqueue.client.internal.consumer.support.TopicMessageConsumerScheduler

TopicMetadata - org.joyqueue.client.internal.metadata.domain中的类

TopicMetadata author: gaohaoxiang date: 2018/12/3

TopicMetadata() - 类 的构造器org.joyqueue.client.internal.metadata.domain.TopicMetadata

TopicMetadata(JoyQueueCode) - 类 的构造器org.joyqueue.client.internal.metadata.domain.TopicMetadata

TopicMetadata(String, ProducerPolicy, ConsumerPolicy, TopicType, List<PartitionGroupMetadata>, List<PartitionMetadata>, Map<Short, PartitionMetadata>, Map<Integer, PartitionGroupMetadata>, List<BrokerNode>, List<BrokerNode>, Map<Integer, BrokerNode>, Map<Integer, List<PartitionMetadata>>, Map<Integer, List<PartitionGroupMetadata>>, boolean, JoyQueueCode) - 类 的构造器org.joyqueue.client.internal.metadata.domain.TopicMetadata

TopicMetadataConverter - io.openmessaging.joyqueue.extension中的类

TopicMetadataConverter author: gaohaoxiang date: 2019/3/1

TopicMetadataConverter() - 类 的构造器io.openmessaging.joyqueue.extension.TopicMetadataConverter

TopicMetadataConverter - org.joyqueue.client.internal.consumer.converter中的类

TopicMetadataConverter author: gaohaoxiang date: 2018/12/7

TopicMetadataConverter() - 类 的构造器org.joyqueue.client.internal.consumer.converter.TopicMetadataConverter

TopicMetadataHolder - org.joyqueue.client.internal.cluster.domain中的类

TopicMetadataHolder author: gaohaoxiang date: 2018/12/3

TopicMetadataHolder(String, TopicMetadata, long, long, JoyQueueCode) - 类 的构造器org.joyqueue.client.internal.cluster.domain.TopicMetadataHolder

toString() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageAdapter

toString() - 类 中的方法io.openmessaging.joyqueue.consumer.message.MessageExtensionHeaderAdapter

toString() - 类 中的方法io.openmessaging.joyqueue.consumer.support.BatchMessageListenerAdapter

toString() - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerInterceptorAdapter

toString() - 类 中的方法io.openmessaging.joyqueue.consumer.support.MessageListenerAdapter

toString() - 类 中的方法io.openmessaging.joyqueue.extension.QueueMetaDataAdapter

toString() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageAdapter

toString() - 类 中的方法io.openmessaging.joyqueue.producer.message.MessageExtensionHeaderAdapter

toString() - 类 中的方法io.openmessaging.joyqueue.producer.support.ProducerInterceptorAdapter

toString() - 类 中的方法io.openmessaging.joyqueue.producer.support.SendResultAdapter

toString() - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignment

toString() - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.BrokerAssignments

toString() - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.domain.PartitionAssignment

toString() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeMessage

toString() - 类 中的方法org.joyqueue.client.internal.consumer.domain.ConsumeReply

toString() - 类 中的方法org.joyqueue.client.internal.metadata.domain.PartitionGroupMetadata

toString() - 类 中的方法org.joyqueue.client.internal.metadata.domain.PartitionMetadata

toString() - 类 中的方法org.joyqueue.client.internal.metadata.domain.TopicMetadata

toString() - 类 中的方法org.joyqueue.client.internal.nameserver.NameServerConfig

toString() - 类 中的方法org.joyqueue.client.internal.producer.domain.ProduceMessage

toString() - 类 中的方法org.joyqueue.client.internal.producer.domain.SendResult

toString() - 类 中的方法org.joyqueue.client.internal.transport.ClientConnectionInfo

TRACE - 接口 中的静态变量org.joyqueue.client.internal.Plugins

trace 插件

Trace - org.joyqueue.client.internal.trace中的接口

Trace author: gaohaoxiang date: 2019/1/3

TraceBuilder - org.joyqueue.client.internal.trace中的类

TraceBuilder author: gaohaoxiang date: 2019/1/3

TraceBuilder() - 类 的构造器org.joyqueue.client.internal.trace.TraceBuilder

TraceCaller - org.joyqueue.client.internal.trace中的接口

TraceCaller author: gaohaoxiang date: 2019/1/3

TraceConsumerInterceptor - org.joyqueue.client.internal.trace.interceptor中的类

TraceConsumerInterceptor author: gaohaoxiang date: 2019/1/11

TraceConsumerInterceptor() - 类 的构造器org.joyqueue.client.internal.trace.interceptor.TraceConsumerInterceptor

TraceContext - org.joyqueue.client.internal.trace中的类

TraceContext author: gaohaoxiang date: 2019/1/3

TraceContext(String, String, String, TraceType) - 类 的构造器org.joyqueue.client.internal.trace.TraceContext

TraceContext(String, String, String, TraceType, long) - 类 的构造器org.joyqueue.client.internal.trace.TraceContext

TraceManager - org.joyqueue.client.internal.trace中的类

TraceManager author: gaohaoxiang date: 2019/1/3

TraceManager() - 类 的构造器org.joyqueue.client.internal.trace.TraceManager

TraceProducerInterceptor - org.joyqueue.client.internal.trace.interceptor中的类

TraceProducerInterceptor author: gaohaoxiang date: 2019/1/11

TraceProducerInterceptor() - 类 的构造器org.joyqueue.client.internal.trace.interceptor.TraceProducerInterceptor

TraceType - org.joyqueue.client.internal.trace中的枚举

TraceType author: gaohaoxiang date: 2019/1/3

TraceWrapper - org.joyqueue.client.internal.trace.support中的类

TraceWrapper author: gaohaoxiang date: 2019/1/3

TraceWrapper() - 类 的构造器org.joyqueue.client.internal.trace.support.TraceWrapper

TRANSACTION_TIMEOUT - 接口 中的静态变量io.openmessaging.joyqueue.domain.JoyQueueProducerBuiltinKeys

TransactionalContextAdapter - io.openmessaging.joyqueue.producer.support中的类

TransactionalContextAdapter author: gaohaoxiang date: 2019/2/19

TransactionalContextAdapter() - 类 的构造器io.openmessaging.joyqueue.producer.support.TransactionalContextAdapter

TransactionalResultAdapter - io.openmessaging.joyqueue.producer.support中的类

TransactionalResultAdapter author: gaohaoxiang date: 2019/2/19

TransactionalResultAdapter(Message, String, MessageProducer) - 类 的构造器io.openmessaging.joyqueue.producer.support.TransactionalResultAdapter

transactionId() - 接口 中的方法io.openmessaging.joyqueue.producer.ExtensionTransactionalResult

transactionId() - 类 中的方法io.openmessaging.joyqueue.producer.support.ExtensionTransactionalResultAdapter

transactionId() - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionalResultAdapter

TransactionMessageProducer - org.joyqueue.client.internal.producer中的接口

TransactionMessageProducer author: gaohaoxiang date: 2018/12/10

TransactionProducerImpl - io.openmessaging.joyqueue.producer.support中的类

TransactionProducerImpl author: gaohaoxiang date: 2019/2/22

TransactionProducerImpl(ExtensionProducer, TransactionStateCheckListener, MessageProducer, MessageAccessPoint, TxFeedbackConfig) - 类 的构造器io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

TransactionStateCheckListenerAdapter - io.openmessaging.joyqueue.producer.support中的类

TransactionStateCheckListenerAdapter author: gaohaoxiang date: 2019/2/19

TransactionStateCheckListenerAdapter(TransactionStateCheckListener) - 类 的构造器io.openmessaging.joyqueue.producer.support.TransactionStateCheckListenerAdapter

TransactionStatus - org.joyqueue.client.internal.producer.domain中的枚举

TransactionStatus author: gaohaoxiang date: 2018/12/10

TransportConfig - org.joyqueue.client.internal.transport.config中的类

TransportConfig author: gaohaoxiang date: 2018/11/28

TransportConfig() - 类 的构造器org.joyqueue.client.internal.transport.config.TransportConfig

TransportConfigChecker - org.joyqueue.client.internal.transport.config中的类

TransportConfigChecker author: gaohaoxiang date: 2019/2/19

TransportConfigChecker() - 类 的构造器org.joyqueue.client.internal.transport.config.TransportConfigChecker

tryGetClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClientManager

tryGetClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClientManager

tryGetClient() - 类 中的方法org.joyqueue.client.internal.transport.ClientGroup

tryGetClient(BrokerNode) - 类 中的方法org.joyqueue.client.internal.transport.ClientManager

tryGetClientGroup(BrokerNode) - 类 中的方法org.joyqueue.client.internal.transport.ClientGroupManager

tryUpdateTopicMetadata(String, String) - 类 中的方法org.joyqueue.client.internal.cluster.ClusterManager

tryUpdateTopicMetadata(String, String) - 类 中的方法org.joyqueue.client.internal.cluster.MetadataUpdater

tryUpdateTopicMetadata(List<String>, String) - 类 中的方法org.joyqueue.client.internal.cluster.MetadataUpdater

TxFeedbackCallback - org.joyqueue.client.internal.producer.callback中的接口

TxFeedbackCallback author: gaohaoxiang date: 2018/12/10

TxFeedbackConfig - org.joyqueue.client.internal.producer.feedback.config中的类

TxFeedbackConfig author: gaohaoxiang date: 2019/1/3

TxFeedbackConfig() - 类 的构造器org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfig

TxFeedbackConfigChecker - org.joyqueue.client.internal.producer.feedback.config中的类

TxFeedbackConfigChecker author: gaohaoxiang date: 2019/2/19

TxFeedbackConfigChecker() - 类 的构造器org.joyqueue.client.internal.producer.feedback.config.TxFeedbackConfigChecker

TxFeedbackDispatcher - org.joyqueue.client.internal.producer.feedback中的类

TxFeedbackDispatcher author: gaohaoxiang date: 2018/12/24

TxFeedbackDispatcher(TxFeedbackConfig, String, TxFeedbackCallback, MessageSender, ClusterManager) - 类 的构造器org.joyqueue.client.internal.producer.feedback.TxFeedbackDispatcher

TxFeedbackManager - org.joyqueue.client.internal.producer中的接口

TxFeedbackManager author: gaohaoxiang date: 2019/1/3

TxFeedbackManagerFactory - org.joyqueue.client.internal.producer中的类

TxFeedbackManagerFactory author: gaohaoxiang date: 2019/1/3

TxFeedbackManagerFactory() - 类 的构造器org.joyqueue.client.internal.producer.TxFeedbackManagerFactory

TxFeedbackManagerWrapper - org.joyqueue.client.internal.producer.feedback中的类

TxFeedbackManagerWrapper author: gaohaoxiang date: 2019/1/3

TxFeedbackManagerWrapper(ClusterManager, ProducerClientManager, MessageSender, TxFeedbackManager) - 类 的构造器org.joyqueue.client.internal.producer.feedback.TxFeedbackManagerWrapper

TxFeedbackScheduler - org.joyqueue.client.internal.producer.feedback中的类

TxFeedbackScheduler author: gaohaoxiang date: 2018/12/24

TxFeedbackScheduler(TxFeedbackConfig, String, TxFeedbackCallback, MessageSender, ClusterManager) - 类 的构造器org.joyqueue.client.internal.producer.feedback.TxFeedbackScheduler

type() - 类 中的方法org.joyqueue.client.internal.common.compress.support.SnappyCompressor

type() - 类 中的方法org.joyqueue.client.internal.common.compress.support.ZlibCompressor

type() - 类 中的方法org.joyqueue.client.internal.consumer.support.RandomBrokerLoadBalance

type() - 类 中的方法org.joyqueue.client.internal.consumer.support.RoundRobinBrokerLoadBalance

type() - 类 中的方法org.joyqueue.client.internal.producer.support.WeightedRoundRobinPartitionSelector

type() - 类 中的方法org.joyqueue.client.internal.trace.support.CompositeTrace

type() - 类 中的方法org.joyqueue.client.internal.trace.support.NoneTrace

type() - 类 中的方法org.joyqueue.client.internal.trace.support.TraceWrapper

type(TraceType) - 类 中的方法org.joyqueue.client.internal.trace.TraceBuilder

U

unbindQueue(String) - 类 中的方法io.openmessaging.joyqueue.consumer.support.ConsumerImpl

unbindQueue(String) - 类 中的方法io.openmessaging.joyqueue.support.ConsumerWrapper

unknown() - 类 中的方法io.openmessaging.joyqueue.producer.support.TransactionalContextAdapter

UnmodifiableTopicMetadata - org.joyqueue.client.internal.metadata.domain中的类

已过时。

UnmodifiableTopicMetadata(String, ProducerPolicy, ConsumerPolicy, TopicType, List<PartitionGroupMetadata>, List<PartitionMetadata>, Map<Short, PartitionMetadata>, Map<Integer, PartitionGroupMetadata>, List<BrokerNode>, List<BrokerNode>, Map<Integer, BrokerNode>, Map<Integer, List<PartitionMetadata>>, Map<Integer, List<PartitionGroupMetadata>>, boolean, JoyQueueCode) - 类 的构造器org.joyqueue.client.internal.metadata.domain.UnmodifiableTopicMetadata

已过时。

unsubscribe() - 接口 中的方法org.joyqueue.client.internal.consumer.MessageConsumer

unsubscribe() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessageConsumer

unsubscribe() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessageConsumerWrapper

updateTopicMetadata(String, String) - 类 中的方法org.joyqueue.client.internal.cluster.ClusterManager

updateTopicMetadata(String, String) - 类 中的方法org.joyqueue.client.internal.cluster.MetadataUpdater

updateTopicMetadata(List<String>, String) - 类 中的方法org.joyqueue.client.internal.cluster.MetadataUpdater

updateUseTime() - 类 中的方法org.joyqueue.client.internal.transport.ClientConnectionState

V

validate() - 类 中的方法org.joyqueue.client.internal.cluster.ClusterClientManager

validate() - 类 中的方法org.joyqueue.client.internal.cluster.ClusterManager

validate() - 类 中的方法org.joyqueue.client.internal.cluster.MetadataUpdater

validate() - 类 中的方法org.joyqueue.client.internal.consumer.coordinator.ConsumerCoordinator

validate() - 类 中的方法org.joyqueue.client.internal.consumer.support.BroadcastMessagePoller

validate() - 类 中的方法org.joyqueue.client.internal.consumer.support.ConsumerLocalIndexStore

validate() - 类 中的方法org.joyqueue.client.internal.consumer.support.DefaultMessagePoller

validate() - 类 中的方法org.joyqueue.client.internal.consumer.support.LocalConsumerIndexManager

validate() - 类 中的方法org.joyqueue.client.internal.consumer.support.MessagePollerInner

validate() - 类 中的方法org.joyqueue.client.internal.consumer.support.PartitionMessagePoller

validate() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumer

validate() - 类 中的方法org.joyqueue.client.internal.consumer.support.TopicMessageConsumerScheduler

validate() - 类 中的方法org.joyqueue.client.internal.consumer.transport.ConsumerClientManager

validate() - 类 中的方法org.joyqueue.client.internal.producer.feedback.TxFeedbackScheduler

validate() - 类 中的方法org.joyqueue.client.internal.producer.support.DefaultMessageProducer

validate() - 类 中的方法org.joyqueue.client.internal.producer.support.MessageProducerInner

validate() - 类 中的方法org.joyqueue.client.internal.producer.transport.ProducerClientManager

validate() - 类 中的方法org.joyqueue.client.internal.transport.ClientGroupManager

validate() - 类 中的方法org.joyqueue.client.internal.transport.ClientManager

valueOf(String) - 枚举 中的静态方法org.joyqueue.client.internal.producer.domain.TransactionStatus

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法org.joyqueue.client.internal.trace.TraceType

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法org.joyqueue.client.internal.transport.ClientState

返回带有指定名称的该类型的枚举常量。

values() - 枚举 中的静态方法org.joyqueue.client.internal.producer.domain.TransactionStatus

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法org.joyqueue.client.internal.trace.TraceType

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法org.joyqueue.client.internal.transport.ClientState

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

VERSION - 类 中的静态变量io.openmessaging.joyqueue.JoyQueueOMSConsts

version() - 类 中的方法io.openmessaging.joyqueue.MessagingAccessPointImpl

VERSION - 类 中的静态变量org.joyqueue.client.internal.ClientConsts

W

WeightedRoundRobinPartitionSelector - org.joyqueue.client.internal.producer.support中的类

WeightedRoundRobinPartitionSelector author: gaohaoxiang date: 2018/12/27

WeightedRoundRobinPartitionSelector() - 类 的构造器org.joyqueue.client.internal.producer.support.WeightedRoundRobinPartitionSelector

Z

ZlibCompressor - org.joyqueue.client.internal.common.compress.support中的类

ZlibCompressor author: gaohaoxiang date: 2019/1/2

ZlibCompressor() - 类 的构造器org.joyqueue.client.internal.common.compress.support.ZlibCompressor

A B C D E F G H I J K L M N O P Q R S T U V W Z