static OutboundSyncJobStateAggregator |
OutboundSyncJobStateAggregator.create(@NotNull OutboundSyncCronJobModel model) |
Instantiates this state aggregator.
|
CountingChangesCollector |
DefaultChangesCollectorFactory.createCountingCollector(OutboundSyncCronJobModel cronJob,
OutboundSyncStreamConfigurationModel stream) |
|
protected OutboundSyncJobStateAggregator |
DefaultOutboundSyncJobRegister.createJobStateAggregator(@NotNull OutboundSyncCronJobModel job) |
|
@NotNull OutboundSyncJob |
DefaultOutboundSyncJobRegister.getJob(@NotNull OutboundSyncCronJobModel jobModel) |
|
@NotNull OutboundSyncJob |
OutboundSyncJobRegister.getJob(@NotNull OutboundSyncCronJobModel jobModel) |
Retrieves the outbound sync job object corresponding to the specified job model.
|
@NotNull OutboundSyncJob |
DefaultOutboundSyncJobRegister.getNewJob(@NotNull OutboundSyncCronJobModel jobModel) |
|
@NotNull OutboundSyncJob |
OutboundSyncJobRegister.getNewJob(@NotNull OutboundSyncCronJobModel jobModel) |
Retrieves new instance of the outbound sync job object for the specified job model.
|
PerformResult |
OutboundSyncCronJobPerformable.perform(OutboundSyncCronJobModel cronJob) |
|
protected void |
DefaultOutboundSyncJobRegister.persistJobState(@NotNull OutboundSyncCronJobModel job,
@NotNull OutboundSyncState state) |
|
protected int |
OutboundSyncCronJobPerformable.processChanges(OutboundSyncCronJobModel cronJob,
OutboundSyncStreamConfigurationModel deltaStream) |
Processes the changes from the given stream configuration
|
protected int |
OutboundSyncCronJobPerformable.processChangesForContainer(OutboundSyncCronJobModel cronJob) |
Process changes for all stream configurations in the container
|
void |
DefaultOutboundSyncJobRegister.stateChanged(@NotNull OutboundSyncCronJobModel model,
@NotNull OutboundSyncState state) |
|
void |
OutboundSyncStateObserver.stateChanged(@NotNull OutboundSyncCronJobModel model,
@NotNull OutboundSyncState state) |
Notifies the observer about the outbound sync job state change.
|