@Override
    protected void execute() {
        try {
            final Task task = consume(Utility.GenerateRandomTaskType());
            
           
            //channel.close();
            //connection.close();
            //ConnectionFactory factory = new ConnectionFactory();
            //factory.setHost("127.0.0.1");
            //connection = factory.newConnection();
            //channel = connection.createChannel();
        } catch (IOException | InterruptedException | ClassNotFoundException ex) {
            
        }
    }