Uncommenting tests

This commit is contained in:
Meher Mankikar 2023-06-20 16:01:12 -07:00
parent 208345c39d
commit c9659ce11b

View file

@ -16,17 +16,17 @@ public class BasicStreamConsumerIntegrationTest {
consumer.run();
}
// @Test
// public void kclReleaseCanaryPollingH1Test() throws Exception {
// KCLAppConfig consumerConfig = new ReleaseCanaryPollingH1TestConfig();
// TestConsumer consumer = new TestConsumer(consumerConfig);
// consumer.run();
// }
//
// @Test
// public void kclReleaseCanaryStreamingTest() throws Exception {
// KCLAppConfig consumerConfig = new ReleaseCanaryStreamingTestConfig();
// TestConsumer consumer = new TestConsumer(consumerConfig);
// consumer.run();
// }
@Test
public void kclReleaseCanaryPollingH1Test() throws Exception {
KCLAppConfig consumerConfig = new ReleaseCanaryPollingH1TestConfig();
TestConsumer consumer = new TestConsumer(consumerConfig);
consumer.run();
}
@Test
public void kclReleaseCanaryStreamingTest() throws Exception {
KCLAppConfig consumerConfig = new ReleaseCanaryStreamingTestConfig();
TestConsumer consumer = new TestConsumer(consumerConfig);
consumer.run();
}
}