public class SubscriptionManager extends FabricThread.Impl
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
FabricThread.Impl
Modifier and Type | Field and Description |
---|---|
static boolean |
ENABLE_OBJECT_UPDATES |
Constructor and Description |
---|
SubscriptionManager(java.lang.String store,
TransactionManager tm) |
Modifier and Type | Method and Description |
---|---|
void |
notifyUpdate(LongSet onums,
RemoteWorker worker)
Notifies the subscription manager that a set of objects has been updated by a
particular worker.
|
void |
run() |
void |
subscribe(long onum,
RemoteWorker worker,
boolean dissemSubscribe)
Subscribes the given worker to the given onum.
|
getTransactionManager, setTransactionManager
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
public static final boolean ENABLE_OBJECT_UPDATES
public SubscriptionManager(java.lang.String store, TransactionManager tm)
tm
- The transaction manager corresponding to the store for which
subscriptions are to be managed.public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public void subscribe(long onum, RemoteWorker worker, boolean dissemSubscribe)
dissemSubscribe
- If true, then the given subscriber will be subscribed as a
dissemination node; otherwise it will be subscribed as a worker.public void notifyUpdate(LongSet onums, RemoteWorker worker)