Class SimpleDistributedProcessIntegrationTest

    • Constructor Detail

      • SimpleDistributedProcessIntegrationTest

        public SimpleDistributedProcessIntegrationTest()
    • Method Detail

      • setUp

        public void setUp()
                   throws java.lang.Exception
        Throws:
        java.lang.Exception
      • tearDown

        public void tearDown()
                      throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldFinishProcessSuccessfully

        public void shouldFinishProcessSuccessfully()
                                             throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldFinishProcessSuccessfullyUsingDatabasePaging

        public void shouldFinishProcessSuccessfullyUsingDatabasePaging()
                                                                throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldFailWholeProcessWhenEachBatchConstantlyThrowsAnException

        public void shouldFailWholeProcessWhenEachBatchConstantlyThrowsAnException()
                                                                            throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldFinishPossibleToDoBatchesAndTryToRetryThoseWhichAreFailing

        public void shouldFinishPossibleToDoBatchesAndTryToRetryThoseWhichAreFailing()
                                                                              throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldFinishProcessSuccessfullyForMultiValueQuery

        public void shouldFinishProcessSuccessfullyForMultiValueQuery()
                                                               throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldFinishProcessSuccesfullyOnlyForItemsMatchesTheQuery

        public void shouldFinishProcessSuccesfullyOnlyForItemsMatchesTheQuery()
                                                                       throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldFinishProcessSuccesfullyUsingScriptingBasedProcessor

        public void shouldFinishProcessSuccesfullyUsingScriptingBasedProcessor()
                                                                        throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldFinishProcessSuccessfullyWithUseOfFullyBlownFlexibleSearchQueryObject

        public void shouldFinishProcessSuccessfullyWithUseOfFullyBlownFlexibleSearchQueryObject()
                                                                                         throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldAllowToSetHookBeforeQueryWhenProducingBatches

        public void shouldAllowToSetHookBeforeQueryWhenProducingBatches()
                                                                 throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldThrowAnExceptionWhenQueryIsNull

        public void shouldThrowAnExceptionWhenQueryIsNull()
                                                   throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldFinishProcessSuccessfullyUsingCollectionBasedCreationData

        public void shouldFinishProcessSuccessfullyUsingCollectionBasedCreationData()
                                                                             throws java.lang.Exception
        Throws:
        java.lang.Exception