Uses of Interface
com.gigaspaces.internal.cluster.node.IReplicationInBatchContext

Packages that use IReplicationInBatchContext

Package	Description
com.gigaspaces.cluster.replication.gateway.sync
com.gigaspaces.internal.cluster.node.handlers
com.gigaspaces.internal.cluster.node.impl
com.gigaspaces.internal.cluster.node.impl.gateway.sink
com.gigaspaces.internal.cluster.node.impl.packets.data
com.gigaspaces.internal.cluster.node.impl.packets.data.operations
com.gigaspaces.internal.cluster.node.impl.processlog.globalorder
com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile
com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile
com.gigaspaces.internal.events.durable
com.gigaspaces.internal.sync.mirror

Uses of IReplicationInBatchContext in com.gigaspaces.cluster.replication.gateway.sync

Constructors in com.gigaspaces.cluster.replication.gateway.sync with parameters of type IReplicationInBatchContext

Modifier	Constructor	Description
	OperationsBatchDataImpl(IReplicationInBatchContext batchContext)
	TransactionDataImpl(IReplicationInBatchContext batchContext, ITransactionInContext transactionContext)

Uses of IReplicationInBatchContext in com.gigaspaces.internal.cluster.node.handlers

Methods in com.gigaspaces.internal.cluster.node.handlers with parameters of type IReplicationInBatchContext

Modifier and Type	Method	Description
void	IReplicationInBatchConsumptionHandler.consumePendingOperationsInBatch(IReplicationInBatchContext context)	Called after all the incoming replication events for the current batch passed through the corresponding event handlers.

Uses of IReplicationInBatchContext in com.gigaspaces.internal.cluster.node.impl

Classes in com.gigaspaces.internal.cluster.node.impl that implement IReplicationInBatchContext

Modifier and Type	Class	Description
class	AbstractReplicationInBatchContext

Methods in com.gigaspaces.internal.cluster.node.impl with parameters of type IReplicationInBatchContext

Modifier and Type	Method	Description
void	ReplicationNodeInFacade.consumePendingOperationsInBatch(IReplicationInBatchContext context)

Uses of IReplicationInBatchContext in com.gigaspaces.internal.cluster.node.impl.gateway.sink

Methods in com.gigaspaces.internal.cluster.node.impl.gateway.sink with parameters of type IReplicationInBatchContext

Modifier and Type	Method	Description
void	LocalClusterReplicationInTransactionHandler.changeEntry(IReplicationInBatchContext context, String typeName, String uid, Object id, int version, int previousVersion, long timeToLive, int routingHash, Collection<SpaceEntryMutator> spaceEntryMutators, boolean isTransient, OperationID operationID)
void	LocalClusterReplicationInBatchConsumptionHandler.consumePendingOperationsInBatch(IReplicationInBatchContext context)
protected void	AbstractLocalClusterReplicationInHandler.execute(IReplicationInBatchContext batchContext)
protected void	AbstractLocalClusterReplicationInHandler.executeIfUidPresent(IReplicationInBatchContext batchContext, String uid)
protected void	AbstractLocalClusterReplicationInHandler.executeTransactional(IReplicationInBatchContext batchContext, ITransactionInContext transactionContext)
protected String	AbstractLocalClusterReplicationInHandler.extractSourceGatewayName(IReplicationInBatchContext batchContext)
protected void	AbstractLocalClusterReplicationInHandler.handleChangeEntry(String typeName, String uid, Object id, int version, int previousVersion, int routingHash, long timeToLive, Collection<SpaceEntryMutator> mutators, IReplicationInBatchContext batchContext)
protected void	AbstractLocalClusterReplicationInHandler.handleRemoveEntry(IEntryPacket entryPacket, IReplicationInBatchContext batchContext)
protected void	AbstractLocalClusterReplicationInHandler.handleRemoveEntryByUid(String typeName, String uid, IReplicationInBatchContext batchContext)
protected void	AbstractLocalClusterReplicationInHandler.handleUpdateEntry(IEntryPacket entryPacket, IEntryPacket oldEntryPacket, IReplicationInBatchContext batchContext, boolean partialUpdate)
protected void	AbstractLocalClusterReplicationInHandler.handleWriteEntry(IEntryPacket entryPacket, IReplicationInBatchContext batchContext)
protected void	AbstractLocalClusterReplicationInHandler.invokeConflictResolver(IReplicationInBatchContext batchContext, LocalClusterReplicationDataConflict conflictData, boolean fromTransaction)
void	LocalClusterReplicationInTransactionHandler.removeEntry(IReplicationInBatchContext context, IEntryPacket entryPacket)
void	LocalClusterReplicationInTransactionHandler.removeEntryByUID(IReplicationInBatchContext context, String typeName, String uid, OperationID operationID)
void	LocalClusterReplicationInTransactionHandler.updateEntry(IReplicationInBatchContext context, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate, short flags)
void	LocalClusterReplicationInTransactionHandler.writeEntry(IReplicationInBatchContext context, IEntryPacket entryPacket)

Uses of IReplicationInBatchContext in com.gigaspaces.internal.cluster.node.impl.packets.data

Methods in com.gigaspaces.internal.cluster.node.impl.packets.data with parameters of type IReplicationInBatchContext

Modifier and Type	Method	Description
void	IReplicationTransactionalPacketEntryData.batchExecuteTransactional(IReplicationInBatchContext context, ITransactionalBatchExecutionCallback executionCallback)
void	ITransactionalBatchExecutionCallback.changeEntry(IReplicationInBatchContext context, String typeName, String uid, Object id, int version, int previousVersion, long timeToLive, int routingHash, Collection<SpaceEntryMutator> spaceEntryMutators, boolean isTransient, OperationID operationID)
IDataConsumeResult	IReplicationPacketDataBatchConsumer.consumePendingPackets(IReplicationInBatchContext batchContext, IReplicationInFacade replicationInFacade)	Consume packets which are pending in the provided batch context.
IDataConsumeResult	ReplicationPacketDataConsumer.consumePendingPackets(IReplicationInBatchContext context, IReplicationInFacade replicationInFacade)
void	ITransactionalBatchExecutionCallback.removeEntry(IReplicationInBatchContext context, IEntryPacket entryPacket)
void	ITransactionalBatchExecutionCallback.removeEntryByUID(IReplicationInBatchContext context, String typeName, String uid, OperationID operationID)
void	ITransactionalBatchExecutionCallback.updateEntry(IReplicationInBatchContext context, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate, short flags)
void	ITransactionalBatchExecutionCallback.writeEntry(IReplicationInBatchContext context, IEntryPacket entryPacket)

Uses of IReplicationInBatchContext in com.gigaspaces.internal.cluster.node.impl.packets.data.operations

Methods in com.gigaspaces.internal.cluster.node.impl.packets.data.operations with parameters of type IReplicationInBatchContext

Modifier and Type	Method	Description
void	ChangeReplicationPacketData.batchExecuteTransactional(IReplicationInBatchContext context, ITransactionalBatchExecutionCallback transactionExecutionCallback)
void	PartialUpdateReplicationPacketData.batchExecuteTransactional(IReplicationInBatchContext context, ITransactionalBatchExecutionCallback executionCallback)
void	RemoveByUIDReplicationPacketData.batchExecuteTransactional(IReplicationInBatchContext context, ITransactionalBatchExecutionCallback executionCallback)
void	RemoveReplicationPacketData.batchExecuteTransactional(IReplicationInBatchContext context, ITransactionalBatchExecutionCallback executionCallback)
void	UpdateReplicationPacketData.batchExecuteTransactional(IReplicationInBatchContext context, ITransactionalBatchExecutionCallback executionCallback)
void	WriteReplicationPacketData.batchExecuteTransactional(IReplicationInBatchContext context, ITransactionalBatchExecutionCallback executionCallback)

Uses of IReplicationInBatchContext in com.gigaspaces.internal.cluster.node.impl.processlog.globalorder

Classes in com.gigaspaces.internal.cluster.node.impl.processlog.globalorder that implement IReplicationInBatchContext

Modifier and Type	Class	Description
class	GlobalOrderReplicationInBatchContext

Uses of IReplicationInBatchContext in com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile

Classes in com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile that implement IReplicationInBatchContext

Modifier and Type	Class	Description
class	MultiBucketSingleFileReplicationInBatchContext

Uses of IReplicationInBatchContext in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile

Classes in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile that implement IReplicationInBatchContext

Modifier and Type	Class	Description
class	MultiSourceSingleFileReplicationInBatchContext

Uses of IReplicationInBatchContext in com.gigaspaces.internal.events.durable

Methods in com.gigaspaces.internal.events.durable with parameters of type IReplicationInBatchContext

Modifier and Type	Method	Description
void	ReplicationNotificationInTransactionEntryHandler.changeEntry(IReplicationInBatchContext context, String typeName, String uid, Object id, int version, int previousVersion, long timeToLive, int routingHash, Collection<SpaceEntryMutator> spaceEntryMutators, boolean isTransient, OperationID operationID)
void	ReplicationNotificationInBatchConsumptionHandler.consumePendingOperationsInBatch(IReplicationInBatchContext context)
void	ReplicationNotificationInTransactionEntryHandler.removeEntry(IReplicationInBatchContext context, IEntryPacket entryPacket)
void	ReplicationNotificationInTransactionEntryHandler.removeEntryByUID(IReplicationInBatchContext context, String typeName, String uid, OperationID operationID)
void	ReplicationNotificationInTransactionEntryHandler.updateEntry(IReplicationInBatchContext context, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate, short flags)
void	ReplicationNotificationInTransactionEntryHandler.writeEntry(IReplicationInBatchContext context, IEntryPacket entryPacket)

Uses of IReplicationInBatchContext in com.gigaspaces.internal.sync.mirror

Methods in com.gigaspaces.internal.sync.mirror with parameters of type IReplicationInBatchContext

Modifier and Type	Method	Description
void	MirrorReplicationInHandler.addChangeEntry(IReplicationInBatchContext context, String typeName, String uid, Object id, int version, long timeToLive, Collection<SpaceEntryMutator> mutators)
void	MirrorReplicationInHandler.addRemoveEntry(IReplicationInBatchContext context, IEntryPacket entryPacket)
void	MirrorReplicationInHandler.addTransaction(IReplicationInBatchContext context, ITransactionInContext transactionContext)
void	MirrorReplicationInHandler.addUpdateEntry(IReplicationInBatchContext context, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate)
void	MirrorReplicationInHandler.addWriteEntry(IReplicationInBatchContext context, IEntryPacket entryPacket)
void	MirrorReplicationInHandler.changeEntry(IReplicationInBatchContext context, String typeName, String uid, Object id, int version, int previousVersion, long timeToLive, int routingHash, Collection<SpaceEntryMutator> spaceEntryMutators, boolean isTransient, OperationID operationID)
void	MirrorReplicationInBatchConsumptionHandler.consumePendingOperationsInBatch(IReplicationInBatchContext context)
void	MirrorBulkExecutor.execute(List<BulkItem> entries, TransactionParticipantDataImpl transactionMetaData, IReplicationInBatchContext batchContext)
protected void	MirrorReplicationInHandler.execute(IReplicationInBatchContext batchContext, TransactionParticipantDataImpl transactionParticipantData)
void	MirrorReplicationInHandler.removeEntry(IReplicationInBatchContext context, IEntryPacket entryPacket)
void	MirrorReplicationInHandler.removeEntryByUID(IReplicationInBatchContext context, String typeName, String uid, OperationID operationID)
void	MirrorReplicationInHandler.updateEntry(IReplicationInBatchContext context, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate, short flags)
void	MirrorReplicationInHandler.writeEntry(IReplicationInBatchContext context, IEntryPacket entryPacket)