Spring Boot Image Service

image-service/
  src/main/java/example/
    ImageServiceApplication.java   # Spring Boot app + FlexiQ config
    ImageTasks.java                # the processImage task + handler
    ImageController.java           # the REST surface
    WorkerRunner.java              # starts the worker with the app
  src/main/resources/application.yaml

dependencies {
    implementation("org.byteveda:flexiq")
    implementation("org.byteveda:flexiq-spring")
    implementation("org.springframework.boot:spring-boot-starter-web")
}

# application.yaml
flexiq:
  url: image-service.db   # SQLite; or a postgres:// / redis:// URL

package example;

import java.util.ArrayList;
import java.util.List;
import org.byteveda.flexiq.task.Task;
import org.springframework.stereotype.Component;

@Component
public class ImageTasks {

    public record ProcessImage(String url, List<Integer> sizes) {}

    public record Variant(int size, String key) {}

    public static final Task<ProcessImage> PROCESS_IMAGE =
            Task.of("process_image", ProcessImage.class)
                    .maxRetries(2)
                    .timeoutMs(120_000);

    public List<Variant> process(ProcessImage payload) throws Exception {
        List<Variant> variants = new ArrayList<>();
        for (int size : payload.sizes()) {
            resize(payload.url(), size); // your real work here
            variants.add(new Variant(size, payload.url() + "@" + size + ".webp"));
        }
        return variants;
    }

    private void resize(String url, int size) throws Exception {
        // ...
    }
}

package example;

import java.util.Map;
import org.byteveda.flexiq.FlexiQ;
import org.byteveda.flexiq.task.EnqueueOptions;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;

@RestController
@RequestMapping("/images")
public class ImageController {
    private final FlexiQ flexiq;

    public ImageController(FlexiQ flexiq) {
        this.flexiq = flexiq;
    }

    @PostMapping
    public ResponseEntity<Map<String, String>> submit(@RequestBody ImageTasks.ProcessImage request) {
        String jobId = flexiq.enqueue(
                ImageTasks.PROCESS_IMAGE,
                request,
                EnqueueOptions.builder().priority(5).build());
        return ResponseEntity.accepted().body(Map.of("jobId", jobId));
    }

    @GetMapping("/{id}")
    public ResponseEntity<Map<String, Object>> status(@PathVariable String id) {
        return flexiq.getJob(id)
                .map(job -> ResponseEntity.ok(Map.<String, Object>of(
                        "status", job.status.wire(),
                        "progress", job.progress == null ? 0 : job.progress,
                        "error", job.error == null ? "" : job.error)))
                .orElse(ResponseEntity.notFound().build());
    }

    @PostMapping("/{id}/cancel")
    public Map<String, Boolean> cancel(@PathVariable String id) {
        // cancel() pulls a pending job; requestCancel() flags a running one.
        boolean cancelled = flexiq.cancel(id) || flexiq.requestCancel(id);
        return Map.of("cancelled", cancelled);
    }
}

package example;

import org.byteveda.flexiq.FlexiQ;
import org.byteveda.flexiq.worker.Worker;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class WorkerRunner {

    @Bean(destroyMethod = "close")
    public Worker worker(FlexiQ flexiq, ImageTasks tasks) {
        return flexiq.worker()
                .handle(ImageTasks.PROCESS_IMAGE, tasks::process)
                .queues("default")
                .concurrency(4)
                .start();
    }
}

./gradlew bootRun
# POST http://localhost:8080/images  {"url": "...", "sizes": [256, 512, 1024]}
# GET  http://localhost:8080/images/<jobId>