toolbox.queueing
Class ListenerGroup

java.lang.Object
  toolbox.queueing.ListenerGroup

public class ListenerGroup
extends java.lang.Object

Class to configure, instantiate and manage Listener threads.

Constructor Summary

ListenerGroup(java.lang.String conf, Worker worker)
Create a new ListenerGroup.

ListenerGroup(XMLProperties xmlProps, Worker worker)
Create a new ListenerGroup.

Method Summary

void	assign(java.lang.Object event) Assign an event to the ListenerGroup
void	destroy() Destroy the ListenerGroup by stopping all Listener threads.

Methods inherited from class java.lang.Object

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

Constructor Detail

ListenerGroup

public ListenerGroup(XMLProperties xmlProps,
                     Worker worker)
              throws ConfException,
                     java.io.IOException

Create a new ListenerGroup.

Parameters:

xmlProps - XMLProperties instance containing the queueing config.

worker - Worker implementation.

Throws:

ConfException

java.io.IOException

ListenerGroup

public ListenerGroup(java.lang.String conf,
                     Worker worker)
              throws ConfException,
                     java.io.IOException

Create a new ListenerGroup.

Parameters:

conf - Location of queueing configuration file.

worker - Worker implementation.

Throws:

ConfException

java.io.IOException

Method Detail

assign

public void assign(java.lang.Object event)
            throws QueueDiscardWarning

Assign an event to the ListenerGroup

Parameters:

event - Object containing event.

Throws:

QueueDiscardWarning

destroy

public void destroy()

Destroy the ListenerGroup by stopping all Listener threads.