Modifier and Type | Method and Description |
---|---|
protected SystemEvent |
AbstractClusterCache.createEvent(EventOperationType operation,
KeyedItem cacheMember) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractClusterCache.consumeEvent(SystemEvent event) |
Modifier and Type | Method and Description |
---|---|
SystemEvent |
DatabaseSystemEventDaoImpl.disableEvent(SystemEvent systemEvent) |
SystemEvent |
DatabaseSystemEventDao.disableEvent(SystemEvent systemEvent)
Disable an event so that it will not be processed.
|
SystemEvent |
DatabaseSystemEventDaoImpl.findSystemEvent(Long eventId) |
SystemEvent |
DatabaseSystemEventDao.findSystemEvent(Long eventId) |
SystemEvent |
DatabaseSystemEventDaoImpl.finishEventInUseState(SystemEvent systemEvent) |
SystemEvent |
DatabaseSystemEventDao.finishEventInUseState(SystemEvent systemEvent)
Mark a VM scoped event as being finished with processing by a node.
|
SystemEvent |
DatabaseSystemEventDaoImpl.save(SystemEvent systemEvent) |
SystemEvent |
DatabaseSystemEventDao.save(SystemEvent systemEvent) |
protected SystemEvent |
DatabaseSystemEventDaoImpl.saveInternal(SystemEvent systemEvent,
boolean preventDuplicates) |
SystemEvent |
DatabaseSystemEventDaoImpl.startEventInUseState(SystemEvent systemEvent) |
SystemEvent |
DatabaseSystemEventDao.startEventInUseState(SystemEvent systemEvent)
Mark a VM scoped event as being processed by a node (other node will ignore the event).
|
Modifier and Type | Method and Description |
---|---|
List<SystemEvent> |
DatabaseSystemEventDaoImpl.getLatestDurableEvents(Date lowDate,
Date lastProcessedDate,
List<Long> alreadyProcessedOnDate,
List<Long> toRetryFromError,
int startPos,
int pageSize,
EventWorkerType workerType) |
List<SystemEvent> |
DatabaseSystemEventDao.getLatestDurableEvents(Date lowDate,
Date lastProcessedDate,
List<Long> alreadyProcessedOnDate,
List<Long> toRetry,
int startPos,
int pageSize,
EventWorkerType workerType)
Retrieve events of type DURABLE_GLOBAL.
|
List<SystemEvent> |
DatabaseSystemEventDaoImpl.getLatestEvents(Date lowDate,
int startPos,
int pageSize,
EventWorkerType workerType,
Long nodeId,
List<Long> excludeIds) |
List<SystemEvent> |
DatabaseSystemEventDao.getLatestEvents(Date lowDate,
int startPos,
int pageSize,
EventWorkerType workerType,
Long nodeId,
List<Long> excludeIds)
Get the list of
EventScopeType.VM events that were created after the lowDate that have not already been executed by this node. |
List<SystemEvent> |
DatabaseSystemEventDaoImpl.getLatestGlobalEvents(Date lowDate,
int startPos,
int pageSize,
EventWorkerType workerType,
Long nodeId,
List<Long> excludeIds) |
List<SystemEvent> |
DatabaseSystemEventDao.getLatestGlobalEvents(Date lowDate,
int startPos,
int pageSize,
EventWorkerType workerType,
Long nodeId,
List<Long> excludeIds)
Get the list of
EventScopeType.GLOBAL events that were created after the lowDate that have not already been executed by this node. |
List<SystemEvent> |
DatabaseSystemEventDaoImpl.getLatestPriorityEvents(Date lowDate,
int startPos,
int pageSize,
EventWorkerType workerType,
Long nodeId,
List<Long> excludeIds) |
List<SystemEvent> |
DatabaseSystemEventDao.getLatestPriorityEvents(Date lowDate,
int startPos,
int pageSize,
EventWorkerType workerType,
Long nodeId,
List<Long> excludeIds)
Get the list of priority events that were created after the lowDate that have not already been executed by this node.
|
List<SystemEvent> |
DatabaseSystemEventDaoImpl.getLatestScheduledDeployEvents(int startPos,
int pageSize) |
List<SystemEvent> |
DatabaseSystemEventDao.getLatestScheduledDeployEvents(int startPos,
int pageSize) |
Modifier and Type | Method and Description |
---|---|
SystemEvent |
DatabaseSystemEventDaoImpl.disableEvent(SystemEvent systemEvent) |
SystemEvent |
DatabaseSystemEventDao.disableEvent(SystemEvent systemEvent)
Disable an event so that it will not be processed.
|
SystemEvent |
DatabaseSystemEventDaoImpl.finishEventInUseState(SystemEvent systemEvent) |
SystemEvent |
DatabaseSystemEventDao.finishEventInUseState(SystemEvent systemEvent)
Mark a VM scoped event as being finished with processing by a node.
|
boolean |
DatabaseSystemEventDaoImpl.lockGlobalEvent(SystemEvent systemEvent,
Long nodeId)
Deprecated.
|
boolean |
DatabaseSystemEventDao.lockGlobalEvent(SystemEvent systemEvent,
Long nodeId)
Deprecated.
No longer used internally
|
boolean |
DatabaseSystemEventDaoImpl.lockSerialEvent(SystemEvent systemEvent) |
boolean |
DatabaseSystemEventDao.lockSerialEvent(SystemEvent systemEvent)
Lock the event of type
getType() . |
void |
DatabaseSystemEventDaoImpl.refresh(SystemEvent event) |
void |
DatabaseSystemEventDao.refresh(SystemEvent event) |
void |
DatabaseSystemEventDaoImpl.removeLock(SystemEvent systemEvent)
Deprecated.
|
void |
DatabaseSystemEventDao.removeLock(SystemEvent systemEvent)
Deprecated.
No longer used internally
|
SystemEvent |
DatabaseSystemEventDaoImpl.save(SystemEvent systemEvent) |
SystemEvent |
DatabaseSystemEventDao.save(SystemEvent systemEvent) |
protected SystemEvent |
DatabaseSystemEventDaoImpl.saveInternal(SystemEvent systemEvent,
boolean preventDuplicates) |
SystemEvent |
DatabaseSystemEventDaoImpl.startEventInUseState(SystemEvent systemEvent) |
SystemEvent |
DatabaseSystemEventDao.startEventInUseState(SystemEvent systemEvent)
Mark a VM scoped event as being processed by a node (other node will ignore the event).
|
Modifier and Type | Method and Description |
---|---|
void |
DatabaseSystemEventDaoImpl.save(List<SystemEvent> events) |
void |
DatabaseSystemEventDao.save(List<SystemEvent> events) |
Modifier and Type | Class and Description |
---|---|
class |
SystemEventImpl |
Modifier and Type | Field and Description |
---|---|
protected SystemEvent |
SystemEventDetailImpl.event |
Modifier and Type | Method and Description |
---|---|
SystemEvent |
SystemEventDetail.getEvent() |
SystemEvent |
SystemEventDetailImpl.getEvent() |
Modifier and Type | Method and Description |
---|---|
void |
SystemEventDetail.setEvent(SystemEvent event) |
void |
SystemEventDetailImpl.setEvent(SystemEvent event) |
Modifier and Type | Class and Description |
---|---|
class |
SystemEventDTO
This dto class is used to represent a
SystemEvent entity during event consumption. |
Modifier and Type | Field and Description |
---|---|
protected SystemEvent |
SystemEventDetailDTO.event |
Modifier and Type | Method and Description |
---|---|
SystemEvent |
SystemEventDetailDTO.getEvent() |
Modifier and Type | Method and Description |
---|---|
void |
SystemEventDetailDTO.setEvent(SystemEvent event) |
Constructor and Description |
---|
SystemEventDetailDTO(SystemEventDetail detail,
SystemEvent eventDTO) |
SystemEventDTO(SystemEvent event) |
Modifier and Type | Method and Description |
---|---|
SystemEvent |
PurgeSystemEventFactory.create(ScheduledJob job)
Deprecated.
|
SystemEvent |
SystemEventFactory.create(ScheduledJob job) |
Modifier and Type | Method and Description |
---|---|
List<SystemEvent> |
SystemEventCompressionHelper.compress(List<SystemEvent> uncompressed)
Reduce the quantity of individual SystemEvent instances in a list removing redundancy.
|
List<SystemEvent> |
SystemEventCompressionHelperImpl.compress(List<SystemEvent> uncompressed) |
List<SystemEvent> |
SystemEventCompressionHelper.decompress(SystemEvent compressed)
Reconstitute multiple individual SystemEvent instances from a single compressed SystemEvent instance.
|
List<SystemEvent> |
SystemEventCompressionHelperImpl.decompress(SystemEvent compressed) |
protected List<SystemEvent> |
ConsumeWorkerImpl.getSystemEvents(int startPos,
Date lowDate,
EventWorkerType workerType) |
protected List<SystemEvent> |
GlobalConsumeWorkerImpl.getSystemEvents(int startPos,
Date lowDate,
EventWorkerType workerType) |
protected List<SystemEvent> |
PriorityConsumeWorkerImpl.getSystemEvents(int startPos,
Date lowDate,
EventWorkerType workerType) |
Modifier and Type | Method and Description |
---|---|
protected void |
DatabaseSystemEventSender.addIncognitoCrossPollination(List<SystemEvent> clusterEvents,
SystemEvent event,
Set<String> activeNodes) |
protected void |
DatabaseSystemEventNodeImpl.asyncExecuteEvent(boolean durable,
QueueStatusThreadPoolTaskExecutor executor,
Map<String,List<SystemEventConsumer>> consumers,
SystemEvent event) |
void |
SystemEventConsumer.consumeEvent(SystemEvent event) |
void |
DatabaseSystemEventNode.consumeLocalEvent(SystemEvent event)
Cause asynchronous consumption of this event to occur in the same JVM, rather than provide to event to the
cluster.
|
void |
DatabaseSystemEventNodeImpl.consumeLocalEvent(SystemEvent event) |
List<SystemEvent> |
SystemEventCompressionHelper.decompress(SystemEvent compressed)
Reconstitute multiple individual SystemEvent instances from a single compressed SystemEvent instance.
|
List<SystemEvent> |
SystemEventCompressionHelperImpl.decompress(SystemEvent compressed) |
protected void |
DatabaseSystemEventNodeImpl.executeEvent(SystemEventConsumer consumer,
SystemEvent lockedEvent) |
void |
ProcessManager.startProcess(SystemEvent event)
Add a new ProcessStatus to the list of currently active processes on this server.
|
void |
ProcessManagerImpl.startProcess(SystemEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
DatabaseSystemEventSender.addIncognitoCrossPollination(List<SystemEvent> clusterEvents,
SystemEvent event,
Set<String> activeNodes) |
List<SystemEvent> |
SystemEventCompressionHelper.compress(List<SystemEvent> uncompressed)
Reduce the quantity of individual SystemEvent instances in a list removing redundancy.
|
List<SystemEvent> |
SystemEventCompressionHelperImpl.compress(List<SystemEvent> uncompressed) |
void |
DatabaseSystemEventNode.executeEvents(List<SystemEvent> events,
boolean durable,
QueueStatusThreadPoolTaskExecutor executor)
Iterate through a list of events and provide those events to the appropriate
SystemEventConsumer
instances. |
void |
DatabaseSystemEventNodeImpl.executeEvents(List<SystemEvent> events,
boolean durable,
QueueStatusThreadPoolTaskExecutor executor) |
void |
AbstractConsumerWorker.populateSystemEvents(List<SystemEvent> events) |
protected void |
DatabaseSystemEventNodeImpl.removeUniversalDuplicates(List<SystemEvent> events) |
void |
SystemEventSender.sendEvents(List<SystemEvent> events)
Send the events to the backing system.
|
void |
DatabaseSystemEventSender.sendEvents(List<SystemEvent> events) |
protected void |
DatabaseSystemEventSender.sendEvents(List<SystemEvent> events,
boolean guaranteed) |
void |
SystemEventSender.unsafeSendEvents(List<SystemEvent> events)
Send the events to the backing system.
|
void |
DatabaseSystemEventSender.unsafeSendEvents(List<SystemEvent> events) |
Modifier and Type | Method and Description |
---|---|
SystemEvent |
CacheInvalidationHelper.constructEvent(String originalItemId,
String entityType,
String propertyVal,
Long processMarker,
String region,
Long targetSandBox,
Long currentProfile,
Long currentCatalog,
EventWorkerType workerType)
Create a cache invalidation event
|
SystemEvent |
CacheInvalidationHelperImpl.constructEvent(String originalItemId,
String entityType,
String propertyVal,
Long processMarker,
String region,
Long targetSandBox,
Long currentProfile,
Long currentCatalog,
EventWorkerType workerType) |
SystemEvent |
CacheInvalidationHelper.constructRegionEvent(Long processMarker,
String region,
EventWorkerType workerType)
Create a cache invalidation event to invalidate an entire cache region
|
SystemEvent |
CacheInvalidationHelperImpl.constructRegionEvent(Long processMarker,
String region,
EventWorkerType workerType) |
protected SystemEvent |
EventLockUtil.refreshSystemEvent(SystemEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
CacheInvalidationHelperImpl.addEventDetail(SystemEvent event,
String name,
String value) |
static String |
EventLockUtil.buildGlobalEventLockKey(SystemEvent systemEvent,
Long nodeId)
Deprecated.
No longer used internally
|
static String |
EventLockUtil.buildGlobalEventRemovalKey(SystemEvent systemEvent)
Deprecated.
No longer used internally
|
void |
PurgeSystemEventConsumer.consumeEvent(SystemEvent event)
Deprecated.
|
void |
LockedOperation.execute(SystemEvent lockedEvent) |
protected SystemEvent |
EventLockUtil.refreshSystemEvent(SystemEvent event) |
void |
EventLockUtil.runLockedOperation(SystemEvent event,
Long nodeId,
LockedOperation operation) |
Modifier and Type | Method and Description |
---|---|
static boolean |
EventScopeType.isLocalEvent(SystemEvent event) |
static boolean |
EventScopeType.isLocalNonAsyncEvent(SystemEvent event) |
static boolean |
EventScopeType.isLocalNonAsyncNoResumeEvent(SystemEvent event) |
Copyright © 2017. All rights reserved.