org.processmining.streamer.utils

Class BroadcastService

java.lang.Object

java.lang.Thread

org.processmining.streamer.utils.BroadcastService

All Implemented Interfaces:

java.lang.Runnable

public class BroadcastService
extends java.lang.Thread

This class is a broadcasting service. This class allows to keep connections with many clients and to broadcast them messages. This service is also a Thread because, as long as it is open, it must accept all the incoming clients.

Author:

Andrea Burattin

Nested Class Summary

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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
BroadcastService(int port) Basic broadcast service constructor

Method Summary

Modifier and Type	Method and Description
void	close() Method to close the current broadcasting service and shutdown the thread that listens for new clients.
void	open() Method to open the broadcasting service.
void	open(int port) Method to open the broadcasting service.
void	run()
void	send(java.lang.String message) This method sends a message to all the clients connected.

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Constructor Detail

BroadcastService

public BroadcastService(int port)

Basic broadcast service constructor

Parameters:

port - the port for the connections

Method Detail

open

public void open()
          throws java.io.IOException

Method to open the broadcasting service. This method wraps the call to the Thread.start() method.

Throws:

java.io.IOException - socket opening errors (e.g. port already used)

open

public void open(int port)
          throws java.io.IOException

Method to open the broadcasting service. This method wraps the call to the Thread.start() method.

Parameters:

port - the port for the connections

Throws:

java.io.IOException - socket opening errors (e.g. port already used)

close

public void close()
           throws java.io.IOException

Method to close the current broadcasting service and shutdown the thread that listens for new clients. This method contains a call to Thread.join().

Throws:

java.io.IOException

send

public void send(java.lang.String message)

This method sends a message to all the clients connected. This method can identify if a client is not connected anymore, and remove it from the connected clients list.

Parameters:

message - the message to be sent

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread