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–2021 The Apache Software Foundation. All rights reserved.