@Test
public void testStoreFactInitiatesReplication() {

  FactRecord fact = new FactRecord();
  when(factRecordConverter.toEntity(fact)).thenReturn(new FactEntity());
  dao.storeFact(fact);
  verify(dcReplicationConsumer).accept(fact);
}