public static boolean isStreamsEnabled()

in src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBConnectorUtilities.java [90:101]

11 lines of code
3 McCabe index (conditional complexity)


    public static boolean isStreamsEnabled(AmazonDynamoDBStreams streamsClient, String streamArn,
                                           StreamViewType viewType) {
        // Get and check stream description
        StreamDescription result = streamsClient.describeStream(new DescribeStreamRequest().withStreamArn(streamArn))
            .getStreamDescription();
        if (result.getStreamStatus().equalsIgnoreCase(DynamoDBConnectorConstants.ENABLED_STRING)
            && result.getStreamViewType().equalsIgnoreCase(viewType.toString())) {
            return true;
        }
        log.error(DynamoDBConnectorConstants.STREAM_NOT_READY + " StreamARN: " + streamArn);
        return false;
    }