public class DelegatingObservationDispatcher extends Object
| Constructor and Description |
|---|
DelegatingObservationDispatcher() |
| Modifier and Type | Method and Description |
|---|---|
void |
addDispatcher(ObservationDispatcher dispatcher)
Adds a new observation dispatcher to the set of dispatchers
|
EventStateCollection |
createEventStateCollection(SessionImpl session,
Path pathPrefix)
Creates an
EventStateCollection tied to the session
given as argument. |
void |
dispatch(List<EventState> eventList,
SessionImpl session,
Path pathPrefix,
String userData)
Dispatchers a list of events to all registered dispatchers.
|
void |
removeDispatcher(ObservationDispatcher dispatcher)
Removes a observation dispatcher from the set of dispatchers
|
public void addDispatcher(ObservationDispatcher dispatcher)
dispatcher - observation dispatcherpublic void removeDispatcher(ObservationDispatcher dispatcher)
dispatcher - observation dispatcherpublic EventStateCollection createEventStateCollection(SessionImpl session, Path pathPrefix)
EventStateCollection tied to the session
given as argument.session - event sourcepathPrefix - event path prefixEventStateCollection instancepublic void dispatch(List<EventState> eventList, SessionImpl session, Path pathPrefix, String userData)
EventStateCollection is created for every dispatcher, fille with
the given event list and then dispatched.eventList - list of eventssession - current sessionpathPrefix - event path prefixuserData - the user dataCopyright © 2004–2020 The Apache Software Foundation. All rights reserved.