@Test
public void testProcessS3EventFetchFailure() throws Exception {

  when(broadcaster.isEmpty()).thenReturn(false);
  when(s3.fetch(any(S3EventNotificationRecord.class)))
      .thenThrow(new AmazonServiceException("error"));
  message.setBody(FixtureHelpers.fixture("fixtures/sns_notification.json"));
  final boolean actual = processor.test(message);
  verify(broadcaster, times(2)).isEmpty();
  verify(broadcaster, never()).test(anyString());
  verify(s3).fetch(any(S3EventNotificationRecord.class));
  assertThat(actual).isFalse();
}