com.purpletech.message.server
Class Processor

java.lang.Object
  |
  +--com.purpletech.util.ActiveTask
        |
        +--com.purpletech.message.server.Processor

All Implemented Interfaces:

java.lang.Runnable, Task

public class Processor

extends ActiveTask

The processor reads messages from the incoming queue and decides how to deal with them.

Version:

$Id: Processor.java,v 1.2 2001/10/30 12:20:52 alex Exp $

Author:

Alex

Field Summary

Fields inherited from class com.purpletech.util.ActiveTask

doStop, name, priority, watcher

Constructor Summary

Processor(MessageServer server, Queue incoming, ClientSet clients, java.util.List problems, Splitter splitter, ProcessorCounter counter, Namer namer)
Initialize this object.

Method Summary

protected void	processSystemMessage(Message m)
void	run() walk through the message queue (incoming) and deliver messages to recipients

Methods inherited from class com.purpletech.util.ActiveTask

setName, setPriority, setWatcher, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

Processor

public Processor(MessageServer server,
                 Queue incoming,
                 ClientSet clients,
                 java.util.List problems,
                 Splitter splitter,
                 ProcessorCounter counter,
                 Namer namer)

Initialize this object.

Method Detail

run

public void run()

walk through the message queue (incoming) and deliver messages to recipients

processSystemMessage

protected void processSystemMessage(Message m)