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

Class GlobalOrderProcessLogBuilder

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.processlog.globalorder.GlobalOrderProcessLogBuilder

All Implemented Interfaces:

IReplicationAsyncProcessLogBuilder, IReplicationProcessLogBuilder, IReplicationReliableAsyncKeeperProcessLogBuilder, IReplicationReliableAsyncProcessLogBuilder, IReplicationSyncProcessLogBuilder

public class GlobalOrderProcessLogBuilder
extends Object
implements IReplicationProcessLogBuilder

Field Summary

Fields

Modifier and Type	Field	Description
protected final IReplicationPacketDataBatchConsumer<?>	_dataConsumer

Constructor Summary

Constructors

Constructor	Description
GlobalOrderProcessLogBuilder(IReplicationPacketDataBatchConsumer<?> dataConsumer)

Method Summary

Modifier and Type	Method	Description
GlobalOrderTargetProcessLog	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)
GlobalOrderReliableAsyncTargetKeeperProcessLog	createReliableAsyncKeeperProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator, IReplicationSyncTargetProcessLog synchronizingProcessLog)
GlobalOrderReliableAsyncTargetProcessLog	createReliableAsyncProcessLog(TargetGroupConfig groupConfig, IBacklogHandshakeRequest handshakeRequest, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationReliableAsyncTargetProcessLog synchronizingProcessLog, IReplicationGroupHistory groupHistory, org.slf4j.Logger specificLogger)
GlobalOrderTargetProcessLog	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

Field Details

_dataConsumer

protected final IReplicationPacketDataBatchConsumer<?> _dataConsumer

Constructor Details

GlobalOrderProcessLogBuilder

public GlobalOrderProcessLogBuilder(IReplicationPacketDataBatchConsumer<?> dataConsumer)

Method Details

createSyncProcessLog

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

Specified by:

createSyncProcessLog in interface IReplicationSyncProcessLogBuilder

createAsyncProcessLog

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

Specified by:

createAsyncProcessLog in interface IReplicationAsyncProcessLogBuilder

createReliableAsyncKeeperProcessLog

public GlobalOrderReliableAsyncTargetKeeperProcessLog 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 GlobalOrderReliableAsyncTargetProcessLog 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