public class AckedQueue extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
private int |
current |
private Vector<ProxyMessage> |
list |
static Logger |
logger
logger
|
private static long |
serialVersionUID
define serialVersionUID for interoperability
|
Constructor and Description |
---|
AckedQueue() |
Modifier and Type | Method and Description |
---|---|
void |
ack(long ackId) |
ProxyMessage |
get() |
void |
push(ProxyMessage msg) |
void |
reset() |
int |
size() |
private static final long serialVersionUID
public static Logger logger
private Vector<ProxyMessage> list
private int current
public void push(ProxyMessage msg)
public ProxyMessage get() throws InterruptedException
InterruptedException
public void ack(long ackId)
public void reset()
public int size()
Copyright © 2023 ScalAgent D.T.. All rights reserved.