Class ChunkTests

    • Constructor Detail

      • ChunkTests

        public ChunkTests()
    • Method Detail

      • testChunkNoProcessorDefined

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

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

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

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

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

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

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

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

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

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

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

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

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

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

        @Test
        @Disabled("Bug 5403.  Decided to exclude this test. Hopefully will introduce a modified version in 1.1")
        public void testChunkSkipMultipleExceptions()
                                             throws Exception
        Throws:
        Exception
      • testChunkSkipRead

        @Test
        public void testChunkSkipRead()
                               throws Exception
        Throws:
        Exception
      • testChunkSkipProcess

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

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

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

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

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

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

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

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

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

        @Test
        @Disabled("Bug 5403.  Decided to exclude this test. Hopefully will introduce a modified version in 1.1")
        public void testChunkRetryMultipleExceptions()
                                              throws Exception
        Throws:
        Exception
      • testChunkItemListeners

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

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

        @Test
        public void testUserDataIsPersistedAfterCheckpoint()
                                                    throws Exception
        Throws:
        Exception