@Test
void shouldCreateConnectionTerminatedErrorWithReason()
{

    String reason = "Thread interrupted";
    ServiceUnavailableException error = newConnectionTerminatedError( reason );
    assertThat( error.getMessage(), startsWith( "Connection to the database terminated" ) );
    assertThat( error.getMessage(), containsString( reason ) );
}