Package com.illumon.util.net

Class DelegatingCommServer

java.lang.Object

com.illumon.util.net.DelegatingCommServer

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable, CommServer

public class DelegatingCommServer
extends Object
implements CommServer

Allows treating multiple CommServer instances as if they were one. Limitations: If there is a "real" Server instance, it should be the first parameter, so that some internal impl details like port are handled correctly. Other details like handleCommand and addClientEntry can't be handled properly at all, and will throw exceptions.

Field Summary

Fields inherited from interface io.deephaven.enterprise.comm.api.CommServer

IGNORE_CACHE_CLIENTS, ONLY_CACHE_CLIENTS, SEND_TO_ALL

Constructor Summary

Constructors

Constructor	Description
DelegatingCommServer(CommServer... servers)

Method Summary

Modifier and Type	Method	Description
void	addClientEntry(ClientEntry client)
void	addClientEntry(ClientEntry client, CommServer server)
void	addCommandHandler(String id, CommandHandler commandHandler)
com.fishlib.base.log.LogOutput	append(com.fishlib.base.log.LogOutput logOutput)
void	disconnect()
List<ClientEntry>	getClientSet()
int	getPort()
void	handleCommand(ClientEntry client, com.fishlib.base.Command cmd)
void	removeCommandHandler(String id)
void	sendAsyncCommandWithResponse(ClientEntry client, String serviceId, com.fishlib.base.Command cmd, AsyncCommandHandler handler, long timeoutMillis, boolean allowFlush)
boolean	sendCommand(ClientEntry clientEntry, String id, com.fishlib.base.Command command, boolean allowFlush)
void	sendCommand(String id, com.fishlib.base.Command command)
void	sendCommand(String id, com.fishlib.base.Command command, int sendTo)
com.fishlib.base.Command	sendCommandWithResponse(ClientEntry client, String serviceId, com.fishlib.base.Command command, AsyncCommandHandler handler, long timeoutMillis, boolean allowFlush)
void	TEST_SOCKET_CLOSE()	For unit tests: throw out all connected clients, but don't shut down the server sockets.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.enterprise.comm.api.CommServer

sendCommand, sendCommandWithResponse, sendCommandWithResponse

Constructor Details

DelegatingCommServer

public DelegatingCommServer(CommServer... servers)

Method Details

getPort

public int getPort()

Specified by:

getPort in interface CommServer

sendCommand

public void sendCommand(String id,
 com.fishlib.base.Command command)

Specified by:

sendCommand in interface CommServer

sendCommand

public void sendCommand(String id,
 com.fishlib.base.Command command,
 int sendTo)

Specified by:

sendCommand in interface CommServer

sendCommand

public boolean sendCommand(ClientEntry clientEntry,
 String id,
 com.fishlib.base.Command command,
 boolean allowFlush)

Specified by:

sendCommand in interface CommServer

sendAsyncCommandWithResponse

public void sendAsyncCommandWithResponse(ClientEntry client,
 String serviceId,
 com.fishlib.base.Command cmd,
 AsyncCommandHandler handler,
 long timeoutMillis,
 boolean allowFlush)
                                  throws IOException

Specified by:

sendAsyncCommandWithResponse in interface CommServer

Throws:

IOException

sendCommandWithResponse

public com.fishlib.base.Command sendCommandWithResponse(ClientEntry client,
 String serviceId,
 com.fishlib.base.Command command,
 AsyncCommandHandler handler,
 long timeoutMillis,
 boolean allowFlush)
                                                 throws IOException

Specified by:

sendCommandWithResponse in interface CommServer

Throws:

IOException

getClientSet

public List<ClientEntry> getClientSet()

Specified by:

getClientSet in interface CommServer

addCommandHandler

public void addCommandHandler(String id,
 CommandHandler commandHandler)

Specified by:

addCommandHandler in interface CommServer

removeCommandHandler

public void removeCommandHandler(String id)

Specified by:

removeCommandHandler in interface CommServer

disconnect

public void disconnect()
                throws IOException

Specified by:

disconnect in interface CommServer

Throws:

IOException

handleCommand

public void handleCommand(ClientEntry client,
 com.fishlib.base.Command cmd)

Specified by:

handleCommand in interface CommServer

addClientEntry

public void addClientEntry(ClientEntry client)

Specified by:

addClientEntry in interface CommServer

addClientEntry

public void addClientEntry(ClientEntry client,
 CommServer server)

TEST_SOCKET_CLOSE

public void TEST_SOCKET_CLOSE()
                       throws IOException

Description copied from interface: CommServer

For unit tests: throw out all connected clients, but don't shut down the server sockets.

Specified by:

TEST_SOCKET_CLOSE in interface CommServer

Throws:

IOException

append

public com.fishlib.base.log.LogOutput append(com.fishlib.base.log.LogOutput logOutput)

Specified by:

append in interface com.fishlib.base.log.LogOutputAppendable