org.globus.cog.karajan.workflow.events
Class Queues

java.lang.Object
  org.globus.cog.karajan.workflow.events.Queues

public class Queues
extends Object

Constructor Summary

Queues()

Method Summary

void	enqueue(EventTargetPair etp)
Collection	getAll() Must be run with a suspended bus, otherwise the result will be meaningless
EventTargetPair	nextEvent()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Queues

public Queues()

Method Detail

enqueue

public final void enqueue(EventTargetPair etp)

nextEvent

public EventTargetPair nextEvent()
                          throws InterruptedException

Throws:

InterruptedException

getAll

public Collection getAll()

Must be run with a suspended bus, otherwise the result will be meaningless