org.objectweb.joram.mom.proxies
Class AckedQueue

java.lang.Object
  extended by 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
 
Constructor Summary
AckedQueue()
           
 
Method Summary
 void ack(long ackId)
           
 ProxyMessage get()
           
 void push(ProxyMessage msg)
           
 void reset()
           
 
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

public static org.objectweb.util.monolog.api.Logger logger
logger


list

private java.util.Vector list

current

private int current
Constructor Detail

AckedQueue

public AckedQueue()
Method Detail

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.