Package bbflow_network

Class objectServer<T>

java.lang.Object
bbflow_network.objectServer<T>
Type Parameters:
T - Type of data received through TCP channel
All Implemented Interfaces:
Runnable
public class objectServer<T> extends Object implements Runnable
Server socket single threaded used to receive data from another node through TCP channel

  • Field Details

    • serverPort

      int serverPort

    • serverSocket

      ServerSocket serverSocket

    • isStopped

      boolean isStopped

    • runningThread

      Thread runningThread

    • queue

      ff_queue<T> queue

  • Constructor Details

    • objectServer

      public objectServer(int connectionId, ff_queue<T> q)

  • Method Details

    • run

      public void run()
      Specified by:
      run in interface Runnable

    • receiveData

      public void receiveData(Socket clientSocket)

    • isStopped

      private boolean isStopped()

    • stop

      public void stop()

    • openServerSocket

      private void openServerSocket()