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 and Description
protected IReplicationPacketDataConsumer	_dataConsumer
protected org.slf4j.Logger	_specificLogger

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

_specificLogger

protected final org.slf4j.Logger _specificLogger

_dataConsumer

protected final IReplicationPacketDataConsumer _dataConsumer

Constructor Detail

AbstractSingleFileTargetProcessLog

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

Method Detail

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