public class FetchAndLockRequestDto extends RequestDto
Modifier and Type | Field and Description |
---|---|
protected Long |
asyncResponseTimeout |
protected int |
maxTasks |
protected List<TopicRequestDto> |
topics |
protected boolean |
usePriority |
workerId
Constructor and Description |
---|
FetchAndLockRequestDto(String workerId,
int maxTasks,
Long asyncResponseTimeout,
List<TopicRequestDto> topics) |
FetchAndLockRequestDto(String workerId,
int maxTasks,
Long asyncResponseTimeout,
List<TopicRequestDto> topics,
boolean usePriority) |
Modifier and Type | Method and Description |
---|---|
Long |
getAsyncResponseTimeout() |
int |
getMaxTasks() |
List<TopicRequestDto> |
getTopics() |
boolean |
isUsePriority() |
getWorkerId
protected int maxTasks
protected boolean usePriority
protected Long asyncResponseTimeout
protected List<TopicRequestDto> topics
public FetchAndLockRequestDto(String workerId, int maxTasks, Long asyncResponseTimeout, List<TopicRequestDto> topics)
public FetchAndLockRequestDto(String workerId, int maxTasks, Long asyncResponseTimeout, List<TopicRequestDto> topics, boolean usePriority)
public int getMaxTasks()
public boolean isUsePriority()
public List<TopicRequestDto> getTopics()
public Long getAsyncResponseTimeout()
Copyright © 2022. All rights reserved.