Clients
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 build.gradle.kts 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:
- a
name
(optional) - a
pulsar
entry describing how to connect to Pulsar
# 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.