Example Failure; NoSuchConstructorException about jesque HOT 4 CLOSED

public abstract class AbstractDelayedMessageSource<T> extends IntegrationObjectSupport implements MessageSource, DisposableBean {

    private final Worker jesqueWorker;
    private final SynchronousQueue<T> queue = new SynchronousQueue<>();
    private final ObjectMapper objectMapper;


    protected AbstractDelayedMessageSource(Config config, ObjectMapper mapper) {
        this.jesqueWorker = new WorkerImpl(config, Arrays.asList("foo"),
                new MapBasedJobFactory(map(entry("MessageDispatcher", MessageDispatcher.class))));
        this.objectMapper = mapper;
    }

    @Override
    protected void onInit() throws Exception {
        super.onInit();
        Thread workerThread = new Thread(jesqueWorker);
        workerThread.start();
    }

    public void destroy() throws Exception {
        jesqueWorker.end(true);
    }

    @Override
    public Message<T> receive() {
        T payload = null;
        try {
            payload = queue.take();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return this.getMessageBuilderFactory().withPayload(payload).build();
    }

    private T deserializeJsonString(String jsonString) {
        try {
            Class<T> type =(Class<T>) GenericTypeResolver.resolveTypeArgument(getClass(), AbstractDelayedMessageSource.class);
            return objectMapper.readerFor(type).readValue(jsonString);
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

    public class MessageDispatcher implements Runnable {
        private final String jsonString;

        public MessageDispatcher(String jsonString) {
            this.jsonString = jsonString;
        }

        @Override
        public void run() {

            T object = deserializeJsonString(jsonString);
            queue.offer(object);
        }
    }
}