integration-tests/src/test/java/com/kdgregory/aws/utils/KinesisIntegrationTest.java
/**
     *  Per-test initialization. Since each test is named, this isn't a @Setup
     *  method. Pass non-zero numShards to create the stream.
     */
Per-test initialization. Since each test is named, this isn't a @Setup
method. Pass non-zero numShards to create the stream.
Per - test initialization . Since each test is named this isn ' t a @Setup method . Pass non - zero numShards to create the stream .
private void init(String testName, int numShards)
    {
        streamName = "KinesisIntegrationTest-" + testName + "-" + UUID.randomUUID().toString();
        MDC.put("testName", testName);
        logger.info("starting. stream name is " + streamName);
        if (numShards > 0)
        {
            KinesisUtil.createStream(client, streamName, numShards, 30000);
        }
    }
private void init ( String testName , int numShards ) { streamName = "KinesisIntegrationTest-" + testName + "-" + UUID . randomUUID ( ) . toString ( ) ; MDC . put ( "testName" , testName ) ; logger . info ( "starting. stream name is " + streamName ) ; if ( numShards > 0 ) { KinesisUtil . createStream ( client , streamName , numShards , 30000 ) ; } }
Per-test initialization.
Per - test initialization .