qsqnk/task-processor

Task processor

This repository contains a simple persistent PostgreSQL-based task processor with RESTful API.

Table of Contents

• Endpoints
  • Submit Task
  • Get Task Info
• Usage
  • Creating runner
  • Submitting task

Endpoints

Submit Task

POST /api/v1/task

Request Body

{
  "runnerName": "Abc",
  "properties": {
      "a": "aValue",
      "b": 1
  }
}

Response Body

{
  "taskId": 1,
}

Get Task Info

GET /api/v1/task/{taskId}/info

Path Parameters

• taskId - ID of the task to get information about

Response Body

{
  "status": COMPLETED
}

Usage

Creating runner

Create class that implements TaskRunner interface and annotate it with @Component

@Component
class AbcRunner : TaskRunner {
    override val name = "Abc"

    override fun run(context: TaskContext) {
        // do something
    }
}

Submitting task

Create task and submit it using TaskService

val task = Task.Builder(runnerName = "Abc")
    .withProperty("a", TextNode("aValue"))
    .withProperty("b", LongNode(1))
    .build()
taskService.submit(
    task,
    delay = Duration.ZERO,
)