ODistributedMessageServiceImpl (OrientDB 2.2.1-SNAPSHOT API)

java.lang.Object
- com.orientechnologies.orient.server.distributed.impl.ODistributedMessageServiceImpl

All Implemented Interfaces:

ODistributedMessageService
```
public class ODistributedMessageServiceImpl
extends Object
implements ODistributedMessageService
```
Hazelcast implementation of distributed peer. There is one instance per database. Each node creates own instance to talk with each others.

Author:

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

Field Summary

Fields
Modifier and Type	Field and Description
`protected TimerTask`	`asynchMessageManager`
`protected Map<String,ODistributedDatabaseImpl>`	`databases`
`protected OHazelcastPlugin`	`manager`
`protected ConcurrentHashMap<Long,ODistributedResponseManager>`	`responsesByRequestIds`
`protected Thread`	`responseThread`
`protected int`	`responseTimeMetricIndex`
`protected long[]`	`responseTimeMetrics`
`protected boolean`	`running`

Constructor Summary

Constructors
Constructor and Description

ODistributedMessageServiceImpl(OHazelcastPlugin manager)

Constructors
Constructor and Description
`ODistributedMessageServiceImpl(OHazelcastPlugin manager)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`long`	`dispatchResponseToThread(ODistributedResponse response)` Not synchronized, it's called when a message arrives
`long`	`getAverageResponseTime()`
`ODistributedDatabaseImpl`	`getDatabase(String iDatabaseName)`
`Set<String>`	`getDatabases()`
`void`	`handleUnreachableNode(String nodeName)`
`protected void`	`purgePendingMessages()`
`ODistributedDatabaseImpl`	`registerDatabase(String iDatabaseName)`
`void`	`registerRequest(long id, ODistributedResponseManager currentResponseMgr)`
`void`	`shutdown()`
`ODistributedDatabaseImpl`	`unregisterDatabase(String iDatabaseName)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

manager

protected final OHazelcastPlugin manager

responsesByRequestIds

protected final ConcurrentHashMap<Long,ODistributedResponseManager> responsesByRequestIds

asynchMessageManager

protected final TimerTask asynchMessageManager

databases

protected Map<String,ODistributedDatabaseImpl> databases

responseThread
```
protected Thread responseThread
```

responseTimeMetrics
```
protected long[] responseTimeMetrics
```

responseTimeMetricIndex
```
protected int responseTimeMetricIndex
```

running
```
protected volatile boolean running
```

Constructor Detail

ODistributedMessageServiceImpl

public ODistributedMessageServiceImpl(OHazelcastPlugin manager)

Method Detail

getDatabase

public ODistributedDatabaseImpl getDatabase(String iDatabaseName)

Specified by:: getDatabase in interface ODistributedMessageService

shutdown
```
public void shutdown()
```

registerRequest

public void registerRequest(long id,
                            ODistributedResponseManager currentResponseMgr)

handleUnreachableNode

public void handleUnreachableNode(String nodeName)

getAverageResponseTime
```
public long getAverageResponseTime()
```

registerDatabase
```
public ODistributedDatabaseImpl registerDatabase(String iDatabaseName)
```
Specified by:

registerDatabase in interface ODistributedMessageService

unregisterDatabase
```
public ODistributedDatabaseImpl unregisterDatabase(String iDatabaseName)
```
Specified by:

unregisterDatabase in interface ODistributedMessageService

getDatabases
```
public Set<String> getDatabases()
```

dispatchResponseToThread
```
public long dispatchResponseToThread(ODistributedResponse response)
```
Not synchronized, it's called when a message arrives

Specified by:

dispatchResponseToThread in interface ODistributedMessageService

Parameters:

response -

purgePendingMessages
```
protected void purgePendingMessages()
```

Class ODistributedMessageServiceImpl

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

manager

responsesByRequestIds

asynchMessageManager

databases

responseThread

responseTimeMetrics

responseTimeMetricIndex

running

Constructor Detail

ODistributedMessageServiceImpl

Method Detail

getDatabase

shutdown

registerRequest

handleUnreachableNode

getAverageResponseTime

registerDatabase

unregisterDatabase

getDatabases

dispatchResponseToThread

purgePendingMessages