Package com.example.common.listener

Class BaseListener

java.lang.Object

java.lang.Thread

com.example.common.listener.BaseListener

All Implemented Interfaces:

Listener, Runnable

Direct Known Subclasses:

BaseClientListener, BaseServerListener

public abstract class BaseListener
extends Thread
implements Listener

BaseListener class implements a basic listener functionality for receiving and sending messages. It extends Thread class and implements the Listener interface.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected StreamIO	streamIO
protected TransportListener	transportListener

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
BaseListener(int portIn, StreamIO streamIO, TransportFactory transportFactory)	Constructor for BaseListener class.

Method Summary

Modifier and Type	Method	Description
void	run()	Continuously waits for incoming messages and processes them using the worker method.
protected abstract void	worker()	Abstract method that must be implemented by subclasses to define the processing of incoming messages.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.example.common.listener.Listener

interrupt, setDaemon, start

Field Details

transportListener

protected TransportListener transportListener

streamIO

protected StreamIO streamIO

Constructor Details

BaseListener

public BaseListener(int portIn,
 StreamIO streamIO,
 TransportFactory transportFactory)

Constructor for BaseListener class.

Parameters:

portIn - the input port number to listen for incoming connections

streamIO - the StreamIO object for handling input and output streams

transportFactory - the TransportFactory object for creating a listener

Method Details

run

public void run()

Continuously waits for incoming messages and processes them using the worker method.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

worker

protected abstract void worker()
                        throws IOException

Abstract method that must be implemented by subclasses to define the processing of incoming messages.

Throws:

IOException - if an error occurs while receiving or processing the message