Package de.hybris.platform.outboundsync.job.impl

Class OutboundSyncJobStateAggregator

java.lang.Object

de.hybris.platform.outboundsync.job.impl.OutboundSyncJobStateAggregator

All Implemented Interfaces:

OutboundSyncJob

public class OutboundSyncJobStateAggregator
extends java.lang.Object
implements OutboundSyncJob

This aggregator keeps track of an outbound sync job by aggregating OutboundSyncEvents indicating the job progress.

Method Summary

Modifier and Type	Method	Description
void	addStateObserver(OutboundSyncStateObserver observer)	Registers an observer to be notified whenever this aggregate state changes, i.e.
<T extends OutboundSyncEvent> void	applyEvent(T event)	Applies an event and recalculates state of the context outbound sync job.
static OutboundSyncJobStateAggregator	create(@NotNull OutboundSyncCronJobModel model)	Instantiates this state aggregator.
OutboundSyncState	getCurrentState()	Retrieves state of the context job after the last event was applied.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

create

public static OutboundSyncJobStateAggregator create(@NotNull
                                                    @NotNull OutboundSyncCronJobModel model)

Instantiates this state aggregator.

Parameters:

model - a job model representing the cron job, for which state has to be managed by this aggregator.

applyEvent

public <T extends OutboundSyncEvent> void applyEvent(T event)

Description copied from interface: OutboundSyncJob

Applies an event and recalculates state of the context outbound sync job.

Specified by:

applyEvent in interface OutboundSyncJob

Parameters:

event - a job state changing event.

getCurrentState

public OutboundSyncState getCurrentState()

Description copied from interface: OutboundSyncJob

Retrieves state of the context job after the last event was applied.

Specified by:

getCurrentState in interface OutboundSyncJob

Returns:

current state of the context outbound sync job.

addStateObserver

public void addStateObserver(OutboundSyncStateObserver observer)

Registers an observer to be notified whenever this aggregate state changes, i.e. the cron job status changes, cron job result changes or StartedOutboundSyncEvent was applied.

Specified by:

addStateObserver in interface OutboundSyncJob

Parameters:

observer - an observer to notify