public class SubscriberIdle extends Object implements IdleCheck
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_FORCE_IDLE_MILLIS |
static int |
DEFAULT_IDLE_TIME_MILLIS |
static int |
MAX_RETRIES |
Constructor and Description |
---|
SubscriberIdle(int idleMillis,
int forceIdleMillies,
AtomicBoolean readyHolder) |
Modifier and Type | Method and Description |
---|---|
void |
busy(int retries)
Called when processing of a message starts
|
void |
close() |
void |
idle()
Called when processing of a message has finished
|
boolean |
isIdle() |
public static final int DEFAULT_IDLE_TIME_MILLIS
public static final int DEFAULT_FORCE_IDLE_MILLIS
public static final int MAX_RETRIES
public SubscriberIdle(int idleMillis, int forceIdleMillies, AtomicBoolean readyHolder)
public void busy(int retries)
public void idle()
public void close()
close
in interface Closeable
close
in interface AutoCloseable
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.