org.objectweb.joram.mom.proxies
Class AckedQueue
java.lang.Object
org.objectweb.joram.mom.proxies.AckedQueue
- All Implemented Interfaces:
- java.io.Serializable
public class AckedQueue
- extends java.lang.Object
- implements java.io.Serializable
- See Also:
- Serialized Form
Field Summary |
private int |
current
|
private java.util.Vector |
list
|
static org.objectweb.util.monolog.api.Logger |
logger
logger |
private static long |
serialVersionUID
define serialVersionUID for interoperability |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
serialVersionUID
private static final long serialVersionUID
- define serialVersionUID for interoperability
- See Also:
- Constant Field Values
logger
public static org.objectweb.util.monolog.api.Logger logger
- logger
list
private java.util.Vector list
current
private int current
AckedQueue
public AckedQueue()
push
public void push(ProxyMessage msg)
get
public ProxyMessage get()
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
ack
public void ack(long ackId)
reset
public void reset()
Copyright © 2010 ScalAgent D.T.. All Rights Reserved.