Client Creation

An Infinitic client lets us start, retry and cancel tasks or workflows, usually from our Web App controllers.

Client

First, add the infinitic-client dependency into our build.gradle file:

dependencies {
    ...
    implementation "io.infinitic:infinitic-client:0.11.+"
    ...
}

dependencies {
    ...
    implementation("io.infinitic:infinitic-client:0.11.+")
    ...
}

We can then instantiate a client from a configuration file in the file system:

import io.infinitic.clients.InfiniticClient;
...
InfiniticClient client = InfiniticClient.fromConfigFile("infinitic.yml");

import io.infinitic.clients.InfiniticClient
...
val client = InfiniticClient.fromConfigFile("infinitic.yml")

or in the resource folder:

import io.infinitic.clients.InfiniticClient;
...
InfiniticClient client = InfiniticClient.fromConfigResource("/infinitic.yml");

import io.infinitic.clients.InfiniticClient
...
val client = InfiniticClient.fromConfigResource("/infinitic.yml")

The infinitic.yml configuration file should contain:

# name is optional
name: client_name

pulsar: ...

When providing a name, it must be unique among all clients connected to Pulsar, as it will be used as Pulsar producer name.