Package com.orientechnologies.orient.server.distributed.impl

Class ODistributedMessageServiceImpl

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.ODistributedMessageServiceImpl

All Implemented Interfaces:

ODistributedMessageService

public class ODistributedMessageServiceImpl
extends Object
implements ODistributedMessageService

Message handler for matching distributed responses to requests of distributed peer. Each node creates own instance to talk with each others.

Author:

Luca Garulli (l.garulli--at--orientdb.com)

Constructor Summary

Constructors

Constructor	Description
ODistributedMessageServiceImpl(OrientDBDistributed context)

Method Summary

Modifier and Type	Method	Description
void	dispatchResponseToThread(ODistributedResponse response)	Not synchronized, it's called when a message arrives
long	getAverageResponseTime()
long	getCurrentLatency(String server)
ODocument	getLatencies()
ODocument	getMessageStats()
long	getProcessedRequests()
long	getReceivedRequests()
void	handleUnreachableNode(String nodeName)
protected void	purgePendingMessages()
void	registerRequest(long id, ODistributedResponseManager currentResponseMgr)
void	shutdown()
void	timeoutRequest(long msgId)	Removes a response context because in timeout.
void	updateLatency(String server, long sentOn)
void	updateMessageStats(String message)

Methods inherited from class java.lang.Object

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

Constructor Details

ODistributedMessageServiceImpl

public ODistributedMessageServiceImpl(OrientDBDistributed context)

Method Details

shutdown

public void shutdown()

registerRequest

public void registerRequest(long id,
 ODistributedResponseManager currentResponseMgr)

Specified by:

registerRequest in interface ODistributedMessageService

handleUnreachableNode

public void handleUnreachableNode(String nodeName)

Specified by:

handleUnreachableNode in interface ODistributedMessageService

getAverageResponseTime

public long getAverageResponseTime()

dispatchResponseToThread

public void dispatchResponseToThread(ODistributedResponse response)

Not synchronized, it's called when a message arrives

Specified by:

dispatchResponseToThread in interface ODistributedMessageService

timeoutRequest

public void timeoutRequest(long msgId)

Removes a response context because in timeout.

Specified by:

timeoutRequest in interface ODistributedMessageService

getLatencies

public ODocument getLatencies()

Specified by:

getLatencies in interface ODistributedMessageService

getCurrentLatency

public long getCurrentLatency(String server)

Specified by:

getCurrentLatency in interface ODistributedMessageService

updateLatency

public void updateLatency(String server,
 long sentOn)

Specified by:

updateLatency in interface ODistributedMessageService

purgePendingMessages

protected void purgePendingMessages()

getMessageStats

public ODocument getMessageStats()

Specified by:

getMessageStats in interface ODistributedMessageService

updateMessageStats

public void updateMessageStats(String message)

Specified by:

updateMessageStats in interface ODistributedMessageService

getReceivedRequests

public long getReceivedRequests()

Specified by:

getReceivedRequests in interface ODistributedMessageService

getProcessedRequests

public long getProcessedRequests()

Specified by:

getProcessedRequests in interface ODistributedMessageService