com.taobao.metamorphosis.client.consumer
类 SimpleFetchManager

java.lang.Object
  com.taobao.metamorphosis.client.consumer.SimpleFetchManager

所有已实现的接口：

FetchManager

public class SimpleFetchManager
extends Object
implements FetchManager

消息抓取管理器的实现

作者：

boyan(boyan@taobao.com)

字段摘要

static Byte

PROCESSED

构造方法摘要

SimpleFetchManager(ConsumerConfig consumerConfig, InnerConsumer consumer)

方法摘要

void	addFetchRequest(FetchRequest request) 添加fetch请求
static TopicPartitionRegInfo	currentTopicRegInfo() Returns current thread processing message's TopicPartitionRegInfo.
int	getFetchRequestCount() Returns current fetch requests count.
boolean	isShutdown() 是否关闭
void	resetFetchState() 重设状态，重设状态后可重用并start
static void	setMessageIdCache(MessageIdCache newCache) Set new message id cache to prevent duplicated messages for the same consumer group.
void	startFetchRunner() 启动管理器
void	stopFetchRunner() 停止fetch

从类 java.lang.Object 继承的方法

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细信息

PROCESSED

public static final Byte PROCESSED

构造方法详细信息

SimpleFetchManager

public SimpleFetchManager(ConsumerConfig consumerConfig,
                          InnerConsumer consumer)

方法详细信息

setMessageIdCache

public static void setMessageIdCache(MessageIdCache newCache)

Set new message id cache to prevent duplicated messages for the same consumer group.

参数：

newCache -

从以下版本开始：

1.4.6

currentTopicRegInfo

public static TopicPartitionRegInfo currentTopicRegInfo()

Returns current thread processing message's TopicPartitionRegInfo.

返回：

从以下版本开始：

1.4.6

getFetchRequestCount

public int getFetchRequestCount()

从接口 FetchManager 复制的描述

Returns current fetch requests count.

指定者：

接口 FetchManager 中的 getFetchRequestCount

返回：

isShutdown

public boolean isShutdown()

从接口 FetchManager 复制的描述

是否关闭

指定者：

接口 FetchManager 中的 isShutdown

返回：

stopFetchRunner

public void stopFetchRunner()
                     throws InterruptedException

从接口 FetchManager 复制的描述

停止fetch

指定者：

接口 FetchManager 中的 stopFetchRunner

抛出：

InterruptedException

resetFetchState

public void resetFetchState()

从接口 FetchManager 复制的描述

重设状态，重设状态后可重用并start

指定者：

接口 FetchManager 中的 resetFetchState

startFetchRunner

public void startFetchRunner()

从接口 FetchManager 复制的描述

启动管理器

指定者：

接口 FetchManager 中的 startFetchRunner

addFetchRequest

public void addFetchRequest(FetchRequest request)

从接口 FetchManager 复制的描述

添加fetch请求

指定者：

接口 FetchManager 中的 addFetchRequest