org.apache.yoko.orb.OB
Class MessageQueue

java.lang.Object
  extended by org.apache.yoko.orb.OB.MessageQueue

public class MessageQueue
extends Object


Field Summary
protected  Vector pending_
           
protected  Vector unsent_
           
 
Method Summary
 void add(ORBInstance orbInstance, Buffer buf)
           
 void add(ORBInstance orbInstance, Downcall down)
           
 Downcall findAndRemovePending(int reqId)
           
 Buffer getFirstUnsentBuffer()
           
 boolean hasUnsent()
           
 Downcall moveFirstUnsentToPending()
           
 void setException(int state, SystemException ex, boolean notCompleted)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

unsent_

protected Vector unsent_

pending_

protected Vector pending_
Method Detail

add

public void add(ORBInstance orbInstance,
                Buffer buf)

add

public void add(ORBInstance orbInstance,
                Downcall down)

getFirstUnsentBuffer

public Buffer getFirstUnsentBuffer()

moveFirstUnsentToPending

public Downcall moveFirstUnsentToPending()

findAndRemovePending

public Downcall findAndRemovePending(int reqId)

setException

public void setException(int state,
                         SystemException ex,
                         boolean notCompleted)

hasUnsent

public boolean hasUnsent()


Copyright © 2006-2011 Apache Software Foundation. All Rights Reserved.