Package 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

All Implemented Interfaces:

JaloSessionHolder

@IntegrationTest
public class ControllerIntegrationTest
extends ServicelayerTransactionalBaseTest

Field Summary

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

jaloSession

Constructor Summary

Constructors

Constructor	Description
ControllerIntegrationTest()

Method Summary

Modifier and Type	Method	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

establishJaloSession, finish, getOrCreateCurrency, getOrCreateLanguage, init, intenseChecksActivated, takeJaloSession

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 java.io.IOException

Throws:

java.io.IOException

shouldScheduleInitializationTaskWhenStartingProcess

public void shouldScheduleInitializationTaskWhenStartingProcess()

shouldInitializeProcessUsingHandler

public void shouldInitializeProcessUsingHandler()
                                         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

shouldSucceedProcessWhenThereAreNoBatchesDuringInitialization

public void shouldSucceedProcessWhenThereAreNoBatchesDuringInitialization()
                                                                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

shouldThrowIllegalStateExceptionWhenHandlerDoesntAssignIdToInputBatch

public void shouldThrowIllegalStateExceptionWhenHandlerDoesntAssignIdToInputBatch()

shouldThrowIllegalStateExceptionWhenHandlerDoesntSpecifyRemainingWorkLoadForInputBatch

public void shouldThrowIllegalStateExceptionWhenHandlerDoesntSpecifyRemainingWorkLoadForInputBatch()

shouldTransitAndCreateInputBatchesDuringInitialization

public void shouldTransitAndCreateInputBatchesDuringInitialization()
                                                            throws java.lang.InterruptedException

Throws:

java.lang.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 java.lang.InterruptedException

Throws:

java.lang.InterruptedException

shouldWaitForProcessWhichIsRunning

public void shouldWaitForProcessWhichIsRunning()
                                        throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

shouldWaitTillProcessIsFinished

public void shouldWaitTillProcessIsFinished()
                                     throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException