AckedQueue (JORAM 5.24.0 API)

java.lang.Object
- org.objectweb.joram.mom.proxies.AckedQueue

All Implemented Interfaces:: Serializable

public class AckedQueue
extends Object
implements Serializable

See Also:: Serialized Form

Field Summary

Fields
Modifier and Type	Field	Description
`private int`	`current`
`private static boolean`	`DEBUG`
`private Vector<ProxyMessage>`	`list`
`private static Logger`	`logger`	logger
`private static long`	`serialVersionUID`	define serialVersionUID for interoperability

Constructor Summary

Constructors
Constructor Description

AckedQueue()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`ack(long ackId)`
`ProxyMessage`	`get()`
`void`	`push(ProxyMessage msg)`
`void`	`reset()`
`int`	`size()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

serialVersionUID
```
private static final long serialVersionUID
```
define serialVersionUID for interoperability

See Also:

Constant Field Values

logger
```
private static final Logger logger
```
logger

DEBUG
```
private static final boolean DEBUG
```

list
```
private Vector<ProxyMessage> list
```

current
```
private int current
```

Constructor Detail
- AckedQueue
```
public AckedQueue()
```

Method Detail

push

public void push(ProxyMessage msg)

get

public ProxyMessage get()
                 throws InterruptedException

Throws:: InterruptedException

ack
```
public void ack(long ackId)
```

reset
```
public void reset()
```

size
```
public int size()
```