@Override
    public void afterJob(JobExecution jobExecution) {
        LOG.debug("sending after job execution event [{}]...", jobExecution);
        producerTemplate.sendBodyAndHeader(endpointUri, jobExecution, EventType.HEADER_KEY, EventType.AFTER.name());
        LOG.debug("sent after job execution event");
    }
@Test
    public void shouldSendAfterJobEvent() throws Exception {
        // When
        jobExecutionListener.afterJob(jobExecution);

        // Then
        assertEquals(jobExecution, consumer().receiveBody("seda:eventQueue"));
    }