com.taobao.metamorphosis.client.consumer
接口 FetchManager

所有已知实现类:
SimpleFetchManager

public interface FetchManager

Fetch请求管理器接口

作者:
boyan

方法摘要
 void addFetchRequest(FetchRequest request)
          添加fetch请求
 int getFetchRequestCount()
          Returns current fetch requests count.
 boolean isShutdown()
          是否关闭
 void resetFetchState()
          重设状态,重设状态后可重用并start
 void startFetchRunner()
          启动管理器
 void stopFetchRunner()
          停止fetch
 

方法详细信息

getFetchRequestCount

int getFetchRequestCount()
Returns current fetch requests count.

返回:
从以下版本开始:
1.4.4

stopFetchRunner

void stopFetchRunner()
                     throws InterruptedException
停止fetch

抛出:
InterruptedException

resetFetchState

void resetFetchState()
重设状态,重设状态后可重用并start


startFetchRunner

void startFetchRunner()
启动管理器


addFetchRequest

void addFetchRequest(FetchRequest request)
添加fetch请求

参数:
request -

isShutdown

boolean isShutdown()
是否关闭

返回:


Copyright © 2010–2013. All rights reserved.