com.taobao.metamorphosis.client
接口 TopicBrowser

所有超级接口:
Shutdownable
所有已知实现类:
MetaTopicBrowser

public interface TopicBrowser
extends Shutdownable

Allows browsing of messages on a Topic. A client uses a TopicBrowser to look at messages on a topic without consuming them.

从以下版本开始:
1.4.5
作者:
dennis

方法摘要
 List<Partition> getPartitions()
          Returns topic's all alive partitions.
 String getTopic()
          Returns the topic
 Iterator<Message> iterator()
          Returns an iterator to iterate all messages under this topic from all alive brokers.The iteration order is from the smallest broker's smallest partition to the biggest broker's biggest partition.Everytime it returns a new iterator.
 
从接口 com.taobao.metamorphosis.client.Shutdownable 继承的方法
shutdown
 

方法详细信息

iterator

Iterator<Message> iterator()
Returns an iterator to iterate all messages under this topic from all alive brokers.The iteration order is from the smallest broker's smallest partition to the biggest broker's biggest partition.Everytime it returns a new iterator.

返回:

getPartitions

List<Partition> getPartitions()
Returns topic's all alive partitions.

返回:

getTopic

String getTopic()
Returns the topic

返回:


Copyright © 2010–2013. All rights reserved.