com.jlupin.impl.client.util.queue

Class JLupinClientQueueUtil

java.lang.Object

com.jlupin.impl.client.util.queue.JLupinClientQueueUtil

public class JLupinClientQueueUtil
extends Object

Constructor Summary

Constructors

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)

Method Summary

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()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JLupinClientQueueUtil

public JLupinClientQueueUtil(String queueName,
                             JLupinQueueManagerService jLupinQueueManagerService,
                             Long waitForTaskResultInMillis,
                             Integer innerWaitQueuesAmount,
                             Integer threadsAmountForSingleInnerWaitQueues,
                             Integer switchTimeBetweenInnerWaitQueuesInMillis,
                             Integer waitTimeBetweenCheckingResultInMillis,
                             JLupinLogger jLupinLogger)

JLupinClientQueueUtil

public JLupinClientQueueUtil(String queueName,
                             JLupinQueueManagerService jLupinQueueManagerService,
                             JLupinLogger jLupinLogger)

JLupinClientQueueUtil

public JLupinClientQueueUtil(String queueName,
                             JLupinQueueManagerService jLupinQueueManagerService)

Method Detail

start

public void start()

registerFunctionOnTaskResult

public void registerFunctionOnTaskResult(String taskId,
                                         com.jlupin.interfaces.function.JLupinQueueReactiveFunction jLupinQueueReactiveFunction)

registerFunctionOnTaskResult

public void registerFunctionOnTaskResult(String taskId,
                                         Long waitForTaskResultInMillis,
                                         com.jlupin.interfaces.function.JLupinQueueReactiveFunction jLupinQueueReactiveFunction)

stop

public void stop()