com.gigaspaces.internal.cluster.node.impl

Class ReplicationNodeInFacade

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.ReplicationNodeInFacade

All Implemented Interfaces:

IReplicationInBatchConsumptionHandler, IReplicationInDataTypeCreatedHandler, IReplicationInDataTypeIndexAddedHandler, IReplicationInEntryHandler, IReplicationInEntryLeaseCancelledHandler, IReplicationInEntryLeaseExpiredHandler, IReplicationInEntryLeaseExtendedHandler, IReplicationInEvictEntryHandler, IReplicationInFacade, IReplicationInNotificationSentHandler, IReplicationInNotifyTemplateCreatedHandler, IReplicationInNotifyTemplateLeaseExpiredHandler, IReplicationInNotifyTemplateLeaseExtendedHandler, IReplicationInNotifyTemplateRemovedHandler, IReplicationInTransactionHandler

public class ReplicationNodeInFacade
extends Object
implements IReplicationInFacade

A component that belongs to the ReplicationNode that implements the IReplicationInFacade

Since:

8.0

Author:

eitany

Constructor Summary

Constructors

Constructor and Description
ReplicationNodeInFacade(ReplicationNodeGroupsHolder groupsHolder)

Method Summary

Modifier and Type	Method and Description
void	afterConsumption(IReplicationInContext context, boolean successful, long lastProcessedKey)
void	beforeConsume(IReplicationInContext context)
void	consumePendingOperationsInBatch(IReplicationInBatchContext context) Called after all the incoming replication events for the current batch passed through the corresponding event handlers.
IReplicationSourceGroup	getReplicationSourceGroup(String groupName)
void	inCancelEntryLease(IReplicationInContext context, IEntryPacket entryPacket)
void	inCancelEntryLeaseByUID(IReplicationInContext context, String className, String uid, boolean isTransient, int routingValue)
void	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	inDataTypeAddIndex(IReplicationInContext context, AddTypeIndexesRequestInfo addIndexRequestInfo)
void	inDataTypeIntroduce(IReplicationInContext context, ITypeDesc typeDescriptor)
void	inEntryLeaseExpired(IReplicationInContext context, IEntryPacket entryPacket)
void	inEntryLeaseExpiredByUID(IReplicationInContext context, String className, String uid, boolean isTransient, OperationID operationID)
void	inEvictEntry(IReplicationInContext context, String uid, boolean isTransient, OperationID operationID)
void	inExtendEntryLeasePeriod(IReplicationInContext context, String className, String uid, boolean isTransient, long lease, int routingValue)
void	inExtendNotifyTemplateLeasePeriod(IReplicationInContext context, String className, String uid, long lease)
void	inInsertNotifyTemplate(IReplicationInContext context, ITemplatePacket templatePacket, String uidToOperateBy, NotifyInfo notifyInfo)
void	inNotificationSent(IReplicationInContext context, OperationID operationId)
void	inNotifyTemplateLeaseExpired(IReplicationInContext context, String className, String uid, OperationID operationID)
void	inRemoveEntry(IReplicationInContext context, IEntryPacket entryPacket)
void	inRemoveEntryByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, OperationID operationID)
void	inRemoveNotifyTemplate(IReplicationInContext context, String className, String uid)
void	inTransaction(IReplicationInContext context, ITransactionInContext transactionContext) Handles one phase commit transaction (single participant)
void	inTransactionAbort(IReplicationInContext context, ITransactionInContext transactionContext) Handle abort stage of two phase committed transaction
void	inTransactionCommit(IReplicationInContext context, ITransactionInContext transactionContext) Handle commit stage of two phase committed transaction
void	inTransactionPrepare(IReplicationInContext context, ITransactionInContext transactionContext) Handle prepare stage of two phase committed transaction
void	inUpdateEntry(IReplicationInContext context, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate, boolean overrideVersion, short flags)
void	inWriteEntry(IReplicationInContext context, IEntryPacket entryPacket)
void	setInBatchConsumptionHandler(IReplicationInBatchConsumptionHandler inBatchConsumptionHandler)
void	setInDataTypeCreatedHandler(IReplicationInDataTypeCreatedHandler handler)
void	setInDataTypeIndexAddedHandler(IReplicationInDataTypeIndexAddedHandler handler)
void	setInEntryHandler(IReplicationInEntryHandler handler)
void	setInEntryLeaseCancelledHandler(IReplicationInEntryLeaseCancelledHandler inCancelEntryLeaseHandler)
void	setInEntryLeaseExpiredHandler(IReplicationInEntryLeaseExpiredHandler inEntryLeaseExpiredHandler)
void	setInEntryLeaseExtendedHandler(IReplicationInEntryLeaseExtendedHandler handler)
void	setInEvictEntryHandler(IReplicationInEvictEntryHandler inEvictEntryHandler)
void	setInNotificationSentHandler(IReplicationInNotificationSentHandler handler)
void	setInNotifyTemplateCreatedHandler(IReplicationInNotifyTemplateCreatedHandler handler)
void	setInNotifyTemplateLeaseExpiredHandler(IReplicationInNotifyTemplateLeaseExpiredHandler inNotifyTemplateLeaseExpiredHandler)
void	setInNotifyTemplateLeaseExtendedHandler(IReplicationInNotifyTemplateLeaseExtendedHandler handler)
void	setInNotifyTemplateRemovedHandler(IReplicationInNotifyTemplateRemovedHandler handler)
void	setInTransactionHandler(IReplicationInTransactionHandler handler)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationNodeInFacade

public ReplicationNodeInFacade(ReplicationNodeGroupsHolder groupsHolder)

Method Detail

inCancelEntryLease

public void inCancelEntryLease(IReplicationInContext context,
                               IEntryPacket entryPacket)
                        throws Exception

Specified by:

inCancelEntryLease in interface IReplicationInEntryLeaseCancelledHandler

Throws:

Exception

inCancelEntryLeaseByUID

public void inCancelEntryLeaseByUID(IReplicationInContext context,
                                    String className,
                                    String uid,
                                    boolean isTransient,
                                    int routingValue)
                             throws Exception

Specified by:

inCancelEntryLeaseByUID in interface IReplicationInEntryLeaseCancelledHandler

Throws:

Exception

inEntryLeaseExpired

public void inEntryLeaseExpired(IReplicationInContext context,
                                IEntryPacket entryPacket)

Specified by:

inEntryLeaseExpired in interface IReplicationInEntryLeaseExpiredHandler

inEntryLeaseExpiredByUID

public void inEntryLeaseExpiredByUID(IReplicationInContext context,
                                     String className,
                                     String uid,
                                     boolean isTransient,
                                     OperationID operationID)

Specified by:

inEntryLeaseExpiredByUID in interface IReplicationInEntryLeaseExpiredHandler

inNotifyTemplateLeaseExpired

public void inNotifyTemplateLeaseExpired(IReplicationInContext context,
                                         String className,
                                         String uid,
                                         OperationID operationID)

Specified by:

inNotifyTemplateLeaseExpired in interface IReplicationInNotifyTemplateLeaseExpiredHandler

inEvictEntry

public void inEvictEntry(IReplicationInContext context,
                         String uid,
                         boolean isTransient,
                         OperationID operationID)
                  throws Exception

Specified by:

inEvictEntry in interface IReplicationInEvictEntryHandler

Throws:

Exception

inExtendEntryLeasePeriod

public void inExtendEntryLeasePeriod(IReplicationInContext context,
                                     String className,
                                     String uid,
                                     boolean isTransient,
                                     long lease,
                                     int routingValue)
                              throws Exception

Specified by:

inExtendEntryLeasePeriod in interface IReplicationInEntryLeaseExtendedHandler

Throws:

Exception

inExtendNotifyTemplateLeasePeriod

public void inExtendNotifyTemplateLeasePeriod(IReplicationInContext context,
                                              String className,
                                              String uid,
                                              long lease)
                                       throws Exception

Specified by:

inExtendNotifyTemplateLeasePeriod in interface IReplicationInNotifyTemplateLeaseExtendedHandler

Throws:

Exception

inInsertNotifyTemplate

public void inInsertNotifyTemplate(IReplicationInContext context,
                                   ITemplatePacket templatePacket,
                                   String uidToOperateBy,
                                   NotifyInfo notifyInfo)
                            throws Exception

Specified by:

inInsertNotifyTemplate in interface IReplicationInNotifyTemplateCreatedHandler

Throws:

Exception

inNotificationSent

public void inNotificationSent(IReplicationInContext context,
                               OperationID operationId)
                        throws Exception

Specified by:

inNotificationSent in interface IReplicationInNotificationSentHandler

Throws:

Exception

inRemoveEntry

public void inRemoveEntry(IReplicationInContext context,
                          IEntryPacket entryPacket)
                   throws Exception

Specified by:

inRemoveEntry in interface IReplicationInEntryHandler

Throws:

Exception

inRemoveEntryByUID

public void inRemoveEntryByUID(IReplicationInContext context,
                               String typeName,
                               String uid,
                               boolean isTransient,
                               OperationID operationID)
                        throws Exception

Specified by:

inRemoveEntryByUID in interface IReplicationInEntryHandler

Throws:

Exception

inRemoveNotifyTemplate

public void inRemoveNotifyTemplate(IReplicationInContext context,
                                   String className,
                                   String uid)

Specified by:

inRemoveNotifyTemplate in interface IReplicationInNotifyTemplateRemovedHandler

inTransaction

public void inTransaction(IReplicationInContext context,
                          ITransactionInContext transactionContext)
                   throws Exception

Description copied from interface: IReplicationInTransactionHandler

Handles one phase commit transaction (single participant)

Specified by:

inTransaction in interface IReplicationInTransactionHandler

Throws:

Exception

inTransactionPrepare

public void inTransactionPrepare(IReplicationInContext context,
                                 ITransactionInContext transactionContext)
                          throws Exception

Description copied from interface: IReplicationInTransactionHandler

Handle prepare stage of two phase committed transaction

Specified by:

inTransactionPrepare in interface IReplicationInTransactionHandler

Throws:

Exception

inTransactionCommit

public void inTransactionCommit(IReplicationInContext context,
                                ITransactionInContext transactionContext)
                         throws Exception

Description copied from interface: IReplicationInTransactionHandler

Handle commit stage of two phase committed transaction

Specified by:

inTransactionCommit in interface IReplicationInTransactionHandler

Throws:

Exception

inTransactionAbort

public void inTransactionAbort(IReplicationInContext context,
                               ITransactionInContext transactionContext)
                        throws Exception

Description copied from interface: IReplicationInTransactionHandler

Handle abort stage of two phase committed transaction

Specified by:

inTransactionAbort in interface IReplicationInTransactionHandler

Throws:

Exception

inUpdateEntry

public void inUpdateEntry(IReplicationInContext context,
                          IEntryPacket entryPacket,
                          IEntryPacket oldEntryPacket,
                          boolean partialUpdate,
                          boolean overrideVersion,
                          short flags)
                   throws Exception

Specified by:

inUpdateEntry in interface IReplicationInEntryHandler

Throws:

Exception

inChangeEntry

public void inChangeEntry(IReplicationInContext context,
                          String typeName,
                          String uid,
                          Object id,
                          int version,
                          int previousVersion,
                          int routingHash,
                          long timeToLive,
                          Collection<SpaceEntryMutator> mutators,
                          boolean isTransient,
                          OperationID operationID)
                   throws Exception

Specified by:

inChangeEntry in interface IReplicationInEntryHandler

Throws:

Exception

inWriteEntry

public void inWriteEntry(IReplicationInContext context,
                         IEntryPacket entryPacket)
                  throws Exception

Specified by:

inWriteEntry in interface IReplicationInEntryHandler

Throws:

Exception

inDataTypeAddIndex

public void inDataTypeAddIndex(IReplicationInContext context,
                               AddTypeIndexesRequestInfo addIndexRequestInfo)
                        throws Exception

Specified by:

inDataTypeAddIndex in interface IReplicationInDataTypeIndexAddedHandler

Throws:

Exception

inDataTypeIntroduce

public void inDataTypeIntroduce(IReplicationInContext context,
                                ITypeDesc typeDescriptor)
                         throws Exception

Specified by:

inDataTypeIntroduce in interface IReplicationInDataTypeCreatedHandler

Throws:

Exception

consumePendingOperationsInBatch

public void consumePendingOperationsInBatch(IReplicationInBatchContext context)
                                     throws Exception

Description copied from interface: IReplicationInBatchConsumptionHandler

Called after all the incoming replication events for the current batch passed through the corresponding event handlers. Any pending unconsumed events should be consumed here.

Specified by:

consumePendingOperationsInBatch in interface IReplicationInBatchConsumptionHandler

Throws:

Exception

setInEntryLeaseCancelledHandler

public void setInEntryLeaseCancelledHandler(IReplicationInEntryLeaseCancelledHandler inCancelEntryLeaseHandler)

setInEntryLeaseExpiredHandler

public void setInEntryLeaseExpiredHandler(IReplicationInEntryLeaseExpiredHandler inEntryLeaseExpiredHandler)

setInNotifyTemplateLeaseExpiredHandler

public void setInNotifyTemplateLeaseExpiredHandler(IReplicationInNotifyTemplateLeaseExpiredHandler inNotifyTemplateLeaseExpiredHandler)

setInEvictEntryHandler

public void setInEvictEntryHandler(IReplicationInEvictEntryHandler inEvictEntryHandler)

setInEntryLeaseExtendedHandler

public void setInEntryLeaseExtendedHandler(IReplicationInEntryLeaseExtendedHandler handler)

setInNotifyTemplateLeaseExtendedHandler

public void setInNotifyTemplateLeaseExtendedHandler(IReplicationInNotifyTemplateLeaseExtendedHandler handler)

setInNotifyTemplateCreatedHandler

public void setInNotifyTemplateCreatedHandler(IReplicationInNotifyTemplateCreatedHandler handler)

setInNotificationSentHandler

public void setInNotificationSentHandler(IReplicationInNotificationSentHandler handler)

setInNotifyTemplateRemovedHandler

public void setInNotifyTemplateRemovedHandler(IReplicationInNotifyTemplateRemovedHandler handler)

setInTransactionHandler

public void setInTransactionHandler(IReplicationInTransactionHandler handler)

setInEntryHandler

public void setInEntryHandler(IReplicationInEntryHandler handler)

setInDataTypeCreatedHandler

public void setInDataTypeCreatedHandler(IReplicationInDataTypeCreatedHandler handler)

setInDataTypeIndexAddedHandler

public void setInDataTypeIndexAddedHandler(IReplicationInDataTypeIndexAddedHandler handler)

setInBatchConsumptionHandler

public void setInBatchConsumptionHandler(IReplicationInBatchConsumptionHandler inBatchConsumptionHandler)

getReplicationSourceGroup

public IReplicationSourceGroup getReplicationSourceGroup(String groupName)

Specified by:

getReplicationSourceGroup in interface IReplicationInFacade

afterConsumption

public void afterConsumption(IReplicationInContext context,
                             boolean successful,
                             long lastProcessedKey)

Specified by:

afterConsumption in interface IReplicationInEntryHandler

beforeConsume

public void beforeConsume(IReplicationInContext context)

Specified by:

beforeConsume in interface IReplicationInEntryHandler