public class CheckUserCountEventProcessor extends AbstractEventProcessor
UserDataService is examined to check that the prescribed
number of users are present.
EVENT_NAME_USERS_READY: Passes inbound data through| Modifier and Type | Field and Description |
|---|---|
static String |
ERR_NOT_ENOUGH_USERS |
static String |
EVENT_NAME_USERS_READY |
static String |
MSG_FOUND_USERS |
DEFAULT_CHART, DEFAULT_PROPAGATE_SESSION_ID, DEFAULT_WARN_DELAY, logger| Constructor and Description |
|---|
CheckUserCountEventProcessor(UserDataService userDataService,
long userCount) |
| Modifier and Type | Method and Description |
|---|---|
EventResult |
processEvent(Event event)
Process an event.
|
void |
setEventNameUsersReady(String eventNameUsersReady)
Override the
default event name when users are ready |
getWarnDelay, isChart, processEvent, propagateSessionId, register, resumeTimer, setBeanName, setChart, setEventName, setEventNames, setPropagateSessionId, setRegistry, setWarnDelay, stopTimer, suspendTimer, toStringpublic static final String EVENT_NAME_USERS_READY
public static final String ERR_NOT_ENOUGH_USERS
public static final String MSG_FOUND_USERS
public CheckUserCountEventProcessor(UserDataService userDataService, long userCount)
userDataService - the service that provides a view onto the usersuserCount - the minimum number of users to havepublic void setEventNameUsersReady(String eventNameUsersReady)
default event name when users are readypublic EventResult processEvent(Event event) throws Exception
AbstractEventProcessorprocessEvent in class AbstractEventProcessorevent - the event (along with associated data)ExceptionAbstractEventProcessor.suspendTimer(),
AbstractEventProcessor.resumeTimer(),
AbstractEventProcessor.stopTimer()Copyright © 2014. All rights reserved.