@Test
public void compensateCorrespondingOmegaInstanceOnly() throws Exception {

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