be.ac.ulg.montefiore.run.totem.socketInterface
Class Consumer

java.lang.Object
  be.ac.ulg.montefiore.run.totem.socketInterface.Consumer

All Implemented Interfaces:

java.lang.Runnable

public class Consumer
extends java.lang.Object
implements java.lang.Runnable

This class consumes elements found in the BlockingQueue filled by the Producer. Then it unmarshalls the message of this element which should be XML scenario events, and executes the corresponding action. It then write the response on the client stream.

Creation date: 03-06-2005

Author:

Olivier Delcourt (delcourt@run.montefiore.ulg.ac.be), Simon Balon (balon@run.montefiore.ulg.ac.be), Gael Monfort (monfort@run.montefiore.ulg.ac.be)

Constructor Summary

Consumer(java.util.concurrent.BlockingQueue<Server.Input> queue)

Method Summary

void

run()

Methods inherited from class java.lang.Object

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

Constructor Detail

Consumer

public Consumer(java.util.concurrent.BlockingQueue<Server.Input> queue)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable