public class JLupinClientQueueUtil extends Object
| Constructor and Description |
|---|
JLupinClientQueueUtil(String queueName,
JLupinQueueManagerService jLupinQueueManagerService) |
JLupinClientQueueUtil(String queueName,
JLupinQueueManagerService jLupinQueueManagerService,
JLupinLogger jLupinLogger) |
JLupinClientQueueUtil(String queueName,
JLupinQueueManagerService jLupinQueueManagerService,
Long waitForTaskResultInMillis,
Integer innerWaitQueuesAmount,
Integer threadsAmountForSingleInnerWaitQueues,
Integer switchTimeBetweenInnerWaitQueuesInMillis,
Integer waitTimeBetweenCheckingResultInMillis,
JLupinLogger jLupinLogger) |
| Modifier and Type | Method and Description |
|---|---|
void |
registerFunctionOnTaskResult(String taskId,
com.jlupin.interfaces.function.JLupinQueueReactiveFunction jLupinQueueReactiveFunction) |
void |
registerFunctionOnTaskResult(String taskId,
Long waitForTaskResultInMillis,
com.jlupin.interfaces.function.JLupinQueueReactiveFunction jLupinQueueReactiveFunction) |
void |
start() |
void |
stop() |
public JLupinClientQueueUtil(String queueName, JLupinQueueManagerService jLupinQueueManagerService, Long waitForTaskResultInMillis, Integer innerWaitQueuesAmount, Integer threadsAmountForSingleInnerWaitQueues, Integer switchTimeBetweenInnerWaitQueuesInMillis, Integer waitTimeBetweenCheckingResultInMillis, JLupinLogger jLupinLogger)
public JLupinClientQueueUtil(String queueName, JLupinQueueManagerService jLupinQueueManagerService, JLupinLogger jLupinLogger)
public JLupinClientQueueUtil(String queueName, JLupinQueueManagerService jLupinQueueManagerService)
public void start()
public void registerFunctionOnTaskResult(String taskId, com.jlupin.interfaces.function.JLupinQueueReactiveFunction jLupinQueueReactiveFunction)
public void registerFunctionOnTaskResult(String taskId, Long waitForTaskResultInMillis, com.jlupin.interfaces.function.JLupinQueueReactiveFunction jLupinQueueReactiveFunction)
public void stop()