com.taobao.metamorphosis.gregor.master
类 SamsaCommandProcessor.SyncAppendCallback

java.lang.Object
  com.taobao.metamorphosis.gregor.master.SamsaCommandProcessor.SyncAppendCallback

所有已实现的接口：

com.taobao.gecko.service.SingleRequestCallBackListener, AppendCallback

包容类：

SamsaCommandProcessor

public final class SamsaCommandProcessor.SyncAppendCallback
extends Object
implements AppendCallback, com.taobao.gecko.service.SingleRequestCallBackListener

append到message store的callback

作者：

boyan(boyan@taobao.com)

构造方法摘要

SamsaCommandProcessor.SyncAppendCallback(int partition, String partitionString, PutCommand request, long messageId, PutCallback cb)

方法摘要

void	appendComplete(Location location) Master append应答
boolean	equals(Object obj)
ThreadPoolExecutor	getExecutor()
int	hashCode()
void	onException(Exception e)
void	onResponse(com.taobao.gecko.core.command.ResponseCommand responseCommand, com.taobao.gecko.service.Connection conn)

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

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

构造方法详细信息

SamsaCommandProcessor.SyncAppendCallback

public SamsaCommandProcessor.SyncAppendCallback(int partition,
                                                String partitionString,
                                                PutCommand request,
                                                long messageId,
                                                PutCallback cb)

方法详细信息

hashCode

public int hashCode()

覆盖：

类 Object 中的 hashCode

equals

public boolean equals(Object obj)

覆盖：

类 Object 中的 equals

appendComplete

public void appendComplete(Location location)

Master append应答

指定者：

接口 AppendCallback 中的 appendComplete

onResponse

public void onResponse(com.taobao.gecko.core.command.ResponseCommand responseCommand,
                       com.taobao.gecko.service.Connection conn)

指定者：

接口 com.taobao.gecko.service.SingleRequestCallBackListener 中的 onResponse

onException

public void onException(Exception e)

指定者：

接口 com.taobao.gecko.service.SingleRequestCallBackListener 中的 onException

getExecutor

public ThreadPoolExecutor getExecutor()

指定者：

接口 com.taobao.gecko.service.SingleRequestCallBackListener 中的 getExecutor