FailoverPersistenceStoreModel implements Serializable { public Map<String, StreamStatusDTO> getStreamStatuses() { return streamStatuses; } FailoverPersistenceStoreModel(Map<String, StreamStatusDTO> streamStatuses, byte[] siddhiSnapshot);  FailoverPersistenceStoreModel(byte[] bytes); Map<String, StreamStatusDTO> getStreamStatuses(); byte[] getSiddhiSnapshot(); byte[] FailOverPersistenceModelToByte(); @Override int hashCode(); @Override boolean equals(Object obj); @Override String toString();  }
@Test public void testGetStreamStatuses() throws Exception { assertEquals("Expected same size of Stream Statuses", 2, persistenceModel.getStreamStatuses().size()); }