@Test public void executeWithNullPayloadTest() { EventIngestionExecutor eventIngestionExecutor = new NoOpEventsIngestionExecutor(); eventIngestionExecutor.execute(null); }
@Override public void execute(EventEnvelopePayload eventEnvelopePayload) { logger.debug("Received event envelope: {}", eventEnvelopePayload != null ? eventEnvelopePayload.toJson() : null); }
NoOpEventsIngestionExecutor implements EventIngestionExecutor { @Override public void execute(EventEnvelopePayload eventEnvelopePayload) { logger.debug("Received event envelope: {}", eventEnvelopePayload != null ? eventEnvelopePayload.toJson() : null); } }
NoOpEventsIngestionExecutor implements EventIngestionExecutor { @Override public void execute(EventEnvelopePayload eventEnvelopePayload) { logger.debug("Received event envelope: {}", eventEnvelopePayload != null ? eventEnvelopePayload.toJson() : null); }  }
NoOpEventsIngestionExecutor implements EventIngestionExecutor { @Override public void execute(EventEnvelopePayload eventEnvelopePayload) { logger.debug("Received event envelope: {}", eventEnvelopePayload != null ? eventEnvelopePayload.toJson() : null); }  @Override void execute(EventEnvelopePayload eventEnvelopePayload); @Override int queueLength(); @Override String name(); }
NoOpEventsIngestionExecutor implements EventIngestionExecutor { @Override public void execute(EventEnvelopePayload eventEnvelopePayload) { logger.debug("Received event envelope: {}", eventEnvelopePayload != null ? eventEnvelopePayload.toJson() : null); }  @Override void execute(EventEnvelopePayload eventEnvelopePayload); @Override int queueLength(); @Override String name(); static final String NAME; }