@Test
public void readDoesNotRethrow() {

    // given
    FailedItemMarshaller failedItemMarshaller = new FailedItemMarshaller();
    Bytes bytes = mock(Bytes.class);
    RuntimeException expectedException = spy(new RuntimeException("test exception"));
    when(bytes.inputStream()).thenThrow(expectedException);
    // when
    failedItemMarshaller.read(bytes, null);
    // then
    verify(expectedException, times(1)).getMessage();
}