
public class ODistributedMessageServiceImpl extends Object implements ODistributedMessageService
| Constructor and Description |
|---|
ODistributedMessageServiceImpl(OHazelcastPlugin manager) |
public ODistributedMessageServiceImpl(OHazelcastPlugin manager)
public ODistributedDatabaseImpl getDatabase(String iDatabaseName)
getDatabase in interface ODistributedMessageServicepublic void shutdown()
public ODistributedResponseManager getResponseManager(ODistributedRequestId reqId)
getResponseManager in interface ODistributedMessageServicepublic void registerRequest(long id,
ODistributedResponseManager currentResponseMgr)
registerRequest in interface ODistributedMessageServicepublic void handleUnreachableNode(String nodeName)
public long getAverageResponseTime()
public ODistributedDatabaseImpl registerDatabase(String iDatabaseName, ODistributedConfiguration cfg)
registerDatabase in interface ODistributedMessageServicepublic ODistributedDatabaseImpl unregisterDatabase(String iDatabaseName)
unregisterDatabase in interface ODistributedMessageServicepublic Set<String> getDatabases()
getDatabases in interface ODistributedMessageServicepublic void dispatchResponseToThread(ODistributedResponse response)
dispatchResponseToThread in interface ODistributedMessageServicepublic void timeoutRequest(long msgId)
public ODocument getLatencies()
getLatencies in interface ODistributedMessageServicepublic long getCurrentLatency(String server)
getCurrentLatency in interface ODistributedMessageServicepublic void updateLatency(String server, long sentOn)
updateLatency in interface ODistributedMessageServiceprotected void purgePendingMessages()
public ODocument getMessageStats()
getMessageStats in interface ODistributedMessageServicepublic void updateMessageStats(String message)
updateMessageStats in interface ODistributedMessageServicepublic long getReceivedRequests()
getReceivedRequests in interface ODistributedMessageServicepublic long getProcessedRequests()
getProcessedRequests in interface ODistributedMessageServiceCopyright © 2009–2025 OrientDB. All rights reserved.