version: 0.24.0-alpha1
Gateway and broker are deployed on two Linux respectively.
@ZeebeWorker(type = "node1")
public void node1(final JobClient client, final ActivatedJob job){
client.newCompleteCommand(job.getKey()).variables(job.getVariables()).send();
}
@ZeebeWorker(type = "node2")
public void node2(final JobClient client, final ActivatedJob job){
client.newCompleteCommand(job.getKey()).variables(job.getVariables()).send();
}
@ZeebeWorker(type = "node3")
public void node3(final JobClient client, final ActivatedJob job){
client.newCompleteCommand(job.getKey()).variables(job.getVariables()).send();
}
@ZeebeWorker(type = "node4")
public void node4(final JobClient client, final ActivatedJob job){
client.newCompleteCommand(job.getKey()).variables(job.getVariables()).send();
}
@ZeebeWorker(type = "node5")
public void node5(final JobClient client, final ActivatedJob job){
client.newCompleteCommand(job.getKey()).variables(job.getVariables()).send();
}
@ZeebeWorker(type = "node6")
public void node6(final JobClient client, final ActivatedJob job){
client.newCompleteCommand(job.getKey()).variables(job.getVariables()).send();
}
There is nothing special about my jobworker.
But jobworker cannot get jobs in real time. Even if it is polling to get the job, it should not be 20 seconds. It is too regular. When I used the embedded gateway, I did not encounter this problem.