@Override
    protected void execute() {
        try {
            final Task task = consume(Utility.GenerateRandomTaskType());
        } catch (IOException ex) {
            Logger.getLogger(ManualAckConsumer.class.getName()).log(Level.SEVERE, null, ex);
        } catch (InterruptedException ex) {
            Logger.getLogger(ManualAckConsumer.class.getName()).log(Level.SEVERE, null, ex);
        } catch (ClassNotFoundException ex) {
            Logger.getLogger(ManualAckConsumer.class.getName()).log(Level.SEVERE, null, ex);
        }
    }