IndexStatusRepositoryImpl extends AbstractCRUDRepository<IndexCreatedEvent> implements IndexStatusRepository { @Override public List<IndexCreatedEvent> readAll() { BoundStatement bs = new BoundStatement(readAllStmt); return (marshalAll(getSession().execute(bs))); } IndexStatusRepositoryImpl(Session session); @Override boolean exists(UUID uuid); @Override boolean exists(Identifier id); @Override IndexCreatedEvent read(UUID uuid); @Override IndexCreatedEvent read(Identifier id); @Override IndexCreatedEvent create(IndexCreatedEvent entity); @Override IndexCreatedEvent update(IndexCreatedEvent entity); @Override void delete(Identifier id); @Override void delete(IndexCreatedEvent entity); @Override List<IndexCreatedEvent> readAll(); @Override List<IndexCreatedEvent> readAll(Identifier id); @Override List<IndexCreatedEvent> readAllCurrentlyIndexing(); @Override Session getSession();  }
@Test public void testReadAll() { System.out.println("readAll"); IndexCreatedEvent entity = Fixtures.createTestIndexCreationStatus(); IndexStatusRepository instance = new IndexStatusRepositoryImpl(f.getSession()); List<IndexCreatedEvent> result = instance.readAll(); assertTrue(result.isEmpty()); instance.create(entity); result = instance.readAll(); assertStatusEqualEnough(entity, result.get(0)); IndexCreatedEvent entity2 = Fixtures.createTestIndexCreationStatus(); entity2.setUuid(UUID.randomUUID()); instance.create(entity2); result = instance.readAll(); assertTrue(result.size() == 2); }