com.gigaspaces.internal.server.storage

Class NotifyTemplateHolder

java.lang.Object

com.gigaspaces.internal.server.storage.AbstractSpaceItem

com.gigaspaces.internal.server.storage.TemplateHolder

com.gigaspaces.internal.server.storage.NotifyTemplateHolder

All Implemented Interfaces:

IEntryHolder, ISpaceItem, ITemplateHolder, Textualizable, ILockedSubject, ILockObject, ISelfLockingSubject

public class NotifyTemplateHolder
extends TemplateHolder

this class contains all the information relevant to a notify template.

Since:

6.0

Version:

1.0

Author:

asy ronen

Constructor Summary

Constructors

Constructor and Description
NotifyTemplateHolder(IServerTypeDesc typeDesc, ITemplatePacket template, String uid, long expirationTime, long eventId, NotifyInfo info, boolean isFifo)

Method Summary

Modifier and Type	Method and Description
void	addPendingEvent(BatchNotifyExecutor.EventHolder event)
void	clearPendingEvents()
boolean	containsNotifyType(NotifyActionType notifyType)
RemoteEvent	createRemoteEvent(IEntryHolder entryHolder, IEntryHolder oldEntryHolder, NotifyActionType notifyType, OperationID operationID, IJSpace spaceProxy, boolean fromReplication)
RemoteEvent	createRemoteEvent(IEntryHolder entryHolder, NotifyActionType notifyType, OperationID operationID, IJSpace spaceProxy, boolean fromReplication)
void	dump(org.slf4j.Logger logger, String msg)
void	finnishedNotify()
long	getBatchOrder()
int	getBatchSize()
long	getBatchTime()
long	getEventId()
INotifyDelegatorFilter	getFilter()
ITemplatePacket	getGenerationTemplate()
MarshalledObject	getHandback()
NotifyInfo	getNotifyInfo()
int	getNotifyType()
int	getPendingEventsSize()
RemoteEventListener	getREListener()
long	getSequenceNumber()
int	getSpaceItemType()
boolean	isBatching()
boolean	isBroadcast()
boolean	isGuaranteedNotification()
boolean	isMatchByID() Return true whether this template should match by uid only (if such provided) or with full match regardless present if uid.
boolean	isNotifyTemplate()
boolean	isReplicateNotify()
boolean	isTriggerNotify()
BatchNotifyExecutor.EventHolder	peekPendingEvent()
BatchNotifyExecutor.EventHolder	pollPendingEvent()
boolean	quickReject(Context context, FifoSearch fifoSearch, ServerTransaction txn, NotifyContextsHolder notifyContextsHolder)
void	setBatchOrder(long _batchOrder)
void	setREListener(RemoteEventListener listener)
boolean	trySetNotifyInProgress()

Methods inherited from class com.gigaspaces.internal.server.storage.TemplateHolder

addEntryWaitingForTemplate, addReadLockOwner, addTemplateWaitingForEntry, anyReadLockXtn, canFinishBatchOperation, clearReadLockOwners, createCopy, createDummy, getAfterOpFilterCode, getAggregatorContext, getAnswerHolder, getBatchOperationContext, getChangeExpiration, getCopyOfTemplatesWaitingForEntry, getCustomQuery, getEntriesWaitingForTemplate, getEntryData, getEntryId, getExplainPlan, getExtendedMatchCodes, getExternalEntryImplClassName, getExternalLockObject, getFifoThreadPartition, getFifoXtnNumberOnSearchStart, getFilterManager, getID, getMaster, getMultipleIdsContext, getMultipleUids, getMutators, getOperationID, getOperationModifiers, getOrdinalForEntryByIdMultipleOperation, getOriginalEntryHolder, getPendingFifoSearchObject, getPreviousVersion, getProjectionTemplate, getQueryResultType, getRangeInclusion, getRangeValue, getReadLockOwners, getRejectedOperationEntry, getRejectedOpOriginalException, getResponseContext, getServerIteratorInfo, getShadow, getSpaceContext, getTemplateEntryData, getTemplateOperation, getTemplatesWaitingForEntry, getTokenFieldNumber, getTxnEntryData, getUidToOperateBy, getUpdatedEntry, getUpdateOperationEntry, getUpfdateOrWriteContext, getWriteLockOperation, getWriteLockOwner, getWriteLockTransaction, getXidOriginated, getXidOriginatedTransaction, hasAnswer, hasExtendedMatchCodes, hasPendingRemoteException, hasShadow, isAllValuesIndexSqlQuery, isBatchOperation, isBlobStoreEntry, isChange, isChangeById, isChangeMultiple, isChangeQuery, isClear, isDirtyReadRequested, isEmptyTemplate, isEntryUnderWriteLockXtn, isExclusiveReadLockOperation, isExpirationTimeSet, isExpired, isExpired, isExplicitInsertionToExpirationManager, isFifoGroupPoll, isFifoSearch, isFifoTemplate, isIdQuery, isIfExist, isInCache, isInExpirationManager, isInitialFifoSearchActive, isInitialIfExistSearchActive, isInitiatedEvictionOperation, isMaybeUnderXtn, isMemoryOnlySearch, isMultipleIdsOperation, isNonBlockingRead, isOptimizedForBlobStoreClear, isOptimizedForBlobStoreOp, isReadCommittedRequested, isReadMultiple, isReadOperation, isReRegisterLeaseOnUpdate, isReturnOnlyUid, isSameEntryInstance, isSecondPhase, isServerIterator, isSetSingleOperationExtendedErrorInfo, isSqlQuery, isTakeMultiple, isTakeOperation, isUnstable, isUpdateMultiple, isUpdateOperation, isWriteLockOperation, match, quickReject, removeEntryWaitingForTemplate, removePendingFifoSearchObject, removeReadLockOwner, removeTemplateWaitingForEntry, resetEntryXtnInfo, resetFifoXtnNumberOnSearchStart, resetInitialFifoSearchActive, resetInitialIfExistSearchActive, resetWriteLockOwner, resetXidOriginated, restoreUpdateXtnRollback, setAggregatorContext, setAnswerHolder, setBatchOperationContext, setChangeExpiration, setCustomQuery, setExpirationTime, setExpirationTime, setFieldsValues, setFifoThreadPartition, setFifoXtnNumberOnSearchStart, setForAfterOperationFilter, setID, setIfExistForChange, setInCache, setInExpirationManager, setInitialFifoSearchActive, setInitialIfExistSearchActive, setMemoryOnlySearch, setMultipleIdsContext, setMutators, setNonBlockingRead, setOrdinalForEntryByIdMultipleOperation, setOtherUpdateUnderXtnEntry, setPendingFifoSearchObject, setPendingRemoteException, setRejectedOpOriginalExceptionAndEntry, setReRegisterLeaseOnUpdate, setSecondPhase, setServerIteratorInfo, setUidToOperateBy, setunStable, setUpdatedEntry, setUpdateOrWriteContext, setWriteLockOperation, setWriteLockOwnerAndOperation, setWriteLockOwnerAndOperation, setWriteLockOwnerOperationAndShadow, toSQLQuery, updateEntryData, updateVersionAndExpiration

Methods inherited from class com.gigaspaces.internal.server.storage.AbstractSpaceItem

getClassName, getEvictableLockObject, getExpirationTime, getOrder, getRoutingValue, getSCN, getServerTypeDesc, getUID, getVersionID, hasShadow, hasWaitingFor, isDeleted, isDummyLease, isDummyLeaseAndNotExpired, isLockSubject, isShadow, isTransient, setDeleted, setDummyLease, setHasWaitingFor, setMaybeUnderXtn, setOrder, setSCN, setTransient, setUID, toString, toText

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.internal.server.storage.ITemplateHolder

getExpirationTime, getLockSubjectType

Methods inherited from interface com.gigaspaces.internal.server.storage.IEntryHolder

getOrder, getRoutingValue, hasShadow, isHollowEntry, isShadow, setOrder, setSCN, setTransient, setUID

Methods inherited from interface com.gigaspaces.internal.server.storage.ISpaceItem

getClassName, getSCN, getServerTypeDesc, hasWaitingFor, isDeleted, isDummyLease, isDummyLeaseAndNotExpired, isTransient, setDeleted, setDummyLease, setHasWaitingFor, setMaybeUnderXtn

Methods inherited from interface com.j_spaces.kernel.locks.ILockObject

isLockSubject

Methods inherited from interface com.j_spaces.kernel.locks.ILockedSubject

getUID

Constructor Detail

NotifyTemplateHolder

public NotifyTemplateHolder(IServerTypeDesc typeDesc,
                            ITemplatePacket template,
                            String uid,
                            long expirationTime,
                            long eventId,
                            NotifyInfo info,
                            boolean isFifo)

Method Detail

isNotifyTemplate

public boolean isNotifyTemplate()

Specified by:

isNotifyTemplate in interface ITemplateHolder

Overrides:

isNotifyTemplate in class TemplateHolder

getSpaceItemType

public int getSpaceItemType()

getEventId

public long getEventId()

getNotifyInfo

public NotifyInfo getNotifyInfo()

getGenerationTemplate

public ITemplatePacket getGenerationTemplate()

getSequenceNumber

public long getSequenceNumber()

isTriggerNotify

public boolean isTriggerNotify()

isReplicateNotify

public boolean isReplicateNotify()

isGuaranteedNotification

public boolean isGuaranteedNotification()

isBroadcast

public boolean isBroadcast()

getNotifyType

public int getNotifyType()

Specified by:

getNotifyType in interface IEntryHolder

Overrides:

getNotifyType in class AbstractSpaceItem

containsNotifyType

public boolean containsNotifyType(NotifyActionType notifyType)

getHandback

public MarshalledObject getHandback()

Specified by:

getHandback in interface IEntryHolder

Overrides:

getHandback in class AbstractSpaceItem

getFilter

public INotifyDelegatorFilter getFilter()

getREListener

public RemoteEventListener getREListener()

setREListener

public void setREListener(RemoteEventListener listener)

addPendingEvent

public void addPendingEvent(BatchNotifyExecutor.EventHolder event)

clearPendingEvents

public void clearPendingEvents()

pollPendingEvent

public BatchNotifyExecutor.EventHolder pollPendingEvent()

peekPendingEvent

public BatchNotifyExecutor.EventHolder peekPendingEvent()

getPendingEventsSize

public int getPendingEventsSize()

isBatching

public boolean isBatching()

getBatchSize

public int getBatchSize()

getBatchTime

public long getBatchTime()

getBatchOrder

public long getBatchOrder()

setBatchOrder

public void setBatchOrder(long _batchOrder)

trySetNotifyInProgress

public boolean trySetNotifyInProgress()

finnishedNotify

public void finnishedNotify()

dump

public void dump(org.slf4j.Logger logger,
                 String msg)

Overrides:

dump in class TemplateHolder

isMatchByID

public boolean isMatchByID()

Return true whether this template should match by uid only (if such provided) or with full match regardless present if uid.

Specified by:

isMatchByID in interface ITemplateHolder

Overrides:

isMatchByID in class TemplateHolder

createRemoteEvent

public RemoteEvent createRemoteEvent(IEntryHolder entryHolder,
                                     NotifyActionType notifyType,
                                     OperationID operationID,
                                     IJSpace spaceProxy,
                                     boolean fromReplication)

createRemoteEvent

public RemoteEvent createRemoteEvent(IEntryHolder entryHolder,
                                     IEntryHolder oldEntryHolder,
                                     NotifyActionType notifyType,
                                     OperationID operationID,
                                     IJSpace spaceProxy,
                                     boolean fromReplication)

quickReject

public boolean quickReject(Context context,
                           FifoSearch fifoSearch,
                           ServerTransaction txn,
                           NotifyContextsHolder notifyContextsHolder)