com.distributed.api
Class MessageReceiver

java.lang.Object
  |
  +--java.lang.Thread
        |
        +--com.distributed.api.MessageReceiver

All Implemented Interfaces:

java.lang.Runnable

public class MessageReceiver

extends java.lang.Thread

Class to implement Message Receiver. Listens to a channel

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

MessageReceiver(int lp, MessageReceiverListener l, java.io.BufferedReader datain, java.io.PrintWriter dataout)
Constructor to be normally used

MessageReceiver(MessageReceiverListener l, java.io.BufferedReader datain, java.io.PrintWriter dataout)
Constructor to be normally used

Method Summary

void	run() Method to Initiate Listener
void	terminate() Method to terminate the Receiving part

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageReceiver

public MessageReceiver(int lp,
                       MessageReceiverListener l,
                       java.io.BufferedReader datain,
                       java.io.PrintWriter dataout)

Constructor to be normally used

Parameters:

lp - ID of the Listener Process

l - Reference to Object to type Message Receiver Listener

datain - Socket Channel Reader

dataout - Socket Writer Object

MessageReceiver

public MessageReceiver(MessageReceiverListener l,
                       java.io.BufferedReader datain,
                       java.io.PrintWriter dataout)

Constructor to be normally used

Parameters:

l - Reference to Object to type Message Receiver Listener

datain - Socket Channel Reader

dataout - Socket Writer Object

Method Detail

run

public void run()

Method to Initiate Listener

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

terminate

public void terminate()

Method to terminate the Receiving part