Skip to content

Commit

Permalink
verify 810 is not a defect (#811)
Browse files Browse the repository at this point in the history
  • Loading branch information
scottf committed Dec 6, 2022
1 parent 325076b commit a789e1f
Showing 1 changed file with 8 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -278,6 +278,13 @@ public void testGetStreamInfo() throws Exception {
subjects[5] = "foo.>";
createMemoryStream(jsm, STREAM, subjects);

StreamInfo si = jsm.getStreamInfo(STREAM);
assertEquals(STREAM, si.getConfiguration().getName());
assertEquals(0, si.getStreamState().getSubjectCount());
assertEquals(0, si.getStreamState().getSubjects().size());
assertEquals(0, si.getStreamState().getDeletedCount());
assertEquals(0, si.getStreamState().getDeleted().size());

List<PublishAck> packs = new ArrayList<>();
JetStream js = nc.jetStream();
for (int x = 0; x < 5; x++) {
Expand All @@ -288,7 +295,7 @@ public void testGetStreamInfo() throws Exception {
}
jsPublish(js, "foo.bar", 6);

StreamInfo si = jsm.getStreamInfo(STREAM);
si = jsm.getStreamInfo(STREAM);
assertEquals(STREAM, si.getConfiguration().getName());
assertEquals(6, si.getStreamState().getSubjectCount());
assertEquals(0, si.getStreamState().getSubjects().size());
Expand Down

0 comments on commit a789e1f

Please sign in to comment.