Package VASSAL.tools.ipc

Class IPCMessenger

java.lang.Object

VASSAL.tools.ipc.IPCMessenger

public class IPCMessenger
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected ObjectInputStream	in
protected MultiEventListenerSupport	lsup
protected AtomicLong	next_id
protected ObjectOutputStream	out
protected BlockingQueue<IPCMessage>	outqueue
protected Map<Long,CompletableFuture<IPCMessage>>	waiting

Constructor Summary

Constructors

Constructor	Description
IPCMessenger(InputStream in, OutputStream out)
IPCMessenger(InputStream in, OutputStream out, MultiEventListenerSupport lsup)
IPCMessenger(Socket sock)

Method Summary

Modifier and Type	Method	Description
<T> void	addEventListener(Class<T> c, EventListener<? super T> l)	Adds an EventListener.
<T> List<EventListener<? super T>>	getEventListeners(Class<T> c)	Notify the listeners of an event.
boolean	hasEventListeners(Class<?> c)	Checks whether there are any EventListeners.
<T> void	removeEventListener(Class<T> c, EventListener<? super T> l)	Removes an EventListener.
Future<IPCMessage>	send(IPCMessage msg)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

next_id

protected final AtomicLong next_id

waiting

protected final Map<Long,CompletableFuture<IPCMessage>> waiting

outqueue

protected final BlockingQueue<IPCMessage> outqueue

in

protected final ObjectInputStream in

out

protected final ObjectOutputStream out

lsup

protected final MultiEventListenerSupport lsup

Constructor Details

IPCMessenger

public IPCMessenger(InputStream in,
OutputStream out,
MultiEventListenerSupport lsup)
             throws IOException

Throws:

IOException

IPCMessenger

public IPCMessenger(Socket sock)
             throws IOException

Throws:

IOException

IPCMessenger

public IPCMessenger(InputStream in,
OutputStream out)
             throws IOException

Throws:

IOException

Method Details

start

public void start()
           throws IOException

Throws:

IOException

stop

public void stop()
          throws IOException

Throws:

IOException

send

public Future<IPCMessage> send(IPCMessage msg)
                        throws IOException

Throws:

IOException

addEventListener

public <T> void addEventListener(Class<T> c,
EventListener<? super T> l)

Adds an EventListener.

Parameters:

c - the class to listen for

l - the listener to add

removeEventListener

public <T> void removeEventListener(Class<T> c,
EventListener<? super T> l)

Removes an EventListener.

Parameters:

c - the class to check

l - the listener to remove

hasEventListeners

public boolean hasEventListeners(Class<?> c)

Checks whether there are any EventListeners.

Parameters:

c - the class to check

Returns:

true if there are any listeners for the given class

getEventListeners

public <T> List<EventListener<? super T>> getEventListeners(Class<T> c)

Notify the listeners of an event.

Parameters:

event - the event to send