public class SimpleFastLaneHandler extends DispatchingHandler
| Modifier and Type | Class and Description |
|---|---|
static class |
SimpleFastLaneHandler.SimpleFastLaneHandlerState
SimpleFastLaneHandlerState extends the generic
state used for dispatching handlers, to add a custom dispatching policy.
|
| Modifier and Type | Field and Description |
|---|---|
static String |
DISPATCHING_POLICY_LEAST_LOADED_FASTLANE_1
The dispatching Policy name used for a "least loaded" dispatching
strategy where the 1st Worker is used as a fast lane.
|
PROPERTY_DEFAULT_BATCHSIZE, PROPERTY_NAME_BATCHSIZE, PROPERTY_NAME_CONTINUOUS_WORKER_MODE_ENABLED, PROPERTY_NAME_DISPATCHINGHANDLERSPECIFICATION, PROPERTY_NAME_DYNAMIC_BATCHSIZE_ENABLED, PROPERTY_NAME_FORCE_RETRY_OF_FAILURES, PROPERTY_NAME_MAXIMUM_WORKER_QUEUE_SIZE, PROPERTY_NAME_PENDING_EVENTSET_NAMES, PROPERTY_NAME_PROCESS_EVENTS_WHEN_NEW_EVENT_POSTED, PROPERTY_NAME_PROCESS_EVENTS_WITH_TIMER, PROPERTY_NAME_REQUEUE_UPON_FAILURE, PROPERTY_NAME_RETRY_PHASE_PERIODS, PROPERTY_NAME_RETRY_UPON_FAILUREDEFAULT_BATCHSIZE| Constructor and Description |
|---|
SimpleFastLaneHandler() |
| Modifier and Type | Method and Description |
|---|---|
protected DispatchingHandlerState |
constructDispatchingHandlerState()
Constructs the DispatchingHandlerState.
|
protected void |
processEvent(LibrarySession session,
AuditEvent event,
DispatchedEvent de)
Low-level processing of an event.
|
protected void |
reallyProcessTheEvent(LibrarySession session,
AuditEvent event,
DispatchedEvent de) |
addPendingEventSetName, checkDispatchingHandlerSpecificationRequests, checkForCompletedEventSets, checkForNewPendingEventSetName, completeEventSet, deriveDispatcherDynamicBatchSize, deriveWorkerDynamicBatchSize, determineDispatchingHandlerSpecification, getBatchSize, getCommonName, getDispatchingHandlerSpecification, getDispatchingHandlerState, getDynamicBatchSize, getEstimatedCost, getEventSetName, getMaximumWorkerQueueSize, getPendingEventSetNames, getRetryPhasePeriods, handleEventPosted, handleInitialize, handleTimerExpired, hasAuxDispatchingHandlerSpecifications, incrementSkipCount, initializeNonDynamicProperties, isContinuousWorkerModeEnabled, isDynamicBatchSizeEnabled, isForceRetryFailuresEnabled, isProcessEventsWhenNewEventPostedEnabled, isProcessEventsWithTimerEnabled, isRequeueUponFailureEnabled, isRetryUponFailureEnabled, markProcessingCompleted, processEvent, processEvents, processExistingDispatchedEvent, rebalanceActiveWorkers, rebalanceInactiveWorkers, rebalanceWorker, refreshDynamicProperties, setForceRetryAllFailuresNextBatch, setForceRetryFailuresNextBatch, setProcessingStarteddeleteEvents, getAuditHandlerSpecification, getAuditSpecification, getHandlerProperty, handleDispose, markProcessingStarted, processEvents, processEvents, selectEvents, selectEvents, selectMaximumEventId, setHandlerPropertypublic static final String DISPATCHING_POLICY_LEAST_LOADED_FASTLANE_1
protected DispatchingHandlerState constructDispatchingHandlerState() throws IfsException
DispatchingHandlerThis is typically overridden by subclasses that wish to add custom dispatching logic.
constructDispatchingHandlerState in class DispatchingHandlerIfsException - if the opertation failsprotected void processEvent(LibrarySession session, AuditEvent event, DispatchedEvent de) throws IfsException
DispatchingHandlerprocessEvent in class DispatchingHandlersession - the session Context to use for processingevent - the event to processde - the associated DispatchedEventIfsException - if the operation failsprotected void reallyProcessTheEvent(LibrarySession session, AuditEvent event, DispatchedEvent de) throws IfsException
IfsExceptionCopyright © 2025. All rights reserved.