Class ClientCommunicator

java.lang.Object

ch.autumo.beetroot.server.communication.Communicator

ch.autumo.beetroot.server.communication.ClientCommunicator

public class ClientCommunicator
extends Communicator

Client communicator.

Field Summary

Fields inherited from class Communicator

CMD_FILE_DELETE, CMD_FILE_RECEIVE_REQUEST, CMD_FILE_REQUEST, CMD_HEALTH, CMD_STOP, HTTP_HEADER_ACCEPT_JSON, HTTP_HEADER_CONTENTTYPE_JSON_UTF8, LOG, MAX_MSG_SIZE, TIMEOUT, USER_AGENT

Modifier and Type	Field	Description
static final String	CMD_FILE_DELETE	File delete
static final String	CMD_FILE_RECEIVE_REQUEST	File receive request for upload
static final String	CMD_FILE_REQUEST	File request for download
static final String	CMD_HEALTH	Health command
static final String	CMD_STOP	Stop command
static final String[]	HTTP_HEADER_ACCEPT_JSON	HTTP Header accept with 'application/json'.
static final String[]	HTTP_HEADER_CONTENTTYPE_JSON_UTF8	HTTP Header accept with 'application/json; charset=utf-8'.
protected static final org.slf4j.Logger	LOG	Logger for this class.
static final int	MAX_MSG_SIZE	Max.
static final int	TIMEOUT	Connection timeout in seconds
static final String	USER_AGENT	User agents used for tunneled server commands.

Constructor Summary

Constructors

Constructor	Description
ClientCommunicator()	Default constructor.

Method Summary

Modifier and Type	Method	Description
static ClientAnswer	readAnswer(DataInputStream in)	Read an answer from the server client side.
static void	reInit()	Re-initialize client communicator.
static ClientAnswer	sendServerCommand(ServerCommand command)	Send a server command client side.

Methods inherited from class Communicator

checkHttpResponse, isInternalCommand, read, readCommand, readJsonCommand, safeClose, writeAnswer

Modifier and Type	Method	Description
static void	checkHttpResponse(org.apache.http.client.methods.CloseableHttpResponse resp)	Check closeable HTTP response with HttpResponse.
protected static boolean	isInternalCommand(ServerCommand command)	Is it an internal command?
protected static String	read(DataInputStream in)	Server- or client-side read.
static ServerCommand	readCommand(DataInputStream in)	Read a server command server side.
static ServerCommand	readJsonCommand(InputStream in, int length)	Read a JSON server command server side.
static final void	safeClose(Object closeable)	Safe close for closeable object (e.g.
static void	writeAnswer(ClientAnswer answer, DataOutputStream out)	Write/send client answer from server to client.

Methods inherited from class Object

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

Constructor Details

ClientCommunicator

public ClientCommunicator()

Default constructor.

Method Details

reInit

public static void reInit()

Re-initialize client communicator.

sendServerCommand

public static ClientAnswer sendServerCommand(ServerCommand command)
                                      throws Exception

Send a server command client side.

Parameters:

command - server command

Returns:

client answer

Throws:

Exception - exception

readAnswer

public static ClientAnswer readAnswer(DataInputStream in)
                               throws IOException

Read an answer from the server client side.

Parameters:

in - input stream

Returns:

client answer or null, if answer received was invalid

Throws:

IOException - IO exception