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

Class MultiBucketSingleFileProcessLogBuilder

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile.MultiBucketSingleFileProcessLogBuilder

All Implemented Interfaces:

IReplicationAsyncProcessLogBuilder, IReplicationProcessLogBuilder, IReplicationReliableAsyncKeeperProcessLogBuilder, IReplicationReliableAsyncProcessLogBuilder, IReplicationSyncProcessLogBuilder

public class MultiBucketSingleFileProcessLogBuilder
extends Object
implements IReplicationProcessLogBuilder

Constructor Summary

Constructors

Constructor	Description
MultiBucketSingleFileProcessLogBuilder(IReplicationPacketDataBatchConsumer<?> dataConsumer)

Method Summary

Modifier and Type	Method	Description
IReplicationAsyncTargetProcessLog	createAsyncProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)
IReplicationBatchConsumeAsyncTargetProcessLog	createBatchConsumeAsyncProcessLog(TargetGroupConfig groupConfig, IBacklogHandshakeRequest handshakeRequest, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)
IReplicationSyncTargetProcessLog	createReliableAsyncKeeperProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator, IReplicationSyncTargetProcessLog synchronizingProcessLog)
IReplicationReliableAsyncTargetProcessLog	createReliableAsyncProcessLog(TargetGroupConfig groupConfig, IBacklogHandshakeRequest handshakeRequest, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationReliableAsyncTargetProcessLog synchronizingProcessLog, IReplicationGroupHistory groupHistory, org.slf4j.Logger specificLogger)
IReplicationSyncTargetProcessLog	createSyncProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

MultiBucketSingleFileProcessLogBuilder

public MultiBucketSingleFileProcessLogBuilder(IReplicationPacketDataBatchConsumer<?> dataConsumer)

Method Details

createSyncProcessLog

public IReplicationSyncTargetProcessLog createSyncProcessLog(TargetGroupConfig groupConfig,
 IReplicationInFacade replicationInFacade,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 String myLookupName,
 String groupName,
 String sourceLookupName,
 IReplicationGroupHistory groupHistory)

Specified by:

createSyncProcessLog in interface IReplicationSyncProcessLogBuilder

createAsyncProcessLog

public IReplicationAsyncTargetProcessLog createAsyncProcessLog(TargetGroupConfig groupConfig,
 IReplicationInFacade replicationInFacade,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 String myLookupName,
 String groupName,
 String sourceLookupName,
 IReplicationGroupHistory groupHistory)

Specified by:

createAsyncProcessLog in interface IReplicationAsyncProcessLogBuilder

createReliableAsyncKeeperProcessLog

public IReplicationSyncTargetProcessLog createReliableAsyncKeeperProcessLog(TargetGroupConfig groupConfig,
 IReplicationInFacade replicationInFacade,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 String myLookupName,
 String groupName,
 String sourceLookupName,
 IReplicationGroupHistory groupHistory,
 IReplicationReliableAsyncMediator mediator,
 IReplicationSyncTargetProcessLog synchronizingProcessLog)

Specified by:

createReliableAsyncKeeperProcessLog in interface IReplicationReliableAsyncKeeperProcessLogBuilder

createReliableAsyncProcessLog

public IReplicationReliableAsyncTargetProcessLog createReliableAsyncProcessLog(TargetGroupConfig groupConfig,
 IBacklogHandshakeRequest handshakeRequest,
 IReplicationInFacade replicationInFacade,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 String myLookupName,
 String groupName,
 String sourceLookupName,
 IReplicationReliableAsyncTargetProcessLog synchronizingProcessLog,
 IReplicationGroupHistory groupHistory,
 org.slf4j.Logger specificLogger)

Specified by:

createReliableAsyncProcessLog in interface IReplicationReliableAsyncProcessLogBuilder

createBatchConsumeAsyncProcessLog

public IReplicationBatchConsumeAsyncTargetProcessLog createBatchConsumeAsyncProcessLog(TargetGroupConfig groupConfig,
 IBacklogHandshakeRequest handshakeRequest,
 IReplicationInFacade replicationInFacade,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 String myLookupName,
 String groupName,
 String sourceLookupName,
 IReplicationGroupHistory groupHistory)

Specified by:

createBatchConsumeAsyncProcessLog in interface IReplicationAsyncProcessLogBuilder

toString

public String toString()

Overrides:

toString in class Object