@Test(expected = RuntimeException.class)
public void shouldThrowExceptionForNonInstantiatableEvent() {

    JsonObject eventPayloadA = mock(JsonObject.class);
    EventA eventA = mock(EventA.class);
    when(jsonObjectToObjectConverter.convert(eventPayloadA, EventA.class)).thenReturn(eventA);
    when(eventStream.read()).thenReturn(Stream.of(envelopeFrom(metadataBuilder()
            .withStreamId(STREAM_ID)
            .withId(randomUUID())
            .withName("eventA"), eventPayloadA)));
    registerEvent(EventA.class, "eventA");
    aggregateService.get(eventStream, PrivateAggregate.class);
}