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

Class ReplicationInContext

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.ReplicationInContext

All Implemented Interfaces:

IReplicationInContext

Direct Known Subclasses:

AbstractReplicationInBatchContext, MultiBucketSingleFileReplicationInBatchContext

public class ReplicationInContext
extends Object
implements IReplicationInContext

Constructor Summary

Constructors

Constructor	Description
ReplicationInContext(String sourceLookupName, String groupName, org.slf4j.Logger specificLogger, boolean hasContentContext, boolean supportDistTransactionConsolidation)
ReplicationInContext(String sourceLookupName, String groupName, org.slf4j.Logger specificLogger, boolean hasContentContext, boolean supportDistTransactionConsolidation, IReplicationReliableAsyncMediator reliableAsyncMediator)

Method Summary

Modifier and Type	Method	Description
ReplicationInContentContext	getContentContext()
org.slf4j.Logger	getContextLogger()
IMarker	getContextMarker(String membersGroupName)
String	getGroupName()
long	getLastProcessedKey()
ReplicationBlobstoreBulkContext	getReplicationBlobstoreBulkContext()
String	getSourceLookupName()
boolean	isBatchContext()
void	setContextPacket(IReplicationOrderedPacket packet)
void	setLastProcessedKey(long lastProcessedKey)
void	setReplicationBlobstoreBulkContext(ReplicationBlobstoreBulkContext replicationBlobstoreBulkContext)
boolean	supportsDistributedTransactionConsolidation()

Methods inherited from class java.lang.Object

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

Constructor Details

ReplicationInContext

public ReplicationInContext(String sourceLookupName,
 String groupName,
 org.slf4j.Logger specificLogger,
 boolean hasContentContext,
 boolean supportDistTransactionConsolidation)

ReplicationInContext

public ReplicationInContext(String sourceLookupName,
 String groupName,
 org.slf4j.Logger specificLogger,
 boolean hasContentContext,
 boolean supportDistTransactionConsolidation,
 IReplicationReliableAsyncMediator reliableAsyncMediator)

Method Details

getSourceLookupName

public String getSourceLookupName()

Specified by:

getSourceLookupName in interface IReplicationInContext

getContextLogger

public org.slf4j.Logger getContextLogger()

Specified by:

getContextLogger in interface IReplicationInContext

getGroupName

public String getGroupName()

Specified by:

getGroupName in interface IReplicationInContext

getContentContext

public ReplicationInContentContext getContentContext()

Specified by:

getContentContext in interface IReplicationInContext

isBatchContext

public boolean isBatchContext()

Specified by:

isBatchContext in interface IReplicationInContext

getContextMarker

public IMarker getContextMarker(String membersGroupName)

Specified by:

getContextMarker in interface IReplicationInContext

setContextPacket

public void setContextPacket(IReplicationOrderedPacket packet)

supportsDistributedTransactionConsolidation

public boolean supportsDistributedTransactionConsolidation()

Specified by:

supportsDistributedTransactionConsolidation in interface IReplicationInContext

setReplicationBlobstoreBulkContext

public void setReplicationBlobstoreBulkContext(ReplicationBlobstoreBulkContext replicationBlobstoreBulkContext)

Specified by:

setReplicationBlobstoreBulkContext in interface IReplicationInContext

getReplicationBlobstoreBulkContext

public ReplicationBlobstoreBulkContext getReplicationBlobstoreBulkContext()

Specified by:

getReplicationBlobstoreBulkContext in interface IReplicationInContext

getLastProcessedKey

public long getLastProcessedKey()

Specified by:

getLastProcessedKey in interface IReplicationInContext

setLastProcessedKey

public void setLastProcessedKey(long lastProcessedKey)