Package org.enanoservices.servermonitor

Class ThisServer

java.lang.Object

org.enanoservices.servermonitor.Server

org.enanoservices.servermonitor.ThisServer

@Component
public class ThisServer
extends Server

Field Summary

Fields inherited from class org.enanoservices.servermonitor.Server

accHbDelay, adminState, context, downTime, heartBeatAlarmDelay, host, lastHeartBeat, maxHbDelay, microservice, minHbDelay, numHeartBeats, port, state

Constructor Summary

Constructors

Constructor	Description
ThisServer()

Method Summary

Modifier and Type	Method	Description
void	checkHearBeatTimeout(long nowMs, IServerMonitor monitor)	called from ServerHolder.updateServersState(), from ServerMonitorThread - check if heart beat has been received within the last x ms - change the server state to disconnect if it hasn't - no action if server is connected since the heartbeat message will be updating the server state
BrokerMessageHeader	createBrokerMessageHeader(java.lang.String msgType)
java.lang.String	createHeartBeatMsg()	create heart-beat message
long	getAccRespTime()
java.lang.String	getAvgRespTime()
java.lang.String	getBegStatsIntv()
java.lang.String	getEndStatsIntv()
java.lang.String	getIntvDuration()
java.lang.String	getMaxReqPerHour()
int	getMaxRespTime()
int	getMinRespTime()
int	getReqCounter()
int	getReqPerHour()
ThisServerInfo	getServerInfo()
ThisServerStatus	getStatus()
boolean	isThisServer(java.lang.String host, java.lang.String microservice, java.lang.String port)	check if message has been sent by this server
void	logTransition(org.enanoservices.servermonitor.ServerState.State prevState, org.enanoservices.servermonitor.ServerState.State nextState, org.enanoservices.servermonitor.ServerEvent.Event event)
void	processHeartBeat(org.enanoservices.servermonitor.HeartBeatBody body, long timeSent, IServerMonitor monitor)	process heart-beat but only for remote servers not for this one ThisServer overrides this method first heart-beat reports server as disconnected, which is finetoggleAdminState server not connected detected in checkHearBeatTimeout, called by ServerMonitorThread caller needs to obtain the lock
void	resetRespStats()
void	updateRespStats(int respTime)
void	updateState(org.enanoservices.servermonitor.ServerEvent.Event event, IServerMonitor monitor)

Methods inherited from class java.lang.Object

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

Methods inherited from class org.enanoservices.servermonitor.Server

calcHeartBeatDelay, checkIfServer, getAdminClientState, getAdminState, getClientState, getContext, getCtxUrl, getHbAvgDelay, getHost, getLastHeartBeat, getMaxHbDelay, getMicroservice, getMinHbDelay, getNsVersion, getOrigin, getPort, getServerState, getServVersion, getSrvVersion, getState, getUrl, init, isAdminUp, isDisconnected, resetHeartBeatCounters, setNsVersion, setSrvVersion, setState, toggleAdminState

Constructor Detail

ThisServer

public ThisServer()

Method Detail

getReqCounter

public int getReqCounter()

getStatus

public ThisServerStatus getStatus()

getReqPerHour

public int getReqPerHour()

getAvgRespTime

public java.lang.String getAvgRespTime()

getMinRespTime

public int getMinRespTime()

getMaxRespTime

public int getMaxRespTime()

getAccRespTime

public long getAccRespTime()

updateRespStats

public void updateRespStats(int respTime)

getMaxReqPerHour

public java.lang.String getMaxReqPerHour()

getBegStatsIntv

public java.lang.String getBegStatsIntv()

getEndStatsIntv

public java.lang.String getEndStatsIntv()

getIntvDuration

public java.lang.String getIntvDuration()

isThisServer

public boolean isThisServer(java.lang.String host,
                            java.lang.String microservice,
                            java.lang.String port)

check if message has been sent by this server

Parameters:

host - - not null

microservice - - not null

port - - not null

Returns:

- true if it's this server

createBrokerMessageHeader

public BrokerMessageHeader createBrokerMessageHeader(java.lang.String msgType)

processHeartBeat

public void processHeartBeat(org.enanoservices.servermonitor.HeartBeatBody body,
                             long timeSent,
                             IServerMonitor monitor)

Description copied from class: Server

process heart-beat but only for remote servers not for this one ThisServer overrides this method first heart-beat reports server as disconnected, which is finetoggleAdminState server not connected detected in checkHearBeatTimeout, called by ServerMonitorThread caller needs to obtain the lock

Overrides:

processHeartBeat in class Server

Parameters:

body - - HeartBeatBody

timeSent - - time mesage sent, it comes from BrokerMessageHeader.tms

monitor - - server monitor object

checkHearBeatTimeout

public void checkHearBeatTimeout(long nowMs,
                                 IServerMonitor monitor)

called from ServerHolder.updateServersState(), from ServerMonitorThread - check if heart beat has been received within the last x ms - change the server state to disconnect if it hasn't - no action if server is connected since the heartbeat message will be updating the server state

Overrides:

checkHearBeatTimeout in class Server

Parameters:

nowMs - - current time

monitor - - IServerMonitor monitor

createHeartBeatMsg

public java.lang.String createHeartBeatMsg()

create heart-beat message

Returns:

- serielized message

updateState

public void updateState(org.enanoservices.servermonitor.ServerEvent.Event event,
                        IServerMonitor monitor)

logTransition

public void logTransition(org.enanoservices.servermonitor.ServerState.State prevState,
                          org.enanoservices.servermonitor.ServerState.State nextState,
                          org.enanoservices.servermonitor.ServerEvent.Event event)

resetRespStats

public void resetRespStats()

getServerInfo

public ThisServerInfo getServerInfo()