@Profile(value="prod") @Component public class RepairProcessingJobs extends Object
Contains two jobs:
RepairExternalCallService.repairProcessingExternalCalls()
Repeat interval for this job is load from configuration .
Job running concurrent in all nodes in cluster.
RepairMessageService.repairProcessingMessages()
Repeat interval for this job is load from configuration .
Job running concurrent in all nodes in cluster.
RepairExternalCallService.repairProcessingExternalCalls()
,
RepairMessageService.repairProcessingMessages()
,
CoreProps.ASYNCH_REPAIR_REPEAT_TIME_SEC
Constructor and Description |
---|
RepairProcessingJobs() |
Modifier and Type | Method and Description |
---|---|
void |
repairExtCallsJob()
Repairs external calls hooked in the state
ExternalCallStateEnum.PROCESSING . |
void |
repairMessagesJob()
Repairs messages hooked in the state
MsgStateEnum.PROCESSING . |
public final void repairExtCallsJob()
ExternalCallStateEnum.PROCESSING
.
After a specified time these external calls are changed to ExternalCallStateEnum.FAILED
state
without increasing failed count.public final void repairMessagesJob()
MsgStateEnum.PROCESSING
.
These messages are after specified time changed to MsgStateEnum.PARTLY_FAILED
state
without increasing failed count.Copyright © 2018 Pivotal Software, Inc.. All rights reserved.