throw new RuntimeException("testException");
}
@Override
public void onError(Session session, Throwable thr) {
OnMessageExceptionEndpoint.throwable = thr;
<BUG>OnMessageExceptionEndpoint.session = session;
ON_ERROR_LATCH.countDown();
}</BUG>
}
@Test

throw new RuntimeException("testException");
}
@Override
public void onError(Session session, Throwable thr) {
OnMessageExceptionEndpoint.throwable = thr;
OnMessageExceptionEndpoint.session = session;
if (thr.getClass().equals(RuntimeException.class) && thr.getMessage().equals("testException")) {
ON_ERROR_LATCH.countDown();
}
}
}
@Test
