Skip to content

Commit

Permalink
Modified to use log4j
Browse files Browse the repository at this point in the history
Signed-off-by: Kondaka <krishkdk@amazon.com>
  • Loading branch information
kkondaka committed Oct 11, 2023
1 parent ce2f66c commit 45c9483
Showing 1 changed file with 5 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,8 @@
import org.opensearch.dataprepper.plugins.InMemorySourceAccessor;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.Assert.assertFalse;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.List;
import java.util.concurrent.TimeUnit;
Expand All @@ -26,7 +28,7 @@
import static org.hamcrest.Matchers.empty;

class PipelinesWithAcksIT {

private static final Logger LOG = LoggerFactory.getLogger(PipelinesWithAcksIT.class);
private static final String IN_MEMORY_IDENTIFIER = "PipelinesWithAcksIT";
private static final String SIMPLE_PIPELINE_CONFIGURATION_UNDER_TEST = "acknowledgements/simple-test.yaml";
private static final String TWO_PIPELINES_CONFIGURATION_UNDER_TEST = "acknowledgements/two-pipelines-test.yaml";
Expand All @@ -45,15 +47,15 @@ void setUp(String configFile) {
.withPipelinesDirectoryOrFile(configFile)
.build();

System.out.println("Data Prepper Test with config file "+ configFile + " started at "+Instant.now());
LOG.info("PipelinesWithAcksIT with config file {} started at {}", configFile, Instant.now());
dataPrepperTestRunner.start();
inMemorySourceAccessor = dataPrepperTestRunner.getInMemorySourceAccessor();
inMemorySinkAccessor = dataPrepperTestRunner.getInMemorySinkAccessor();
}

@AfterEach
void tearDown() {
System.out.println("Data Prepper Test stopped at "+Instant.now());
LOG.info("PipelinesWithAcksIT with stopped at {}", Instant.now());
dataPrepperTestRunner.stop();
}

Expand Down

0 comments on commit 45c9483

Please sign in to comment.