Skip to content

Commit

Permalink
Update JetStreamManagementTests.java
Browse files Browse the repository at this point in the history
  • Loading branch information
scottf committed Nov 7, 2021
1 parent 871b3a6 commit 438b696
Showing 1 changed file with 0 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -430,17 +430,8 @@ private ConsumerConfiguration prepForUpdateTest(JetStreamManagement jsm) throws

private void assertInvalidConsumerUpdate(JetStreamManagement jsm, ConsumerConfiguration cc) {
JetStreamApiException e = assertThrows(JetStreamApiException.class, () -> jsm.addOrUpdateConsumer(STREAM, cc));
// 10013 consumer name already in use
// 10105 consumer already exists and is still active
System.out.println(e);
assertEquals(10012, e.getApiErrorCode());
assertEquals(500, e.getErrorCode());
// if (expected == null) {
// assertTrue(e.getApiErrorCode() == 10013 || e.getApiErrorCode() == 10105);
// assertEquals(400, e.getErrorCode());
// }
// else {
// }
}

private void assertValidAddOrUpdate(JetStreamManagement jsm, ConsumerConfiguration cc) throws IOException, JetStreamApiException {
Expand Down

0 comments on commit 438b696

Please sign in to comment.