Package it.polimi.ingsw.Server

Class SocketListener

java.lang.Object

it.polimi.ingsw.Server.SocketListener

All Implemented Interfaces:

Runnable

public class SocketListener
extends Object
implements Runnable

Given a SocketWrapper and a BlockingQueue<ClientEvent>, moves only the ClientEvent received on the socket to the queue.

Field Summary

Fields

Modifier and Type	Field	Description
private final BlockingQueue<ClientEvent>	queue
private final SocketWrapper	socket

Constructor Summary

Constructors

Modifier	Constructor	Description
private	SocketListener(SocketWrapper socket, BlockingQueue<ClientEvent> queue)	Construct the listener

Method Summary

Modifier and Type	Method	Description
void	run()	Listens on the SocketWrapper for messages, passes Messages implementing ClientEvent to the BlockingQueue<ClientEvent> for the server to read from.
static void	subscribe(SocketWrapper socket, BlockingQueue<ClientEvent> queue)	Given a socket and a queue, generate a listener and put it to work

Methods inherited from class java.lang.Object

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

Field Details

socket

private final SocketWrapper socket

queue

private final BlockingQueue<ClientEvent> queue

Constructor Details

SocketListener

private SocketListener(SocketWrapper socket,
 BlockingQueue<ClientEvent> queue)

Construct the listener

Parameters:

socket - the SocketWrapper to poll messages from

queue - the BlockingQueue<ClientEvent> to push events to

Method Details

subscribe

public static void subscribe(SocketWrapper socket,
 BlockingQueue<ClientEvent> queue)

Given a socket and a queue, generate a listener and put it to work

Parameters:

socket - the SocketWrapper to poll messages from

queue - the BlockingQueue<ClientEvent> to push events to

run

public void run()

Listens on the SocketWrapper for messages, passes Messages implementing ClientEvent to the BlockingQueue<ClientEvent> for the server to read from.
Note: in case of read errors from the socket, the socket will be closed and the listener terminated.

Specified by:

run in interface Runnable