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
Integer	getInnerWaitQueuesAmount()
Integer	getSwitchTimeBetweenInnerWaitQueuesInMillis()
Integer	getThreadsAmountForSingleInnerWaitQueues()
Long	getWaitForTaskResultInMillis()
Integer	getWaitTimeBetweenCheckingResultInMillis()
String	putTaskInput(String microserviceName, String serviceName, String methodName, Object[] args)
void	registerFunctionOnTaskResult(String taskId, com.jlupin.interfaces.function.JLupinQueueReactiveFunction jLupinQueueReactiveFunction)
void	registerFunctionOnTaskResult(String taskId, Long waitForTaskResultInMillis, com.jlupin.interfaces.function.JLupinQueueReactiveFunction jLupinQueueReactiveFunction)
void	setInnerWaitQueuesAmount(Integer innerWaitQueuesAmount)
void	setSwitchTimeBetweenInnerWaitQueuesInMillis(Integer switchTimeBetweenInnerWaitQueuesInMillis)
void	setThreadsAmountForSingleInnerWaitQueues(Integer threadsAmountForSingleInnerWaitQueues)
void	setWaitForTaskResultInMillis(Long waitForTaskResultInMillis)
void	setWaitTimeBetweenCheckingResultInMillis(Integer waitTimeBetweenCheckingResultInMillis)
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

putTaskInput

public String putTaskInput(String microserviceName,
                           String serviceName,
                           String methodName,
                           Object[] args)
                    throws JLupinClientQueueUtilException

Throws:

JLupinClientQueueUtilException

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

getWaitForTaskResultInMillis

public Long getWaitForTaskResultInMillis()

setWaitForTaskResultInMillis

public void setWaitForTaskResultInMillis(Long waitForTaskResultInMillis)

getInnerWaitQueuesAmount

public Integer getInnerWaitQueuesAmount()

setInnerWaitQueuesAmount

public void setInnerWaitQueuesAmount(Integer innerWaitQueuesAmount)

getThreadsAmountForSingleInnerWaitQueues

public Integer getThreadsAmountForSingleInnerWaitQueues()

setThreadsAmountForSingleInnerWaitQueues

public void setThreadsAmountForSingleInnerWaitQueues(Integer threadsAmountForSingleInnerWaitQueues)

getSwitchTimeBetweenInnerWaitQueuesInMillis

public Integer getSwitchTimeBetweenInnerWaitQueuesInMillis()

setSwitchTimeBetweenInnerWaitQueuesInMillis

public void setSwitchTimeBetweenInnerWaitQueuesInMillis(Integer switchTimeBetweenInnerWaitQueuesInMillis)

getWaitTimeBetweenCheckingResultInMillis

public Integer getWaitTimeBetweenCheckingResultInMillis()

setWaitTimeBetweenCheckingResultInMillis

public void setWaitTimeBetweenCheckingResultInMillis(Integer waitTimeBetweenCheckingResultInMillis)