de.hybris.platform.processing.distributed.defaultimpl

Class ControllerIntegrationTest

java.lang.Object

de.hybris.platform.testframework.HybrisJUnit4Test

de.hybris.platform.servicelayer.ServicelayerBaseTest

de.hybris.platform.servicelayer.ServicelayerTransactionalBaseTest

de.hybris.platform.processing.distributed.defaultimpl.ControllerIntegrationTest

@IntegrationTest
public class ControllerIntegrationTest
extends ServicelayerTransactionalBaseTest

Field Summary

Fields inherited from class de.hybris.platform.testframework.HybrisJUnit4Test

defaultLanguage, jaloSession

Constructor Summary

Constructors

Constructor and Description
ControllerIntegrationTest()

Method Summary

Modifier and Type	Method and Description
void	setUp()
void	shouldBeAbleToPersist_10_000_OfBatches()
void	shouldCreateInitialBatchProvidedByHandler()
void	shouldCreateProcessInCreatedState()
void	shouldFailProcessIfHandlerReportsFailure()
void	shouldFailWhenHandlerDoesntChangeExecutionId()
void	shouldInitializeProcessUsingHandler()
void	shouldMarkProcessToBeStoppedWhenItsRunning()
void	shouldNotWaitForProcessIfItHasAlreadyFinished()
void	shouldPersistAdditionalModelsProvidedByHandlerDuringCreation()
void	shouldScheduleInitializationTaskWhenStartingProcess()
void	shouldScheduleWorkerTaskAndWithWaitTaskDuringScheduling()
void	shouldStopProcessImmediatelyWhenItsInCreatedState()
void	shouldSucceedProcessIfHandlerReportsNoInputBatches()
void	shouldSucceedProcessIfHandlerReportsSuccees()
void	shouldSucceedProcessWhenThereAreNoBatchesDuringInitialization()
void	shouldThrowIllegalStateExceptionWhenHandlerDoesntAssignCodeToNewProcess()
void	shouldThrowIllegalStateExceptionWhenHandlerDoesntAssignIdToInitialBatch()
void	shouldThrowIllegalStateExceptionWhenHandlerDoesntAssignIdToInputBatch()
void	shouldThrowIllegalStateExceptionWhenHandlerDoesntSpecifyRemainingWorkLoadForInitialBatch()
void	shouldThrowIllegalStateExceptionWhenHandlerDoesntSpecifyRemainingWorkLoadForInputBatch()
void	shouldTransitAndCreateInputBatchesDuringInitialization()
void	shouldTransitToScheduleExecutionWhenThereIsAnyInputBatchReturnedByHandler()
void	shouldWaitForProcessWhichIsRunning()
void	shouldWaitTillProcessIsFinished()
void	shoulNotdMarkProcessToBeStoppedWhenItsFinished()
void	shoulStopProcessWhenItsRunning()

Methods inherited from class de.hybris.platform.servicelayer.ServicelayerBaseTest

autowireProperties, getApplicationContext, getBeanName, prepareApplicationContextAndSession

Methods inherited from class de.hybris.platform.testframework.HybrisJUnit4Test

finish, getOrCreateCurrency, getOrCreateLanguage, init, intenseChecksActivated

Methods inherited from class java.lang.Object

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

Constructor Detail

ControllerIntegrationTest

public ControllerIntegrationTest()

Method Detail

setUp

public void setUp()

shouldThrowIllegalStateExceptionWhenHandlerDoesntAssignCodeToNewProcess

public void shouldThrowIllegalStateExceptionWhenHandlerDoesntAssignCodeToNewProcess()

shouldCreateProcessInCreatedState

public void shouldCreateProcessInCreatedState()

shouldThrowIllegalStateExceptionWhenHandlerDoesntAssignIdToInitialBatch

public void shouldThrowIllegalStateExceptionWhenHandlerDoesntAssignIdToInitialBatch()

shouldThrowIllegalStateExceptionWhenHandlerDoesntSpecifyRemainingWorkLoadForInitialBatch

public void shouldThrowIllegalStateExceptionWhenHandlerDoesntSpecifyRemainingWorkLoadForInitialBatch()

shouldCreateInitialBatchProvidedByHandler

public void shouldCreateInitialBatchProvidedByHandler()

shouldPersistAdditionalModelsProvidedByHandlerDuringCreation

public void shouldPersistAdditionalModelsProvidedByHandlerDuringCreation()

shouldBeAbleToPersist_10_000_OfBatches

public void shouldBeAbleToPersist_10_000_OfBatches()
                                            throws IOException

Throws:

IOException

shouldScheduleInitializationTaskWhenStartingProcess

public void shouldScheduleInitializationTaskWhenStartingProcess()

shouldInitializeProcessUsingHandler

public void shouldInitializeProcessUsingHandler()
                                         throws InterruptedException

Throws:

InterruptedException

shouldSucceedProcessWhenThereAreNoBatchesDuringInitialization

public void shouldSucceedProcessWhenThereAreNoBatchesDuringInitialization()
                                                                   throws InterruptedException

Throws:

InterruptedException

shouldThrowIllegalStateExceptionWhenHandlerDoesntAssignIdToInputBatch

public void shouldThrowIllegalStateExceptionWhenHandlerDoesntAssignIdToInputBatch()

shouldThrowIllegalStateExceptionWhenHandlerDoesntSpecifyRemainingWorkLoadForInputBatch

public void shouldThrowIllegalStateExceptionWhenHandlerDoesntSpecifyRemainingWorkLoadForInputBatch()

shouldTransitAndCreateInputBatchesDuringInitialization

public void shouldTransitAndCreateInputBatchesDuringInitialization()
                                                            throws InterruptedException

Throws:

InterruptedException

shouldScheduleWorkerTaskAndWithWaitTaskDuringScheduling

public void shouldScheduleWorkerTaskAndWithWaitTaskDuringScheduling()

shouldSucceedProcessIfHandlerReportsSuccees

public void shouldSucceedProcessIfHandlerReportsSuccees()

shouldFailProcessIfHandlerReportsFailure

public void shouldFailProcessIfHandlerReportsFailure()

shouldFailWhenHandlerDoesntChangeExecutionId

public void shouldFailWhenHandlerDoesntChangeExecutionId()

shouldSucceedProcessIfHandlerReportsNoInputBatches

public void shouldSucceedProcessIfHandlerReportsNoInputBatches()

shouldTransitToScheduleExecutionWhenThereIsAnyInputBatchReturnedByHandler

public void shouldTransitToScheduleExecutionWhenThereIsAnyInputBatchReturnedByHandler()

shouldStopProcessImmediatelyWhenItsInCreatedState

public void shouldStopProcessImmediatelyWhenItsInCreatedState()

shouldMarkProcessToBeStoppedWhenItsRunning

public void shouldMarkProcessToBeStoppedWhenItsRunning()

shoulNotdMarkProcessToBeStoppedWhenItsFinished

public void shoulNotdMarkProcessToBeStoppedWhenItsFinished()

shoulStopProcessWhenItsRunning

public void shoulStopProcessWhenItsRunning()

shouldNotWaitForProcessIfItHasAlreadyFinished

public void shouldNotWaitForProcessIfItHasAlreadyFinished()
                                                   throws InterruptedException

Throws:

InterruptedException

shouldWaitForProcessWhichIsRunning

public void shouldWaitForProcessWhichIsRunning()
                                        throws InterruptedException

Throws:

InterruptedException

shouldWaitTillProcessIsFinished

public void shouldWaitTillProcessIsFinished()
                                     throws InterruptedException

Throws:

InterruptedException