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

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

All Implemented Interfaces:

java.lang.Runnable

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

It listens on a socket to messages and stores them in a BlockingQueue (along with client outputStream) where they will be read by the Consumer class.

Creation date: 03-June-2005

Author:

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

Constructor Summary

Producer(java.net.Socket client, 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

Producer

public Producer(java.net.Socket client,
                java.util.concurrent.BlockingQueue<Server.Input> queue)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable