Class ChunkTests


  • public class ChunkTests
    extends Object
    • Constructor Detail

      • ChunkTests

        public ChunkTests()
    • Method Detail

      • cleanup

        public void cleanup()
      • testChunkNoProcessorDefined

        public void testChunkNoProcessorDefined()
                                         throws Exception
        Throws:
        Exception
      • testChunkNullCheckpointInfo

        public void testChunkNullCheckpointInfo()
                                         throws Exception
        Throws:
        Exception
      • testChunkArtifactInstanceUniqueness

        public void testChunkArtifactInstanceUniqueness()
                                                 throws Exception
        Throws:
        Exception
      • testChunkOnErrorListener

        public void testChunkOnErrorListener()
                                      throws Exception
        Throws:
        Exception
      • testChunkRestartItemCount7

        public void testChunkRestartItemCount7()
                                        throws Exception
        Throws:
        Exception
      • testChunkRestartItemCount10

        public void testChunkRestartItemCount10()
                                         throws Exception
        Throws:
        Exception
      • testChunkRestartChunk5

        public void testChunkRestartChunk5()
                                    throws Exception
        Throws:
        Exception
      • testChunkDefaultItemCount

        public void testChunkDefaultItemCount()
                                       throws Exception
        Throws:
        Exception
      • testChunkRestartCustomCheckpoint

        public void testChunkRestartCustomCheckpoint()
                                              throws Exception
        Throws:
        Exception
      • testChunkTimeBasedDefaultCheckpoint

        public void testChunkTimeBasedDefaultCheckpoint()
                                                 throws Exception
        Throws:
        Exception
      • testChunkTimeBasedTimeLimit0

        public void testChunkTimeBasedTimeLimit0()
                                          throws Exception
        Throws:
        Exception
      • testChunkTimeBased10Seconds

        public void testChunkTimeBased10Seconds()
                                         throws Exception
        Throws:
        Exception
      • testChunkRestartTimeBasedCheckpoint

        public void testChunkRestartTimeBasedCheckpoint()
                                                 throws Exception
        Throws:
        Exception
      • testChunkRestartTimeBasedDefaultCheckpoint

        public void testChunkRestartTimeBasedDefaultCheckpoint()
                                                        throws Exception
        Throws:
        Exception
      • testChunkSkipMultipleExceptions

        public void testChunkSkipMultipleExceptions()
                                             throws Exception
        Throws:
        Exception
      • testChunkSkipProcess

        public void testChunkSkipProcess()
                                  throws Exception
        Throws:
        Exception
      • testChunkSkipWrite

        public void testChunkSkipWrite()
                                throws Exception
        Throws:
        Exception
      • testChunkSkipOnError

        public void testChunkSkipOnError()
                                  throws Exception
        Throws:
        Exception
      • testChunkRetryOnError

        public void testChunkRetryOnError()
                                   throws Exception
        Throws:
        Exception
      • testChunkSkipReadExceedSkip

        public void testChunkSkipReadExceedSkip()
                                         throws Exception
        Throws:
        Exception
      • testChunkSkipProcessExceedSkip

        public void testChunkSkipProcessExceedSkip()
                                            throws Exception
        Throws:
        Exception
      • testChunkSkipWriteExceedSkip

        public void testChunkSkipWriteExceedSkip()
                                          throws Exception
        Throws:
        Exception
      • testChunkSkipReadNoSkipChildEx

        public void testChunkSkipReadNoSkipChildEx()
                                            throws Exception
        Throws:
        Exception
      • testChunkRetryRead

        public void testChunkRetryRead()
                                throws Exception
        Throws:
        Exception
      • testChunkRetryMultipleExceptions

        public void testChunkRetryMultipleExceptions()
                                              throws Exception
        Throws:
        Exception
      • testChunkItemListeners

        public void testChunkItemListeners()
                                    throws Exception
        Throws:
        Exception
      • testChunkItemListenersOnError

        public void testChunkItemListenersOnError()
                                           throws Exception
        Throws:
        Exception
      • testUserDataIsPersistedAfterCheckpoint

        public void testUserDataIsPersistedAfterCheckpoint()
                                                    throws Exception
        Throws:
        Exception