com.bea.alsb.debug.internal.client

Class AbstractEventQueue<E>

java.lang.Object

com.bea.alsb.debug.internal.client.ALSBDebuggerObject

com.bea.alsb.debug.internal.client.AbstractEventQueue<E>

All Implemented Interfaces:

IALSBDebuggerObject, IEventPacketListener

Direct Known Subclasses:

EventQueue

public abstract class AbstractEventQueue<E>
extends ALSBDebuggerObject
implements IEventPacketListener

implementation of an event queue

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractEventQueue(ALSBDebugger debugger) constructor

Method Summary

Modifier and Type	Method and Description
void	close() closes this queue
protected abstract E	createEvent(Packet packet) creates an event for a packet
void	newEvent(Packet packet) notifies of a new event
E	remove() Waits forever for the next available event.
E	remove(long timeout) Waits a specified time for the next available event.

Methods inherited from class com.bea.alsb.debug.internal.client.ALSBDebuggerObject

debugger, equals, hashCode, validate

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bea.alsb.debug.client.IALSBDebuggerObject

toString

Constructor Detail

AbstractEventQueue

protected AbstractEventQueue(ALSBDebugger debugger)

constructor

Method Detail

createEvent

protected abstract E createEvent(Packet packet)
                          throws java.lang.Exception

creates an event for a packet

Throws:

java.lang.Exception

remove

public E remove()
         throws java.lang.InterruptedException

Waits forever for the next available event.

Throws:

java.lang.InterruptedException

remove

public E remove(long timeout)
         throws java.lang.InterruptedException

Waits a specified time for the next available event.

Throws:

java.lang.InterruptedException

newEvent

public void newEvent(Packet packet)

notifies of a new event

Specified by:

newEvent in interface IEventPacketListener

close

public void close()

closes this queue