@Test
public void worker_passes_to_context() throws Exception {

  try (Receiver receiver = new Receiver(metrics, contextManager, origin, offramp)) {
    receiver.start();
    verify(context1).messageReceived(message1);
    verify(context2).messageReceived(message2);
  }
}