class TransactableEventWatcher extends EventRegistrationWatcher implements Transactable
Modifier and Type | Field and Description |
---|---|
private RemoteEventListener |
listener
The listener that should be notified of matches
|
private Txn |
txn
The transaction (represented as a
Txn ) this
event registration is associated with. |
cookie, eventID, expiration, handback, lastSeqNumDelivered
startOrdinal
ABORTED, ACTIVE, COMMITTED, NOTCHANGED, PREPARED, VOTING
Constructor and Description |
---|
TransactableEventWatcher(long timestamp,
long startOrdinal,
Uuid cookie,
MarshalledObject handback,
long eventID,
RemoteEventListener listener,
Txn txn)
Create a new
TransactableEventWatcher . |
Modifier and Type | Method and Description |
---|---|
void |
abort(TransactableMgr mgr,
OutriggerServerImpl space)
Just need to terminate this registration.
|
void |
commit(TransactableMgr mgr,
OutriggerServerImpl space)
This should never happen since we always return
NOTCHANGED from prepare . |
(package private) RemoteEventListener |
getListener(ProxyPreparer preparer)
Return the remote listener associated with this
EventRegistrationWatcher . |
(package private) boolean |
isInterested(EntryTransition transition,
long ordinal)
Return
true if this watcher cares about a given
visibility transition. |
int |
prepare(TransactableMgr mgr,
OutriggerServerImpl space)
Just need to terminate this registration and return
NOTCHANGED . |
addTemplateHandle, cancel, cleanup, getCookie, getExpiration, process, removeIfExpired, setExpiration
compareTo
private final RemoteEventListener listener
private final Txn txn
Txn
) this
event registration is associated with.TransactableEventWatcher(long timestamp, long startOrdinal, Uuid cookie, MarshalledObject handback, long eventID, RemoteEventListener listener, Txn txn)
TransactableEventWatcher
.timestamp
- the value that is used
to sort TransitionWatcher
s.startOrdinal
- the highest ordinal associated
with operations that are considered to have occurred
before the operation associated with this watcher.cookie
- The unique identifier associated
with this watcher. Must not be null
.handback
- The handback object that
should be sent along with event
notifications to the the listener.eventID
- The event ID for event type
represented by this object.listener
- The object to notify of
matches.txn
- The transaction this registration is
associated with.NullPointerException
- if the cookie
,
listener
, or txn
arguments are
null
.boolean isInterested(EntryTransition transition, long ordinal)
TransitionWatcher
true
if this watcher cares about a given
visibility transition. Assumes the transitioning entry matches
the template in the TemplateHandle
associated with
this watcher. This method should return a value even if the
expiration time has been reached or remove
has
been called. This call should not obtain any locks.isInterested
in class TransitionWatcher
transition
- A EntryTransition
that
describes the transition and what
entry is transitioning. This method
will assume that transition.getHandle
returns a non-null value.ordinal
- The ordinal associated with transition
.true
if this watcher is interested
in the indicated transition and false
otherwise.RemoteEventListener getListener(ProxyPreparer preparer)
EventRegistrationWatcher
EventRegistrationWatcher
. Optionally
prepare the listener if it has been recovered from
the store and not yet re-prepared.getListener
in class EventRegistrationWatcher
EventRegistrationWatcher
.public int prepare(TransactableMgr mgr, OutriggerServerImpl space)
NOTCHANGED
.prepare
in interface Transactable
public void commit(TransactableMgr mgr, OutriggerServerImpl space)
NOTCHANGED
from prepare
.commit
in interface Transactable
public void abort(TransactableMgr mgr, OutriggerServerImpl space)
abort
in interface Transactable
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.