public final class Common
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
Common.Builder
Builder.
|
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.atomic.AtomicInteger |
getCountMachine()
Returns machine counter.
|
long |
getRequestCount()
Returns request counts that current processing.
|
SenderAdapter |
getSendData()
Returns response sender.
|
java.lang.String |
getServerIp()
Returns host address that current server.
|
void |
sendError(java.lang.String request,
int code,
java.lang.String message,
int index)
Send error message.
|
void |
sendErrorClose(java.lang.String request,
int code,
java.lang.String message,
int index)
Logging after sending error message and close connection.
|
void |
sendMonitor(int index,
long queueSize)
Send server status.
|
void |
sendPong(org.json.JSONObject json,
int index)
Send heartbeat.
|
void |
setMonitorAdditionalInfo(java.util.function.Supplier<java.lang.String> info)
Set the monitoring value to return additional additional information.
|
public void setMonitorAdditionalInfo(java.util.function.Supplier<java.lang.String> info)
info
- additional informationpublic void sendError(java.lang.String request, int code, java.lang.String message, int index)
request
- requestcode
- error codemessage
- messageindex
- indexpublic void sendErrorClose(java.lang.String request, int code, java.lang.String message, int index)
request
- requestcode
- error codemessage
- messageindex
- indexpublic void sendPong(org.json.JSONObject json, int index)
json
- jsonindex
- indexpublic void sendMonitor(int index, long queueSize)
index
- indexqueueSize
- queueSizepublic long getRequestCount()
public SenderAdapter getSendData()
public java.util.concurrent.atomic.AtomicInteger getCountMachine()
public java.lang.String getServerIp()