Package com.gigaspaces.internal.cluster.node.impl.processlog

Class AbstractSingleFileTargetProcessLog

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.processlog.AbstractSingleFileTargetProcessLog

Direct Known Subclasses:

AbstractGlobalOrderTargetProcessLog, AbstractMultiBucketSingleFileTargetProcessLog, MultiSourceSingleFileReliableAsyncTargetProcessLog

public abstract class AbstractSingleFileTargetProcessLog
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final IReplicationPacketDataConsumer	_dataConsumer
protected final org.slf4j.Logger	_specificLogger

Constructor Summary

Constructors

Constructor	Description
AbstractSingleFileTargetProcessLog(IReplicationPacketDataConsumer dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)

Method Summary

Modifier and Type	Method	Description
protected abstract boolean	contentRequiredWhileProcessing()
ReplicationInContext	createReplicationInContext()
abstract String	dumpState()
<T extends IReplicationPacketData<?>> IReplicationPacketDataConsumer<T>	getDataConsumer()
IReplicationProcessLogExceptionHandler	getExceptionHandler()
IReplicationGroupHistory	getGroupHistory()
String	getGroupName()
ReplicationInContext	getReplicationInContext()
IReplicationInFacade	getReplicationInFacade()
protected String	getSourceLookupName()
static void	throwIfRepetitiveError(IDataConsumeResult prevResult, IDataConsumeResult consumeResult)
String	toLogMessage()

Methods inherited from class java.lang.Object

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

Field Details

_specificLogger

protected final org.slf4j.Logger _specificLogger

_dataConsumer

protected final IReplicationPacketDataConsumer _dataConsumer

Constructor Details

AbstractSingleFileTargetProcessLog

public AbstractSingleFileTargetProcessLog(IReplicationPacketDataConsumer dataConsumer,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 IReplicationInFacade replicationInFacade,
 String name,
 String groupName,
 String sourceLookupName,
 IReplicationGroupHistory groupHistory)

Method Details

createReplicationInContext

public ReplicationInContext createReplicationInContext()

contentRequiredWhileProcessing

protected abstract boolean contentRequiredWhileProcessing()

getDataConsumer

public <T extends IReplicationPacketData<?>>
IReplicationPacketDataConsumer<T> getDataConsumer()

getReplicationInContext

public ReplicationInContext getReplicationInContext()

getGroupHistory

public IReplicationGroupHistory getGroupHistory()

getSourceLookupName

protected String getSourceLookupName()

getGroupName

public String getGroupName()

getExceptionHandler

public IReplicationProcessLogExceptionHandler getExceptionHandler()

getReplicationInFacade

public IReplicationInFacade getReplicationInFacade()

toLogMessage

public String toLogMessage()

dumpState

public abstract String dumpState()

throwIfRepetitiveError

public static void throwIfRepetitiveError(IDataConsumeResult prevResult,
 IDataConsumeResult consumeResult)
                                   throws Exception

Throws:

Exception