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 throughModifier 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, toString
public 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
AbstractEventProcessor
processEvent
in class AbstractEventProcessor
event
- the event (along with associated data)Exception
AbstractEventProcessor.suspendTimer()
,
AbstractEventProcessor.resumeTimer()
,
AbstractEventProcessor.stopTimer()
Copyright © 2014. All rights reserved.