com.gigaspaces.internal.cluster.node.impl.gateway.sink

Class LocalClusterReplicationEntryLeaseEventHandler

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.gateway.sink.AbstractLocalClusterReplicationInHandler

com.gigaspaces.internal.cluster.node.impl.gateway.sink.LocalClusterReplicationEntryLeaseEventHandler

All Implemented Interfaces:

IReplicationInEntryLeaseCancelledHandler, IReplicationInEntryLeaseExtendedHandler

public class LocalClusterReplicationEntryLeaseEventHandler
extends AbstractLocalClusterReplicationInHandler
implements IReplicationInEntryLeaseCancelledHandler, IReplicationInEntryLeaseExtendedHandler

Since:

9.1

Author:

yael

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.sink.AbstractLocalClusterReplicationInHandler

_config, _spaceProxy

Method Summary

Modifier and Type	Method and Description
void	inCancelEntryLease(IReplicationInContext context, IEntryPacket entryPacket)
void	inCancelEntryLeaseByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, int routingValue)
void	inExtendEntryLeasePeriod(IReplicationInContext context, String typeName, String uid, boolean isTransient, long lease, int routingValue)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.sink.AbstractLocalClusterReplicationInHandler

execute, executeIfUidPresent, executeTransactional, extractSourceGatewayName, getSpaceProxy, handleChangeEntry, handleRemoveEntry, handleRemoveEntryByUid, handleUpdateEntry, handleWriteEntry, invokeConflictResolver

Methods inherited from class java.lang.Object

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

Method Detail

inExtendEntryLeasePeriod

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

Specified by:

inExtendEntryLeasePeriod in interface IReplicationInEntryLeaseExtendedHandler

Throws:

Exception

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 typeName,
                                    String uid,
                                    boolean isTransient,
                                    int routingValue)
                             throws Exception

Specified by:

inCancelEntryLeaseByUID in interface IReplicationInEntryLeaseCancelledHandler

Throws:

Exception