@Test
public void compensateOtherOmegaInstance_IfTheRequestedIsUnreachable() throws Exception {

  callbacks.get(serviceName2).remove(instanceId2One);
  TxEvent event = eventOf(serviceName2, instanceId2One, TxStartedEvent);
  compositeOmegaCallback.compensate(event);
  verify(callback1One, never()).compensate(event);
  verify(callback1Two, never()).compensate(event);
  verify(callback2One, never()).compensate(event);
  verify(callback2Two).compensate(event);
  assertThat(callbacks.get(serviceName1).values(), Matchers.containsInAnyOrder(callback1One, callback1Two));
  assertThat(callbacks.get(serviceName2).values(), containsInAnyOrder(callback2Two));
}