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

Class MultiSourceSingleFileProcessLogBuilder

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile.MultiSourceSingleFileProcessLogBuilder

All Implemented Interfaces:

IReplicationAsyncProcessLogBuilder, IReplicationProcessLogBuilder, IReplicationReliableAsyncKeeperProcessLogBuilder, IReplicationReliableAsyncProcessLogBuilder, IReplicationSyncProcessLogBuilder

public class MultiSourceSingleFileProcessLogBuilder
extends Object
implements IReplicationProcessLogBuilder

Since:

8.0.4

Author:

idan

Constructor Summary

Constructors

Constructor and Description
MultiSourceSingleFileProcessLogBuilder(IReplicationPacketDataBatchConsumer<?> dataConsumer)

Method Summary

Modifier and Type	Method and 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)
MultiSourceSingleFileReliableAsyncTargetProcessLog	createReliableAsyncProcessLog(TargetGroupConfig groupConfig, IBacklogHandshakeRequest handshakeRequest, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationReliableAsyncTargetProcessLog synchronizingProcessLog, IReplicationGroupHistory groupHistory, Logger specificLogger)
GlobalOrderTargetProcessLog	createSyncOneWayProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)
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

Constructor Detail

MultiSourceSingleFileProcessLogBuilder

public MultiSourceSingleFileProcessLogBuilder(IReplicationPacketDataBatchConsumer<?> dataConsumer)

Method Detail

createSyncProcessLog

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

Specified by:

createSyncProcessLog in interface IReplicationSyncProcessLogBuilder

createSyncOneWayProcessLog

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

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 MultiSourceSingleFileReliableAsyncTargetProcessLog createReliableAsyncProcessLog(TargetGroupConfig groupConfig,
                                                                                        IBacklogHandshakeRequest handshakeRequest,
                                                                                        IReplicationInFacade replicationInFacade,
                                                                                        IReplicationProcessLogExceptionHandler exceptionHandler,
                                                                                        String myLookupName,
                                                                                        String groupName,
                                                                                        String sourceLookupName,
                                                                                        IReplicationReliableAsyncTargetProcessLog synchronizingProcessLog,
                                                                                        IReplicationGroupHistory groupHistory,
                                                                                        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