Client Creation

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

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

dependencies {
    ...
    implementation "io.infinitic:infinitic-client:0.13.0"
    ...
}

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

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 (optional): Specifies the name of the client
• pulsar: Details the connection parameters for Pulsar
• shutdownGracePeriodInSeconds (optional): Defines the grace period allotted to the client to complete its current actions before shutting down (default is 10.0 seconds).

# optional
name: client_name

pulsar:
  brokerServiceUrl: pulsar://localhost:6650
  webServiceUrl: http://localhost:8080
  tenant: infinitic
  namespace: dev
  ...

# optional
shutdownGracePeriodInSeconds: 10.0