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

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

public final class EventBus
extends Object

Field Summary

static long	cummulativeEventTime
static long	eventCount
static org.apache.log4j.Logger	logger

Constructor Summary

EventBus()

Method Summary

static void	failElement(EventListener l, FlowEvent event, String message)
static Collection	getAllEvents()
static EventBus	getBus()
protected static EventDispatcher	getDispatcher()
Queues	getQueues()
WorkerManager	getWorkerManager()
static void	initialize()
static boolean	isInitialized()
static void	post(EventListener target, Event event)
static void	removeEventHook()
static void	resumeAll()
static void	send(EventListener l, Event event)
static void	sendHooked(EventListener l, Event e)
static void	setEventHook(EventHook hook)
static void	suspendAll()
static boolean	waitForEvents()

Methods inherited from class java.lang.Object

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

Field Detail

logger

public static final org.apache.log4j.Logger logger

eventCount

public static volatile long eventCount

cummulativeEventTime

public static volatile long cummulativeEventTime

Constructor Detail

EventBus

public EventBus()

Method Detail

post

public static void post(EventListener target,
                        Event event)

getBus

public static EventBus getBus()

getWorkerManager

public WorkerManager getWorkerManager()

getQueues

public Queues getQueues()

initialize

public static void initialize()

suspendAll

public static void suspendAll()

resumeAll

public static void resumeAll()

isInitialized

public static boolean isInitialized()

setEventHook

public static void setEventHook(EventHook hook)

removeEventHook

public static void removeEventHook()

sendHooked

public static void sendHooked(EventListener l,
                              Event e)

send

public static void send(EventListener l,
                        Event event)

failElement

public static void failElement(EventListener l,
                               FlowEvent event,
                               String message)
                        throws ExecutionException

Throws:

ExecutionException

waitForEvents

public static boolean waitForEvents()

getAllEvents

public static Collection getAllEvents()

getDispatcher

protected static EventDispatcher getDispatcher()