Skip to content

Commit

Permalink
test
Browse files Browse the repository at this point in the history
  • Loading branch information
cbornet committed Nov 6, 2023
1 parent 5c857df commit 3dc5b17
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -166,11 +166,11 @@ void testTopicProducerSuccess() throws Exception {
assertEquals("test-value2", recordsToWrite.poll(5, TimeUnit.SECONDS).value().toString());
}

//@Test
@Test
void testTopicProducerError() throws Exception {
TestAgentContext context = new TestAgentContextFailure();
startProcessor(context);
assertEquals("INTERNAL: test-error", context.failure.get(5, TimeUnit.SECONDS).getMessage());
assertEquals("INTERNAL: test-error", context.failure.get(15, TimeUnit.SECONDS).getMessage());
}

@Test
Expand Down

0 comments on commit 3dc5b17

Please sign in to comment.