Package com.orientechnologies.orient.core.query.live

Class OLiveQueryHookV2

java.lang.Object

com.orientechnologies.orient.core.query.live.OLiveQueryHookV2

public class OLiveQueryHookV2
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OLiveQueryHookV2.OLiveQueryOp
static class	OLiveQueryHookV2.OLiveQueryOps

Constructor Summary

Constructors

Constructor	Description
OLiveQueryHookV2()

Method Summary

Modifier and Type	Method	Description
static void	addOp(ODocument iDocument, byte iType, ODatabaseDocument database)
static OResultInternal	calculateBefore(ODocument iDocument, Set<String> projectionsToLoad)
static OLiveQueryHookV2.OLiveQueryOps	getOpsReference(ODatabaseInternal db)
static void	notifyForTxChanges(ODatabaseDocument database)
static void	removePendingDatabaseOps(ODatabaseDocument database)
static Integer	subscribe(Integer token, OLiveQueryListenerV2 iListener, ODatabaseInternal db)
static Object	unboxRidbags(Object value)
static void	unsubscribe(Integer id, ODatabaseInternal db)

Methods inherited from class java.lang.Object

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

Constructor Details

OLiveQueryHookV2

public OLiveQueryHookV2()

Method Details

getOpsReference

public static OLiveQueryHookV2.OLiveQueryOps getOpsReference(ODatabaseInternal db)

subscribe

public static Integer subscribe(Integer token,
 OLiveQueryListenerV2 iListener,
 ODatabaseInternal db)

unsubscribe

public static void unsubscribe(Integer id,
 ODatabaseInternal db)

notifyForTxChanges

public static void notifyForTxChanges(ODatabaseDocument database)

removePendingDatabaseOps

public static void removePendingDatabaseOps(ODatabaseDocument database)

addOp

public static void addOp(ODocument iDocument,
 byte iType,
 ODatabaseDocument database)

calculateBefore

public static OResultInternal calculateBefore(ODocument iDocument,
 Set<String> projectionsToLoad)

unboxRidbags

public static Object unboxRidbags(Object value)