public class oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies extends java.lang.Object
{
private int newQueueThreshold;
private int thresholdCheckMs;
private int maxQueues;
private java.util.concurrent.ThreadFactory threadFactory;
private static final int DEFAULT_QUEUE_THRESHOLD;
private static final int DEFAULT_THRESHOLD_CHECK_MS;
private static final int DEFAULT_MAX_QUEUES;
public static oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies$Builder builder()
{
oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies$Builder v;
v = new oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies$Builder;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies$Builder: void <init>()>();
return v;
}
int getNewQueueThreshold()
{
int v;
oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies v;
v := @this: oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies;
v = v.<oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies: int newQueueThreshold>;
return v;
}
int getThresholdCheckMs()
{
int v;
oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies v;
v := @this: oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies;
v = v.<oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies: int thresholdCheckMs>;
return v;
}
int getMaxQueues()
{
int v;
oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies v;
v := @this: oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies;
v = v.<oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies: int maxQueues>;
return v;
}
java.util.concurrent.ThreadFactory getThreadFactory()
{
oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies v;
java.util.concurrent.ThreadFactory v;
v := @this: oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies;
v = v.<oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies: java.util.concurrent.ThreadFactory threadFactory>;
return v;
}
private void <init>()
{
oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies v;
java.util.concurrent.ThreadFactory v;
v := @this: oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies: int newQueueThreshold> = 10000;
v.<oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies: int thresholdCheckMs> = 30000;
v.<oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies: int maxQueues> = 10;
v = <oadd.org.apache.curator.framework.recipes.queue.QueueBuilder: java.util.concurrent.ThreadFactory defaultThreadFactory>;
v.<oadd.org.apache.curator.framework.recipes.queue.QueueSharderPolicies: java.util.concurrent.ThreadFactory threadFactory> = v;
return;
}
}