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

Packages that use IReplicationInContext

Package	Description
com.gigaspaces.internal.client.cache.localview.replication
com.gigaspaces.internal.cluster.node
com.gigaspaces.internal.cluster.node.handlers
com.gigaspaces.internal.cluster.node.impl
com.gigaspaces.internal.cluster.node.impl.filters
com.gigaspaces.internal.cluster.node.impl.gateway.sink
com.gigaspaces.internal.cluster.node.impl.groups
com.gigaspaces.internal.cluster.node.impl.handlers
com.gigaspaces.internal.cluster.node.impl.packets.data
com.gigaspaces.internal.cluster.node.impl.packets.data.errors
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.server.space.events
com.gigaspaces.internal.sync
com.gigaspaces.internal.sync.mirror

Uses of IReplicationInContext in com.gigaspaces.internal.client.cache.localview.replication

Methods in com.gigaspaces.internal.client.cache.localview.replication with parameters of type IReplicationInContext

Modifier and Type	Method and Description
void	LocalViewReplicationEntryEventHandler.changeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String typeName, String uid, Object id, int routingHash, int version, int previousVersion, long timeToLive, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID, IEntryData previousEntry)
void	LocalViewReplicationEntryLeaseEventHandler.inCancelEntryLeaseByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, int routingValue)
void	LocalViewReplicationMetadataEventHandler.inDataTypeAddIndex(IReplicationInContext context, AddTypeIndexesRequestInfo requestInfo)
void	LocalViewReplicationMetadataEventHandler.inDataTypeIntroduce(IReplicationInContext context, ITypeDesc typeDesc)
void	LocalViewReplicationEntryLeaseEventHandler.inEntryLeaseExpired(IReplicationInContext context, IEntryPacket entryPacket)
void	LocalViewReplicationEntryLeaseEventHandler.inEntryLeaseExpiredByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, OperationID operationID)
void	LocalViewReplicationEntryLeaseEventHandler.inExtendEntryLeasePeriod(IReplicationInContext context, String typeName, String uid, boolean isTransient, long lease, int routingValue)
void	LocalViewReplicationTransactionEventHandler.inTransaction(IReplicationInContext context, ITransactionInContext transactionContext)
void	LocalViewReplicationTransactionEventHandler.inTransactionAbort(IReplicationInContext context, ITransactionInContext transactionContext)
void	LocalViewReplicationTransactionEventHandler.inTransactionCommit(IReplicationInContext context, ITransactionInContext transactionContext)
void	LocalViewReplicationTransactionEventHandler.inTransactionPrepare(IReplicationInContext context, ITransactionInContext transactionContext)
void	LocalViewReplicationEntryEventHandler.removeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
void	LocalViewReplicationEntryEventHandler.removeEntryByUid(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String uid, boolean isTransient, OperationID operationID, String typeName)
void	LocalViewReplicationEntryEventHandler.updateEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry, IEntryPacket previousPacket, boolean partialUpdate, boolean overrideVersion)
void	LocalViewReplicationEntryEventHandler.writeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)

Uses of IReplicationInContext in com.gigaspaces.internal.cluster.node

Subinterfaces of IReplicationInContext in com.gigaspaces.internal.cluster.node

Modifier and Type	Interface and Description
interface	IReplicationInBatchContext

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

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

Modifier and Type	Method and Description
void	AbstractReplicationEntryEventHandler.afterConsumption(IReplicationInContext context, boolean successful, long lastProcessedKey)
void	IReplicationInEntryHandler.afterConsumption(IReplicationInContext context, boolean successful, long lastProcessedKey)
void	AbstractReplicationEntryEventHandler.beforeConsume(IReplicationInContext context)
void	IReplicationInEntryHandler.beforeConsume(IReplicationInContext context)
abstract void	AbstractReplicationEntryEventHandler.changeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String typeName, String uid, Object id, int routingHash, int version, int previousVersion, long timeToLive, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID, IEntryData previousEntryData)
void	IReplicationInEntryLeaseCancelledHandler.inCancelEntryLease(IReplicationInContext context, IEntryPacket entryPacket)
void	IReplicationInEntryLeaseCancelledHandler.inCancelEntryLeaseByUID(IReplicationInContext context, String className, String uid, boolean isTransient, int routingValue)
void	AbstractReplicationEntryEventHandler.inChangeEntry(IReplicationInContext context, String typeName, String uid, Object id, int version, int previousVersion, int routingHash, long timeToLive, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID)
void	IReplicationInEntryHandler.inChangeEntry(IReplicationInContext context, String typeName, String uid, Object id, int version, int previousVersion, int routingHash, long timeToLive, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID)
void	IReplicationInDataTypeIndexAddedHandler.inDataTypeAddIndex(IReplicationInContext context, AddTypeIndexesRequestInfo addIndexRequestInfo)
void	IReplicationInDataTypeDropHandler.inDataTypeDrop(IReplicationInContext context, String className)
void	IReplicationInDataTypeCreatedHandler.inDataTypeIntroduce(IReplicationInContext context, ITypeDesc typeDescriptor)
void	IReplicationInEntryLeaseExpiredHandler.inEntryLeaseExpired(IReplicationInContext context, IEntryPacket entryPacket)
void	IReplicationInEntryLeaseExpiredHandler.inEntryLeaseExpiredByUID(IReplicationInContext context, String className, String uid, boolean isTransient, OperationID operationID)
void	IReplicationInEvictEntryHandler.inEvictEntry(IReplicationInContext context, String uid, boolean isTransient, OperationID operationID)
void	IReplicationInEntryLeaseExtendedHandler.inExtendEntryLeasePeriod(IReplicationInContext context, String className, String uid, boolean isTransient, long lease, int routingValue)
void	IReplicationInNotifyTemplateLeaseExtendedHandler.inExtendNotifyTemplateLeasePeriod(IReplicationInContext context, String className, String uid, long lease)
void	IReplicationInNotifyTemplateCreatedHandler.inInsertNotifyTemplate(IReplicationInContext context, ITemplatePacket entryPacket, String uid, NotifyInfo notifyInfo)
void	IReplicationInNotificationSentHandler.inNotificationSent(IReplicationInContext context, OperationID operationId)
void	IReplicationInNotifyTemplateLeaseExpiredHandler.inNotifyTemplateLeaseExpired(IReplicationInContext context, String className, String uid, OperationID operationID)
void	AbstractReplicationEntryEventHandler.inRemoveEntry(IReplicationInContext context, IEntryPacket entry)
void	IReplicationInEntryHandler.inRemoveEntry(IReplicationInContext context, IEntryPacket entryPacket)
void	AbstractReplicationEntryEventHandler.inRemoveEntryByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, OperationID operationID)
void	IReplicationInEntryHandler.inRemoveEntryByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, OperationID operationID)
void	IReplicationInNotifyTemplateRemovedHandler.inRemoveNotifyTemplate(IReplicationInContext context, String className, String uid)
void	IReplicationInTransactionHandler.inTransaction(IReplicationInContext context, ITransactionInContext transactionContext) Handles one phase commit transaction (single participant)
void	IReplicationInTransactionHandler.inTransactionAbort(IReplicationInContext context, ITransactionInContext transactionContext) Handle abort stage of two phase committed transaction
void	IReplicationInTransactionHandler.inTransactionCommit(IReplicationInContext context, ITransactionInContext transactionContext) Handle commit stage of two phase committed transaction
void	IReplicationInTransactionHandler.inTransactionPrepare(IReplicationInContext context, ITransactionInContext transactionContext) Handle prepare stage of two phase committed transaction
void	AbstractReplicationEntryEventHandler.inUpdateEntry(IReplicationInContext context, IEntryPacket entry, IEntryPacket oldEntryPacket, boolean partialUpdate, boolean overrideVersion, short flags)
void	IReplicationInEntryHandler.inUpdateEntry(IReplicationInContext context, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate, boolean overrideVersion, short flags)
void	AbstractReplicationEntryEventHandler.inWriteEntry(IReplicationInContext context, IEntryPacket entry)
void	IReplicationInEntryHandler.inWriteEntry(IReplicationInContext context, IEntryPacket entryPacket)
abstract void	AbstractReplicationEntryEventHandler.removeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
abstract void	AbstractReplicationEntryEventHandler.removeEntryByUid(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String uid, boolean isTransient, OperationID operationID, String typeName)
abstract void	AbstractReplicationEntryEventHandler.updateEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry, IEntryPacket previousPacket, boolean partialUpdate, boolean overrideVersion)
abstract void	AbstractReplicationEntryEventHandler.writeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)

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

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

Modifier and Type	Class and Description
class	AbstractReplicationInBatchContext
class	ReplicationInContext

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

Modifier and Type	Method and Description
void	ReplicationNodeInFacade.afterConsumption(IReplicationInContext context, boolean successful, long lastProcessedKey)
void	ReplicationNodeInFacade.beforeConsume(IReplicationInContext context)
void	DataTypeDropPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	DataTypeAddIndexPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	DataTypeIntroducePacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	ReplicationNodeInFacade.inCancelEntryLease(IReplicationInContext context, IEntryPacket entryPacket)
void	ReplicationNodeInFacade.inCancelEntryLeaseByUID(IReplicationInContext context, String className, String uid, boolean isTransient, int routingValue)
void	ReplicationNodeInFacade.inChangeEntry(IReplicationInContext context, String typeName, String uid, Object id, int version, int previousVersion, int routingHash, long timeToLive, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID)
void	ReplicationNodeInFacade.inDataTypeAddIndex(IReplicationInContext context, AddTypeIndexesRequestInfo addIndexRequestInfo)
void	ReplicationNodeInFacade.inDataTypeDrop(IReplicationInContext context, String className)
void	ReplicationNodeInFacade.inDataTypeIntroduce(IReplicationInContext context, ITypeDesc typeDescriptor)
void	ReplicationNodeInFacade.inEntryLeaseExpired(IReplicationInContext context, IEntryPacket entryPacket)
void	ReplicationNodeInFacade.inEntryLeaseExpiredByUID(IReplicationInContext context, String className, String uid, boolean isTransient, OperationID operationID)
void	ReplicationNodeInFacade.inEvictEntry(IReplicationInContext context, String uid, boolean isTransient, OperationID operationID)
void	ReplicationNodeInFacade.inExtendEntryLeasePeriod(IReplicationInContext context, String className, String uid, boolean isTransient, long lease, int routingValue)
void	ReplicationNodeInFacade.inExtendNotifyTemplateLeasePeriod(IReplicationInContext context, String className, String uid, long lease)
void	ReplicationNodeInFacade.inInsertNotifyTemplate(IReplicationInContext context, ITemplatePacket templatePacket, String uidToOperateBy, NotifyInfo notifyInfo)
void	ReplicationNodeInFacade.inNotificationSent(IReplicationInContext context, OperationID operationId)
void	ReplicationNodeInFacade.inNotifyTemplateLeaseExpired(IReplicationInContext context, String className, String uid, OperationID operationID)
void	ReplicationNodeInFacade.inRemoveEntry(IReplicationInContext context, IEntryPacket entryPacket)
void	ReplicationNodeInFacade.inRemoveEntryByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, OperationID operationID)
void	ReplicationNodeInFacade.inRemoveNotifyTemplate(IReplicationInContext context, String className, String uid)
void	ReplicationNodeInFacade.inTransaction(IReplicationInContext context, ITransactionInContext transactionContext)
void	ReplicationNodeInFacade.inTransactionAbort(IReplicationInContext context, ITransactionInContext transactionContext)
void	ReplicationNodeInFacade.inTransactionCommit(IReplicationInContext context, ITransactionInContext transactionContext)
void	ReplicationNodeInFacade.inTransactionPrepare(IReplicationInContext context, ITransactionInContext transactionContext)
void	ReplicationNodeInFacade.inUpdateEntry(IReplicationInContext context, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate, boolean overrideVersion, short flags)
void	ReplicationNodeInFacade.inWriteEntry(IReplicationInContext context, IEntryPacket entryPacket)

Uses of IReplicationInContext in com.gigaspaces.internal.cluster.node.impl.filters

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

Modifier and Type	Method and Description
void	IReplicationInFilterCallback.invokeInFilter(IReplicationInContext context, IReplicationPacketData<?> data) Callback method for the data consumer to invoke input filters before executing the packet

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

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

Modifier and Type	Method and Description
void	LocalClusterReplicationInEntryHandler.afterConsumption(IReplicationInContext context, boolean successful, long lastProcessedKey)
void	LocalClusterReplicationInEntryHandler.beforeConsume(IReplicationInContext context)
void	LocalClusterReplicationEntryLeaseEventHandler.inCancelEntryLease(IReplicationInContext context, IEntryPacket entryPacket)
void	LocalClusterReplicationEntryLeaseEventHandler.inCancelEntryLeaseByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, int routingValue)
void	LocalClusterReplicationInEntryHandler.inChangeEntry(IReplicationInContext context, String typeName, String uid, Object id, int version, int previousVersion, int routingHash, long timeToLive, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID)
void	LocalClusterReplicationMetadataEventHandler.inDataTypeAddIndex(IReplicationInContext context, AddTypeIndexesRequestInfo requestInfo)
void	LocalClusterReplicationMetadataEventHandler.inDataTypeIntroduce(IReplicationInContext context, ITypeDesc typeDesc)
void	LocalClusterReplicationEntryLeaseEventHandler.inExtendEntryLeasePeriod(IReplicationInContext context, String typeName, String uid, boolean isTransient, long lease, int routingValue)
void	LocalClusterReplicationInEntryHandler.inRemoveEntry(IReplicationInContext context, IEntryPacket entryPacket)
void	LocalClusterReplicationInEntryHandler.inRemoveEntryByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, OperationID operationID)
void	LocalClusterReplicationInTransactionHandler.inTransaction(IReplicationInContext context, ITransactionInContext transactionContext)
void	LocalClusterReplicationInTransactionHandler.inTransactionAbort(IReplicationInContext context, ITransactionInContext transactionContext)
void	LocalClusterReplicationInTransactionHandler.inTransactionCommit(IReplicationInContext context, ITransactionInContext transactionContext)
void	LocalClusterReplicationInTransactionHandler.inTransactionPrepare(IReplicationInContext context, ITransactionInContext transactionContext)
void	LocalClusterReplicationInEntryHandler.inUpdateEntry(IReplicationInContext context, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate, boolean overrideVersion, short flags)
void	LocalClusterReplicationInEntryHandler.inWriteEntry(IReplicationInContext context, IEntryPacket entryPacket)

Uses of IReplicationInContext in com.gigaspaces.internal.cluster.node.impl.groups

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

Modifier and Type	Method and Description
void	AbstractReplicationTargetChannel.invokeInFilter(IReplicationInContext context, IReplicationPacketData<?> data)

Uses of IReplicationInContext in com.gigaspaces.internal.cluster.node.impl.handlers

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

Modifier and Type	Method and Description
void	BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.afterConsumption(IReplicationInContext context, boolean successful, long lastProcessedKey) Flushes the bulk to disk after consuming the replication.
void	BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.beforeConsume(IReplicationInContext context)
void	AbstractSpaceReplicationEntryEventHandler.changeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String typeName, String uid, Object id, int routingHash, int version, int previousVersion, long timeToLive, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID, IEntryData previousEntry)
void	SpaceReplicationTransactionEventHandler.changeEntry(IReplicationInContext context, Transaction transaction, boolean twoPhaseCommit, String typeName, String uid, Object id, int version, int previousVersion, long timeToLive, int routingHash, Collection<SpaceEntryMutator> spaceEntryMutators, boolean isTransient, OperationID operationID, IEntryData previousEntryData)
protected void	BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.changeEntryInSpace(IReplicationInContext context, Transaction txn, String uid, int version, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID, IEntryData previousEntry, long timeToLive, boolean twoPhaseCommit, String typeName)
protected void	AbstractSpaceReplicationEntryEventHandler.changeEntryInSpace(IReplicationInContext context, Transaction txn, String uid, int version, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID, IEntryData previousEntry, long timeToLive, boolean twoPhaseCommit, String typeName)
protected void	PrimaryBackupSpaceReplicationEntryEventHandler.changeEntryInSpace(IReplicationInContext context, Transaction txn, String uid, int version, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID, IEntryData previousEntry, long timeToLive, boolean twoPhaseCommit, String typeName)
protected ExtendedAnswerHolder	AbstractSpaceReplicationEntryEventHandler.executeUpdateOperation(IReplicationInContext context, Transaction txn, IEntryPacket entry, IEntryPacket previousEntry, boolean partialUpdate, boolean overrideVersion, long lease, boolean twoPhaseCommit, int updateModifiers)
protected ExtendedAnswerHolder	PrimaryBackupSpaceReplicationEvictionProtectionEntryEventHandler.executeUpdateOperation(IReplicationInContext context, Transaction txn, IEntryPacket entry, IEntryPacket previousEntry, boolean partialUpdate, boolean overrideVersion, long lease, boolean twoPhaseCommit, int updateModifiers)
void	ReplicationInExceptionHandler.handleEntryAlreadyInSpaceOnWrite(IReplicationInContext context, IEntryPacket entryPacket)
void	SpaceReplicationEntryLeaseEventHandler.inCancelEntryLease(IReplicationInContext context, IEntryPacket entryPacket)
void	SpaceReplicationEntryLeaseEventHandler.inCancelEntryLeaseByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, int routingValue)
void	SpaceReplicationMetadataEventHandler.inDataTypeAddIndex(IReplicationInContext context, AddTypeIndexesRequestInfo requestInfo)
void	SpaceReplicationMetadataEventHandler.inDataTypeDrop(IReplicationInContext context, String className)
void	SpaceReplicationMetadataEventHandler.inDataTypeIntroduce(IReplicationInContext context, ITypeDesc typeDesc)
void	SpaceReplicationEntryLeaseEventHandler.inEntryLeaseExpired(IReplicationInContext context, IEntryPacket entryPacket)
void	SpaceReplicationEntryLeaseEventHandler.inEntryLeaseExpiredByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, OperationID operationID)
void	AbstractSpaceReplicationEntryEventHandler.inEvictEntry(IReplicationInContext context, String uid, boolean isTransient, OperationID operationID)
void	SpaceReplicationEntryLeaseEventHandler.inExtendEntryLeasePeriod(IReplicationInContext context, String typeName, String uid, boolean isTransient, long lease, int routingValue)
void	SpaceReplicationTemplateEventHandler.inExtendNotifyTemplateLeasePeriod(IReplicationInContext context, String typeName, String uid, long lease)
void	SpaceReplicationTemplateEventHandler.inInsertNotifyTemplate(IReplicationInContext context, ITemplatePacket template, String templateUid, NotifyInfo notifyInfo)
void	SpaceReplicationTemplateEventHandler.inNotifyTemplateLeaseExpired(IReplicationInContext context, String className, String uid, OperationID operationID)
void	SpaceReplicationTemplateEventHandler.inRemoveNotifyTemplate(IReplicationInContext context, String typeName, String uid)
void	SpaceReplicationTransactionEventHandler.inTransaction(IReplicationInContext context, ITransactionInContext transactionContext)
void	SpaceReplicationTransactionEventHandler.inTransactionAbort(IReplicationInContext context, ITransactionInContext transactionContext)
void	SpaceReplicationTransactionEventHandler.inTransactionCommit(IReplicationInContext context, ITransactionInContext transactionContext)
void	SpaceReplicationTransactionEventHandler.inTransactionPrepare(IReplicationInContext context, ITransactionInContext transactionContext)
protected void	AbstractSpaceReplicationEntryEventHandler.postChangeExecution(IReplicationInContext context, IEntryData previousEntryData, IEntryData modifiedEntryData)
protected void	PrimaryBackupSpaceReplicationEntryEventHandler.postChangeExecution(IReplicationInContext context, IEntryData previousEntryData, IEntryData modifiedEntryData)
protected void	AbstractSpaceReplicationEntryEventHandler.postRemoveExecution(IReplicationInContext context, AnswerPacket aPacket)
protected void	PrimaryBackupSpaceReplicationEntryEventHandler.postRemoveExecution(IReplicationInContext context, AnswerPacket aPacket)
protected void	AbstractSpaceReplicationEntryEventHandler.postUpdateExecution(IReplicationInContext context, IEntryData previousEntryData, IEntryData currentEntryData)
protected void	PrimaryBackupSpaceReplicationEntryEventHandler.postUpdateExecution(IReplicationInContext context, IEntryData previousEntryData, IEntryData currentEntryData)
void	SpaceReplicationTransactionEventHandler.removeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
void	AbstractSpaceReplicationEntryEventHandler.removeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
void	AbstractSpaceReplicationEntryEventHandler.removeEntryByUid(IReplicationInContext context, Transaction transaction, boolean twoPhaseCommit, String uid, boolean isTransient, OperationID operationID, String typeName)
void	SpaceReplicationTransactionEventHandler.removeEntryByUID(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String uid, boolean isTransient, OperationID operationID, String typeName)
protected void	BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.removeEntryFromSpace(IReplicationInContext context, Transaction txn, ITemplatePacket template, boolean twoPhaseCommit)
protected void	AbstractSpaceReplicationEntryEventHandler.removeEntryFromSpace(IReplicationInContext context, Transaction txn, ITemplatePacket template, boolean twoPhaseCommit)
protected void	PrimaryBackupSpaceReplicationEntryEventHandler.removeEntryFromSpace(IReplicationInContext context, Transaction txn, ITemplatePacket template, boolean twoPhaseCommit)
protected boolean	ActiveActiveSpaceReplicationEntryEventHandler.shouldChangeEntryInSpace(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String typeName, String uid, boolean isTransient, int version)
protected abstract boolean	AbstractSpaceReplicationEntryEventHandler.shouldChangeEntryInSpace(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String typeName, String uid, boolean isTransient, int version)
protected boolean	PrimaryBackupSpaceReplicationEntryEventHandler.shouldChangeEntryInSpace(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String typeName, String uid, boolean isTransient, int version)
protected boolean	ActiveActiveSpaceReplicationEntryEventHandler.shouldUpdateEntryInSpace(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
protected abstract boolean	AbstractSpaceReplicationEntryEventHandler.shouldUpdateEntryInSpace(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
protected boolean	PrimaryBackupSpaceReplicationEntryEventHandler.shouldUpdateEntryInSpace(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
void	AbstractSpaceReplicationEntryEventHandler.updateEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry, IEntryPacket previousEntry, boolean partialUpdate, boolean overrideVersion)
void	SpaceReplicationTransactionEventHandler.updateEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry, IEntryPacket previousEntryPacket, boolean partialUpdate, boolean overrideVersion, short flags)
protected void	BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.updateEntryInSpace(IReplicationInContext context, Transaction txn, IEntryPacket entry, IEntryPacket previousEntry, boolean partialUpdate, boolean overrideVersion, long lease, boolean twoPhaseCommit)
protected void	AbstractSpaceReplicationEntryEventHandler.updateEntryInSpace(IReplicationInContext context, Transaction txn, IEntryPacket entry, IEntryPacket previousEntry, boolean partialUpdate, boolean overrideVersion, long lease, boolean twoPhaseCommit)
protected void	PrimaryBackupSpaceReplicationEntryEventHandler.updateEntryInSpace(IReplicationInContext context, Transaction txn, IEntryPacket entry, IEntryPacket previousEntry, boolean partialUpdate, boolean overrideVersion, long lease, boolean twoPhaseCommit)
protected ExtendedAnswerHolder	ActiveActiveSpaceReplicationEntryEventHandler.updateOrWrite(IReplicationInContext context, Transaction transaction, IEntryPacket entryPacket, long lease, int updateModifiers)
protected abstract ExtendedAnswerHolder	AbstractSpaceReplicationEntryEventHandler.updateOrWrite(IReplicationInContext context, Transaction txn, IEntryPacket entry, long lease, int modifiers)
protected ExtendedAnswerHolder	PrimaryBackupSpaceReplicationEntryEventHandler.updateOrWrite(IReplicationInContext context, Transaction transaction, IEntryPacket entryPacket, long lease, int updateModifiers)
void	SpaceReplicationTransactionEventHandler.writeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
void	AbstractSpaceReplicationEntryEventHandler.writeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
protected void	BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.writeEntryIntoSpace(IReplicationInContext context, Transaction txn, IEntryPacket entry, long lease, boolean twoPhaseCommit)
protected void	AbstractSpaceReplicationEntryEventHandler.writeEntryIntoSpace(IReplicationInContext context, Transaction txn, IEntryPacket entry, long lease, boolean twoPhaseCommit)
protected void	PrimaryBackupSpaceReplicationEntryEventHandler.writeEntryIntoSpace(IReplicationInContext context, Transaction txn, IEntryPacket entry, long lease, boolean twoPhaseCommit)

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

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

Modifier and Type	Method and Description
IExecutableReplicationPacketData<?>	ReplicationPacketDataConsumer.applyFix(IReplicationInContext context, IExecutableReplicationPacketData<?> data, IDataConsumeFix fix)
T	IReplicationPacketDataConsumer.applyFix(IReplicationInContext context, T data, IDataConsumeFix fix) Apply a fix to a data, the fix is generated due to a failed consumption of IReplicationPacketData
void	ITransactionalExecutionCallback.changeEntry(IReplicationInContext context, Transaction transaction, boolean twoPhaseCommit, String typeName, String uid, Object id, int version, int previousVersion, long timeToLive, int routingHash, Collection<SpaceEntryMutator> spaceEntryMutators, boolean isTransient, OperationID operationID, IEntryData previousEntryData)
IDataConsumeResult	ReplicationPacketDataConsumer.consume(IReplicationInContext context, IExecutableReplicationPacketData<?> data, IReplicationInFacade replicationInFacade, IReplicationInFilterCallback inFilterCallback)
IDataConsumeResult	BlobstoreReplicationPacketDataConsumer.consume(IReplicationInContext context, IExecutableReplicationPacketData<?> data, IReplicationInFacade replicationInFacade, IReplicationInFilterCallback inFilterCallback)
IDataConsumeResult	IReplicationPacketDataConsumer.consume(IReplicationInContext context, T data, IReplicationInFacade replicationInFacade, IReplicationInFilterCallback filterInCallback) Consumes a IReplicationPacketData and delegate the operation is represents to the corresponding method at the given IReplicationInFacade
void	DiscardReplicationPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	IExecutableReplicationPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	IReplicationTransactionalPacketEntryData.executeTransactional(IReplicationInContext context, ITransactionalExecutionCallback transactionExecutionCallback, Transaction transaction, boolean twoPhaseCommit)
abstract IExecutableReplicationPacketData<?>	AbstractDataConsumeFix.fix(IReplicationInContext context, IDataConsumeFixFacade fixFacade, ReplicationPacketDataConsumer consumer, IExecutableReplicationPacketData<?> data)
void	ITransactionalExecutionCallback.removeEntry(IReplicationInContext context, Transaction transaction, boolean twoPhaseCommit, IEntryPacket entryPacket)
void	ITransactionalExecutionCallback.removeEntryByUID(IReplicationInContext context, Transaction transaction, boolean twoPhaseCommit, String uid, boolean isTransient, OperationID operationID, String typeName)
Iterable<IReplicationFilterEntry>	IReplicationPacketDataConsumer.toFilterEntries(IReplicationInContext context, IReplicationPacketData<?> data) Transform generated data to filter entry in order to be passed to a filter
Iterable<IReplicationFilterEntry>	ReplicationPacketDataConsumer.toFilterEntries(IReplicationInContext context, IReplicationPacketData<?> data)
void	ITransactionalExecutionCallback.updateEntry(IReplicationInContext context, Transaction transaction, boolean twoPhaseCommit, IEntryPacket entryPacket, IEntryPacket previousEntryPacket, boolean partialUpdate, boolean overrideVersion, short flags)
void	ITransactionalExecutionCallback.writeEntry(IReplicationInContext context, Transaction transaction, boolean twoPhaseCommit, IEntryPacket entryPacket)

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

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

Modifier and Type	Method and Description
IExecutableReplicationPacketData<?>	ResurrectEntryFix.fix(IReplicationInContext context, IDataConsumeFixFacade fixFacade, ReplicationPacketDataConsumer consumer, IExecutableReplicationPacketData<?> data)
IExecutableReplicationPacketData<?>	UnknownLeaseErrorUnfixed.fix(IReplicationInContext context, IDataConsumeFixFacade fixFacade, ReplicationPacketDataConsumer consumer, IExecutableReplicationPacketData<?> data)
IExecutableReplicationPacketData<?>	RestoreFullTransactionFix.fix(IReplicationInContext context, IDataConsumeFixFacade fixFacade, ReplicationPacketDataConsumer consumer, IExecutableReplicationPacketData<?> data)
IExecutableReplicationPacketData<?>	TypeDescriptorConsumeFix.fix(IReplicationInContext context, IDataConsumeFixFacade fixFacade, ReplicationPacketDataConsumer consumer, IExecutableReplicationPacketData<?> data)
IExecutableReplicationPacketData<?>	UnhandledErrorFix.fix(IReplicationInContext context, IDataConsumeFixFacade fixFacade, ReplicationPacketDataConsumer consumer, IExecutableReplicationPacketData<?> data)
IExecutableReplicationPacketData<?>	ResurrectNotifyTemplateFix.fix(IReplicationInContext context, IDataConsumeFixFacade fixFacade, ReplicationPacketDataConsumer consumer, IExecutableReplicationPacketData<?> data)

Uses of IReplicationInContext 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 IReplicationInContext

Modifier and Type	Method and Description
void	TransactionCommitReplicationPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	SingleUidReplicationPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	RemoveReplicationPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	InsertNotifyTemplateReplicationPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	EntryLeaseExpiredFullReplicationPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	TransactionOnePhaseReplicationPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	TransactionReplicationPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator) Deprecated.
void	WriteReplicationPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	TransactionPrepareReplicationPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	PartialUpdateReplicationPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	TransactionAbortReplicationPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	CancelLeaseFullReplicationPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	UpdateReplicationPacketData.execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
protected abstract void	SingleUidReplicationPacketData.executeImpl(IReplicationInContext context, IReplicationInFacade inReplicationHandler)
protected void	CancelLeaseReplicationPacketData.executeImpl(IReplicationInContext context, IReplicationInFacade inReplicationHandler)
protected void	ExtendNotifyTemplateLeaseReplicationPacketData.executeImpl(IReplicationInContext context, IReplicationInFacade inReplicationHandler)
protected void	NotifyTemplateLeaseExpiredReplicationPacketData.executeImpl(IReplicationInContext context, IReplicationInFacade inReplicationHandler)
protected void	RemoveNotifyTemplateReplicationPacketData.executeImpl(IReplicationInContext context, IReplicationInFacade inReplicationHandler)
protected void	EvictReplicationPacketData.executeImpl(IReplicationInContext context, IReplicationInFacade inReplicationHandler)
protected void	ChangeReplicationPacketData.executeImpl(IReplicationInContext context, IReplicationInFacade inReplicationHandler)
protected void	ExtendEntryLeaseReplicationPacketData.executeImpl(IReplicationInContext context, IReplicationInFacade inReplicationHandler)
protected void	EntryLeaseExpiredReplicationPacketData.executeImpl(IReplicationInContext context, IReplicationInFacade inReplicationHandler)
protected void	RemoveByUIDReplicationPacketData.executeImpl(IReplicationInContext context, IReplicationInFacade inReplicationHandler)
void	RemoveReplicationPacketData.executeTransactional(IReplicationInContext context, ITransactionalExecutionCallback transactionExecutionCallback, Transaction transaction, boolean twoPhaseCommit)
void	WriteReplicationPacketData.executeTransactional(IReplicationInContext context, ITransactionalExecutionCallback transactionExecutionCallback, Transaction transaction, boolean twoPhaseCommit)
void	ChangeReplicationPacketData.executeTransactional(IReplicationInContext context, ITransactionalExecutionCallback transactionExecutionCallback, Transaction transaction, boolean twoPhaseCommit)
void	PartialUpdateReplicationPacketData.executeTransactional(IReplicationInContext context, ITransactionalExecutionCallback transactionExecutionCallback, Transaction transaction, boolean twoPhaseCommit)
void	UpdateReplicationPacketData.executeTransactional(IReplicationInContext context, ITransactionalExecutionCallback transactionExecutionCallback, Transaction transaction, boolean twoPhaseCommit)
void	RemoveByUIDReplicationPacketData.executeTransactional(IReplicationInContext context, ITransactionalExecutionCallback transactionExecutionCallback, Transaction transaction, boolean twoPhaseCommit)

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

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

Modifier and Type	Class and Description
class	GlobalOrderReplicationInBatchContext

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

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

Modifier and Type	Class and Description
class	MultiBucketSingleFileReplicationInBatchContext

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

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

Modifier and Type	Class and Description
class	MultiSourceSingleFileReplicationInBatchContext

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

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

Modifier and Type	Method and Description
void	AbstractReplicationNotificationInEntryHandler.afterConsumption(IReplicationInContext context, boolean successful, long lastProcessedKey)
void	AbstractReplicationNotificationInEntryHandler.beforeConsume(IReplicationInContext context)
protected static void	AbstractReplicationNotificationInEntryHandler.consumeBatchContentIfNotInTransaction(IReplicationInContext context, boolean inTransaction)
protected abstract void	AbstractReplicationNotificationInEntryHandler.handleEntryImpl(EntryArrivedRemoteEvent entryArrived, IReplicationInContext context, boolean inTransaction)
protected void	ReplicationNotificationBatchInEntryHandler.handleEntryImpl(EntryArrivedRemoteEvent entryArrived, IReplicationInContext context, boolean inTransaction)
protected void	ReplicationNotificationInEntryHandler.handleEntryImpl(EntryArrivedRemoteEvent entryArrived, IReplicationInContext context, boolean inTransaction)
void	AbstractReplicationNotificationInEntryHandler.handleEntryLeaseExpired(IReplicationInContext context, boolean inTransaction, IEntryPacket entryPacket)
void	AbstractReplicationNotificationInEntryHandler.handleEntryLeaseExpiredByUID(IReplicationInContext context, boolean inTransaction, String className, String uid, boolean isTransient, OperationID operationID)
void	AbstractReplicationNotificationInEntryHandler.handleRemoveEntry(IReplicationInContext context, boolean inTransaction, IEntryPacket entryPacket)
void	AbstractReplicationNotificationInEntryHandler.handleRemoveEntryByUID(IReplicationInContext context, boolean inTransaction, String uid, boolean isTransient, OperationID operationID)
void	AbstractReplicationNotificationInEntryHandler.handleUpdateEntry(IReplicationInContext context, boolean inTransaction, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate, boolean overrideVersion, short flags)
void	AbstractReplicationNotificationInEntryHandler.handleWriteEntry(IReplicationInContext context, boolean inTransaction, IEntryPacket entryPacket)
void	AbstractReplicationNotificationInEntryHandler.inChangeEntry(IReplicationInContext context, String typeName, String uid, Object id, int version, int previousVersion, int routingHash, long timeToLive, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID)
void	AbstractReplicationNotificationInEntryHandler.inEntryLeaseExpired(IReplicationInContext context, IEntryPacket entryPacket)
void	AbstractReplicationNotificationInEntryHandler.inEntryLeaseExpiredByUID(IReplicationInContext context, String className, String uid, boolean isTransient, OperationID operationID)
void	AbstractReplicationNotificationInEntryHandler.inRemoveEntry(IReplicationInContext context, IEntryPacket entryPacket)
void	AbstractReplicationNotificationInEntryHandler.inRemoveEntryByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, OperationID operationID)
void	ReplicationNotificationInTransactionEntryHandler.inTransaction(IReplicationInContext context, ITransactionInContext transactionContext)
void	ReplicationNotificationInTransactionEntryHandler.inTransactionAbort(IReplicationInContext context, ITransactionInContext transactionContext)
void	ReplicationNotificationInTransactionEntryHandler.inTransactionCommit(IReplicationInContext context, ITransactionInContext transactionContext)
void	ReplicationNotificationInTransactionEntryHandler.inTransactionPrepare(IReplicationInContext context, ITransactionInContext transactionContext)
void	AbstractReplicationNotificationInEntryHandler.inUpdateEntry(IReplicationInContext context, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate, boolean overrideVersion, short flags)
void	AbstractReplicationNotificationInEntryHandler.inWriteEntry(IReplicationInContext context, IEntryPacket entryPacket)

Uses of IReplicationInContext in com.gigaspaces.internal.server.space.events

Methods in com.gigaspaces.internal.server.space.events with parameters of type IReplicationInContext

Modifier and Type	Method and Description
void	NotifyBackupLog.inNotificationSent(IReplicationInContext context, OperationID operationId)

Uses of IReplicationInContext in com.gigaspaces.internal.sync

Constructors in com.gigaspaces.internal.sync with parameters of type IReplicationInContext

Constructor and Description
ConsolidationParticipantDataImpl(List<DataSyncOperation> dataItems, TransactionParticipantMetaData metaData, IReplicationInContext context)

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

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

Modifier and Type	Method and Description
void	MirrorReplicationInEntryHandler.afterConsumption(IReplicationInContext context, boolean successful, long lastProcessedKey)
void	MirrorReplicationInEntryHandler.beforeConsume(IReplicationInContext context)
void	MirrorReplicationInEntryHandler.inChangeEntry(IReplicationInContext context, String typeName, String uid, Object id, int version, int previousVersion, int routingHash, long timeToLive, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID)
void	MirrorReplicationMetadataEventHandler.inDataTypeAddIndex(IReplicationInContext context, AddTypeIndexesRequestInfo requestInfo)
void	MirrorReplicationMetadataEventHandler.inDataTypeIntroduce(IReplicationInContext context, ITypeDesc typeDesc)
void	MirrorReplicationInEntryHandler.inRemoveEntry(IReplicationInContext context, IEntryPacket entryPacket)
void	MirrorReplicationInEntryHandler.inRemoveEntryByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, OperationID operationID)
void	MirrorReplicationInAggregatedTransactionHandler.inTransaction(IReplicationInContext context, ITransactionInContext transactionContext)
void	MirrorReplicationInTransactionHandler.inTransaction(IReplicationInContext context, ITransactionInContext transactionContext)
void	MirrorReplicationInAggregatedTransactionHandler.inTransactionAbort(IReplicationInContext context, ITransactionInContext transactionContext)
void	MirrorReplicationInTransactionHandler.inTransactionAbort(IReplicationInContext context, ITransactionInContext transactionContext)
void	MirrorReplicationInAggregatedTransactionHandler.inTransactionCommit(IReplicationInContext context, ITransactionInContext transactionContext)
void	MirrorReplicationInTransactionHandler.inTransactionCommit(IReplicationInContext context, ITransactionInContext transactionContext)
void	MirrorReplicationInAggregatedTransactionHandler.inTransactionPrepare(IReplicationInContext context, ITransactionInContext transactionContext)
void	MirrorReplicationInTransactionHandler.inTransactionPrepare(IReplicationInContext context, ITransactionInContext transactionContext)
void	MirrorReplicationInEntryHandler.inUpdateEntry(IReplicationInContext context, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate, boolean overrideVersion, short flags)
void	MirrorReplicationInEntryHandler.inWriteEntry(IReplicationInContext context, IEntryPacket entryPacket)