@Test
public void afterConnectionEstablished() throws Exception {

  underTest.afterConnectionEstablished(session);
  verify(metrics).markConnectionEstablished();
  assertThat(underTest.getService(), is(service));
  assertThat(underTest.getMetrics(), is(metrics));
}