类的使用
org.joyqueue.client.internal.metadata.domain.TopicMetadata

使用TopicMetadata的程序包

程序包	说明
io.openmessaging.joyqueue.consumer.extension
io.openmessaging.joyqueue.extension
io.openmessaging.joyqueue.producer.extension
org.joyqueue.client.internal.cluster
org.joyqueue.client.internal.cluster.domain
org.joyqueue.client.internal.consumer
org.joyqueue.client.internal.consumer.converter
org.joyqueue.client.internal.consumer.coordinator
org.joyqueue.client.internal.consumer.support
org.joyqueue.client.internal.metadata
org.joyqueue.client.internal.metadata.converter
org.joyqueue.client.internal.metadata.domain
org.joyqueue.client.internal.producer
org.joyqueue.client.internal.producer.feedback
org.joyqueue.client.internal.producer.helper
org.joyqueue.client.internal.producer.interceptor
org.joyqueue.client.internal.producer.support

io.openmessaging.joyqueue.consumer.extension中TopicMetadata的使用

返回TopicMetadata的io.openmessaging.joyqueue.consumer.extension中的方法

限定符和类型	方法和说明
protected TopicMetadata	ExtensionAdapter.getTopicMetadata(String queueName)

io.openmessaging.joyqueue.extension中TopicMetadata的使用

返回TopicMetadata的io.openmessaging.joyqueue.extension中的方法

限定符和类型	方法和说明
TopicMetadata	QueueMetaDataAdapter.getTopicMetadata()
protected abstract TopicMetadata	AbstractExtensionAdapter.getTopicMetadata(String queueName)

参数类型为TopicMetadata的io.openmessaging.joyqueue.extension中的方法

限定符和类型	方法和说明
static io.openmessaging.extension.QueueMetaData	TopicMetadataConverter.convert(TopicMetadata topicMetadata)

参数类型为TopicMetadata的io.openmessaging.joyqueue.extension中的构造器

构造器和说明
QueueMetaDataAdapter(TopicMetadata topicMetadata)

io.openmessaging.joyqueue.producer.extension中TopicMetadata的使用

返回TopicMetadata的io.openmessaging.joyqueue.producer.extension中的方法

限定符和类型	方法和说明
protected TopicMetadata	ExtensionAdapter.getTopicMetadata(String queueName)

org.joyqueue.client.internal.cluster中TopicMetadata的使用

返回TopicMetadata的org.joyqueue.client.internal.cluster中的方法

限定符和类型	方法和说明
TopicMetadata	ClusterManager.fetchTopicMetadata(String topic, String app)
TopicMetadata	ClusterManager.forceUpdateTopicMetadata(String topic, String app)
TopicMetadata	MetadataUpdater.updateTopicMetadata(String topic, String app)
TopicMetadata	ClusterManager.updateTopicMetadata(String topic, String app)

返回变量类型为TopicMetadata的类型的org.joyqueue.client.internal.cluster中的方法

限定符和类型	方法和说明
Map<String,TopicMetadata>	ClusterManager.fetchTopicMetadata(List<String> topics, String app)
List<TopicMetadata>	ClusterManager.fetchTopicMetadataList(List<String> topics, String app)
Map<String,TopicMetadata>	ClusterManager.forceUpdateTopicMetadata(List<String> topics, String app)
Map<String,TopicMetadata>	MetadataUpdater.updateTopicMetadata(List<String> topics, String app)

参数类型为TopicMetadata的org.joyqueue.client.internal.cluster中的方法

限定符和类型	方法和说明
protected TopicMetadataHolder	MetadataCacheManager.newTopicMetadataHolder(String topic, TopicMetadata topicMetadata)
void	MetadataCacheManager.putTopicMetadata(String topic, String app, TopicMetadata topicMetadata)

类型变量类型为TopicMetadata的org.joyqueue.client.internal.cluster中的方法参数

限定符和类型	方法和说明
void	MetadataCacheManager.putTopicMetadata(Map<String,TopicMetadata> topicMetadata, String app)
void	MetadataCacheManager.setTopicMetadata(Map<String,TopicMetadata> topicMetadata, String app)

org.joyqueue.client.internal.cluster.domain中TopicMetadata的使用

返回TopicMetadata的org.joyqueue.client.internal.cluster.domain中的方法

限定符和类型	方法和说明
TopicMetadata	TopicMetadataHolder.getTopicMetadata()

参数类型为TopicMetadata的org.joyqueue.client.internal.cluster.domain中的构造器

构造器和说明
TopicMetadataHolder(String topic, TopicMetadata topicMetadata, long createTime, long expireTime, org.joyqueue.exception.JoyQueueCode code)

org.joyqueue.client.internal.consumer中TopicMetadata的使用

返回TopicMetadata的org.joyqueue.client.internal.consumer中的方法

限定符和类型	方法和说明
TopicMetadata	MessagePoller.getTopicMetadata(String topic)
TopicMetadata	MessageConsumer.getTopicMetadata(String topic)

org.joyqueue.client.internal.consumer.converter中TopicMetadata的使用

返回变量类型为TopicMetadata的类型的org.joyqueue.client.internal.consumer.converter中的方法

限定符和类型	方法和说明
static Map<String,TopicMetadata>	TopicMetadataConverter.convertToMap(List<TopicMetadata> topicMetadatas)

参数类型为TopicMetadata的org.joyqueue.client.internal.consumer.converter中的方法

限定符和类型	方法和说明
static BrokerAssignments	BrokerAssignmentConverter.convertBrokerAssignments(TopicMetadata topicMetadata)
static BrokerAssignments	BrokerAssignmentConverter.convertTopicAssignments(TopicMetadata topicMetadata)

类型变量类型为TopicMetadata的org.joyqueue.client.internal.consumer.converter中的方法参数

限定符和类型	方法和说明
static List<String>	TopicMetadataConverter.convertToCodeList(List<TopicMetadata> topicMetadatas)
static Map<String,TopicMetadata>	TopicMetadataConverter.convertToMap(List<TopicMetadata> topicMetadatas)

org.joyqueue.client.internal.consumer.coordinator中TopicMetadata的使用

参数类型为TopicMetadata的org.joyqueue.client.internal.consumer.coordinator中的方法

限定符和类型	方法和说明
protected BrokerAssignments	ConsumerCoordinator.buildAllBrokerAssignments(TopicMetadata topicMetadata)
BrokerAssignments	ConsumerCoordinator.fetchAllBrokerAssignments(TopicMetadata topicMetadata, String app)
BrokerAssignments	PartitionAssignmentManager.fetchBrokerAssignment(TopicMetadata topicMetadata, String app, long sessionTimeout)
BrokerAssignments	ConsumerCoordinator.fetchBrokerAssignment(TopicMetadata topicMetadata, String app, long sessionTimeout)
PartitionAssignment	PartitionAssignmentManager.fetchPartitionAssignment(TopicMetadata topicMetadata, String app, long sessionTimeout)

org.joyqueue.client.internal.consumer.support中TopicMetadata的使用

返回TopicMetadata的org.joyqueue.client.internal.consumer.support中的方法

限定符和类型	方法和说明
TopicMetadata	MessagePollerInner.getAndCheckTopicMetadata(String topic)
TopicMetadata	BroadcastMessagePoller.getTopicMetadata(String topic)
TopicMetadata	DefaultMessagePoller.getTopicMetadata(String topic)
TopicMetadata	MessageConsumerWrapper.getTopicMetadata(String topic)
TopicMetadata	MessagePollerWrapper.getTopicMetadata(String topic)
TopicMetadata	DefaultMessageConsumer.getTopicMetadata(String topic)
TopicMetadata	PartitionMessagePoller.getTopicMetadata(String topic)

参数类型为TopicMetadata的org.joyqueue.client.internal.consumer.support中的方法

限定符和类型	方法和说明
BrokerAssignments	MessagePollerInner.buildAllBrokerAssignments(TopicMetadata topicMetadata)
protected BrokerAssignments	PartitionMessagePoller.buildAllBrokerAssignments(TopicMetadata topicMetadata)
protected TraceCaller	MessagePollerInner.buildTraceCaller(TopicMetadata topicMetadata)
protected List<ConsumeReply>	TopicMessageConsumerDispatcher.doBatchDispatch(TopicMetadata topicMetadata, org.joyqueue.domain.ConsumerPolicy consumerPolicy, List<ConsumeMessage> messages, List<BatchMessageListener> listeners)
protected List<ConsumeReply>	TopicMessageConsumerDispatcher.doDispatch(TopicMetadata topicMetadata, org.joyqueue.domain.ConsumerPolicy consumerPolicy, List<ConsumeMessage> messages)
protected List<ConsumeMessage>	MessagePollerInner.doFetchPartition(BrokerNode brokerNode, TopicMetadata topicMetadata, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	MessagePollerInner.doFetchTopic(BrokerNode brokerNode, TopicMetadata topicMetadata, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeReply>	TopicMessageConsumerDispatcher.doOnceDispatch(TopicMetadata topicMetadata, org.joyqueue.domain.ConsumerPolicy consumerPolicy, List<ConsumeMessage> messages, List<MessageListener> listeners)
protected BrokerAssignments	DefaultMessagePoller.fetchBrokerAssignment(TopicMetadata topicMetadata)
List<ConsumeMessage>	MessagePollerInner.fetchPartition(BrokerNode brokerNode, TopicMetadata topicMetadata, short partition, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	MessagePollerInner.fetchPartition(BrokerNode brokerNode, TopicMetadata topicMetadata, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	MessagePollerInner.fetchTopic(BrokerNode brokerNode, TopicMetadata topicMetadata, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
BrokerAssignments	MessagePollerInner.filterRegionBrokers(TopicMetadata topicMetadata, BrokerAssignments brokerAssignments)

参数类型为TopicMetadata的org.joyqueue.client.internal.consumer.support中的构造器

构造器和说明
BatchConsumerInvoker(ConsumerConfig config, TopicMetadata topicMetadata, org.joyqueue.domain.ConsumerPolicy consumerPolicy, List<ConsumeMessage> messages, List<BatchMessageListener> listeners)
OnceConsumerInvoker(ConsumerConfig config, TopicMetadata topicMetadata, org.joyqueue.domain.ConsumerPolicy consumerPolicy, List<ConsumeMessage> messages, List<MessageListener> listeners)

org.joyqueue.client.internal.metadata中TopicMetadata的使用

返回TopicMetadata的org.joyqueue.client.internal.metadata中的方法

限定符和类型	方法和说明
TopicMetadata	MetadataManager.fetchMetadata(String topic, String app)

org.joyqueue.client.internal.metadata.converter中TopicMetadata的使用

返回TopicMetadata的org.joyqueue.client.internal.metadata.converter中的方法

限定符和类型	方法和说明
static TopicMetadata	ClusterMetadataConverter.convertTopicMetadata(String code, Topic topic, Map<Integer,BrokerNode> brokerMap)

org.joyqueue.client.internal.metadata.domain中TopicMetadata的使用

org.joyqueue.client.internal.metadata.domain中TopicMetadata的子类

限定符和类型	类和说明
class	UnmodifiableTopicMetadata 已过时。

返回TopicMetadata的org.joyqueue.client.internal.metadata.domain中的方法

限定符和类型	方法和说明
TopicMetadata	TopicMetadata.clone() 已过时。
TopicMetadata	ClusterMetadata.getTopic(String code)

返回变量类型为TopicMetadata的类型的org.joyqueue.client.internal.metadata.domain中的方法

限定符和类型	方法和说明
Map<String,TopicMetadata>	ClusterMetadata.getTopics()

类型变量类型为TopicMetadata的org.joyqueue.client.internal.metadata.domain中的构造器参数

构造器和说明
ClusterMetadata(Map<String,TopicMetadata> topics, Map<Integer,BrokerNode> brokers)

org.joyqueue.client.internal.producer中TopicMetadata的使用

返回TopicMetadata的org.joyqueue.client.internal.producer中的方法

限定符和类型	方法和说明
TopicMetadata	MessageProducer.getTopicMetadata(String topic)

参数类型为TopicMetadata的org.joyqueue.client.internal.producer中的方法

限定符和类型	方法和说明
PartitionMetadata	PartitionSelector.select(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)

org.joyqueue.client.internal.producer.feedback中TopicMetadata的使用

返回TopicMetadata的org.joyqueue.client.internal.producer.feedback中的方法

限定符和类型	方法和说明
protected TopicMetadata	DefaultTxFeedbackManager.checkTopicMetadata(String topic)

参数类型为TopicMetadata的org.joyqueue.client.internal.producer.feedback中的方法

限定符和类型	方法和说明
protected void	TxFeedbackDispatcher.doConfirm(BrokerNode brokerNode, TopicMetadata topicMetadata, FeedbackData feedbackData)
protected void	TxFeedbackDispatcher.doFeedback(TopicMetadata topicMetadata, BrokerNode brokerNode)

org.joyqueue.client.internal.producer.helper中TopicMetadata的使用

参数类型为TopicMetadata的org.joyqueue.client.internal.producer.helper中的方法

限定符和类型	方法和说明
static PartitionMetadata	ProducerHelper.dispatchPartitions(List<ProduceMessage> messages, TopicMetadata topicMetadata, List<PartitionMetadata> partitions, PartitionSelector partitionSelector)

org.joyqueue.client.internal.producer.interceptor中TopicMetadata的使用

参数类型为TopicMetadata的org.joyqueue.client.internal.producer.interceptor中的构造器

构造器和说明
ProducerInvocation(ProducerConfig config, NameServerConfig nameServerConfig, TopicMetadata topicMetadata, List<ProduceMessage> messages, ProducerInterceptorManager producerInterceptorManager, ProducerInvoker producerInvoker)

org.joyqueue.client.internal.producer.support中TopicMetadata的使用

返回TopicMetadata的org.joyqueue.client.internal.producer.support中的方法

限定符和类型	方法和说明
TopicMetadata	MessageProducerInner.getAndCheckTopicMetadata(String topic)
TopicMetadata	MessageProducerWrapper.getTopicMetadata(String topic)
TopicMetadata	DefaultMessageProducer.getTopicMetadata(String topic)

参数类型为TopicMetadata的org.joyqueue.client.internal.producer.support中的方法

限定符和类型	方法和说明
PartitionMetadata	MessageProducerInner.dispatchPartitions(List<ProduceMessage> messages, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
PartitionMetadata	MessageProducerInner.dispatchPartitions(List<ProduceMessage> messages, TopicMetadata topicMetadata, List<PartitionMetadata> partitions, List<PartitionMetadata> blackPartitionList)
List<SendResult>	MessageProducerInner.doBatchSend(List<ProduceMessage> messages, TopicMetadata topicMetadata, PartitionMetadata partition, List<PartitionMetadata> partitions, String txId, long timeout, TimeUnit timeoutUnit, boolean isOneway, boolean failover, AsyncBatchProduceCallback callback)
protected List<SendResult>	MessageProducerInner.doBatchSendInternal(List<ProduceMessage> messages, TopicMetadata topicMetadata, PartitionMetadata partition, List<PartitionMetadata> partitions, String txId, long timeout, TimeUnit timeoutUnit, boolean isOneway, boolean failover, AsyncBatchProduceCallback callback)
List<PartitionMetadata>	MessageProducerInner.getBrokerPartitions(TopicMetadata topicMetadata, List<BrokerNode> brokerNodes)
List<BrokerNode>	MessageProducerInner.getRegionBrokers(TopicMetadata topicMetadata)
protected PartitionMetadata	AbstractPartitionSelector.hashPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
protected abstract PartitionMetadata	AbstractPartitionSelector.nextPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
protected PartitionMetadata	WeightedRoundRobinPartitionSelector.nextPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
PartitionMetadata	AbstractPartitionSelector.select(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
protected PartitionMetadata	AbstractPartitionSelector.selectPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)