public class QueueState extends Object
Constructor and Description |
---|
QueueState(long lastProcessedOffset,
int headRetries,
int maxRetries,
ClearCallback clearCallback) |
Modifier and Type | Method and Description |
---|---|
ClearCallback |
getClearCallback() |
int |
getHeadRetries() |
long |
getLastProcessedOffset() |
int |
getMaxRetries() |
public QueueState(long lastProcessedOffset, int headRetries, int maxRetries, ClearCallback clearCallback)
public long getLastProcessedOffset()
public int getHeadRetries()
public int getMaxRetries()
public ClearCallback getClearCallback()
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.