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,
int startPos,
int pageSize,
EventWorkerType workerType) |
List<SystemEvent> |
DatabaseSystemEventDao.getLatestDurableEvents(Date lowDate,
Date lastProcessedDate,
List<Long> alreadyProcessedOnDate,
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<SystemEvent> |
DatabaseSystemEventDao.getLatestEvents(Date lowDate,
int startPos,
int pageSize,
EventWorkerType workerType,
Long nodeId)
Get the list of 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) |
boolean |
DatabaseSystemEventDao.lockGlobalEvent(SystemEvent systemEvent,
Long nodeId)
Lock the event on the node.
|
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) |
void |
DatabaseSystemEventDao.removeLock(SystemEvent systemEvent)
Purge the lock record from the database
|
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 | Method and Description |
---|---|
SystemEvent |
PurgeSystemEventFactory.create(ScheduledJob job)
Deprecated.
|
SystemEvent |
SystemEventFactory.create(ScheduledJob job) |
Modifier and Type | Method and Description |
---|---|
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) |
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 |
---|---|
void |
DatabaseSystemEventNode.executeEvents(List<SystemEvent> events,
boolean durable)
Iterate through a list of events and provide those events to the appropriate
SystemEventConsumer
instances. |
void |
DatabaseSystemEventNodeImpl.executeEvents(List<SystemEvent> events,
boolean durable) |
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) |
static String |
EventLockUtil.buildGlobalEventRemovalKey(SystemEvent systemEvent) |
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) |
Copyright © 2019. All rights reserved.