- assertTrue(streamSubscribes.get(entry.getKey()).getType().equals(entry.getValue().getType()));
- assertTrue(streamSubscribes.get(entry.getKey()).getDmaap_info().equals(entry.getValue().getDmaap_info()));
+ assertEquals(streamSubscribes.get(entry.getKey()).getType(), entry.getValue().getType());
+ assertEquals(((Dmaap) streamSubscribes.get(entry.getKey())).getDmaap_info(),
+ ((Dmaap) entry.getValue()).getDmaap_info());