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

Class ReliableAsyncAdaptiveProcessLogBuilder

java.lang.Object

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

All Implemented Interfaces:

IReplicationAsyncProcessLogBuilder, IReplicationProcessLogBuilder, IReplicationReliableAsyncKeeperProcessLogBuilder, IReplicationReliableAsyncProcessLogBuilder, IReplicationSyncProcessLogBuilder

public class ReliableAsyncAdaptiveProcessLogBuilder
extends Object
implements IReplicationProcessLogBuilder

A process log builder that creates a processing log according to the given target group config process log configuration

Since:

8.0

Author:

eitany

Constructor Summary

Constructors

Constructor	Description
ReliableAsyncAdaptiveProcessLogBuilder(IReplicationPacketDataBatchConsumer<?> dataConsumer, DistributedTransactionProcessingConfiguration distributedTransactionProcessingConfiguration)

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

ReliableAsyncAdaptiveProcessLogBuilder

public ReliableAsyncAdaptiveProcessLogBuilder(IReplicationPacketDataBatchConsumer<?> dataConsumer,
 DistributedTransactionProcessingConfiguration distributedTransactionProcessingConfiguration)

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

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

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

toString

public String toString()

Overrides:

toString in class Object