ODistributedWorker (OrientDB 2.2.1-SNAPSHOT API)

java.lang.Object
- java.lang.Thread
- - com.orientechnologies.orient.server.distributed.impl.ODistributedWorker

All Implemented Interfaces:

Runnable
```
public class ODistributedWorker
extends Thread
```
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)

Nested Class Summary
- Nested classes/interfaces inherited from class java.lang.Thread
  Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields
Modifier and Type	Field and Description
`protected ODatabaseDocumentTx`	`database`
`protected String`	`databaseName`
`protected ODistributedDatabaseImpl`	`distributed`
`protected int`	`id`
`protected OUser`	`lastUser`
`protected String`	`localNodeName`
`protected ArrayBlockingQueue<ODistributedRequest>`	`localQueue`
`protected ODistributedServerManager`	`manager`
`protected ODistributedMessageServiceImpl`	`msgService`
`protected boolean`	`running`

Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors
Constructor and Description

ODistributedWorker(ODistributedDatabaseImpl iDistributed, String iDatabaseName, int i)

Constructors
Constructor and Description
`ODistributedWorker(ODistributedDatabaseImpl iDistributed, String iDatabaseName, int i)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`ODatabaseDocumentTx`	`getDatabase()`
`protected String`	`getLocalNodeName()`
`void`	`initDatabaseInstance()`
`protected ODistributedRequest`	`nextMessage()`
`protected void`	`onMessage(ODistributedRequest iRequest)` Execute the remote call on the local node and send back the result
`void`	`processRequest(ODistributedRequest request)`
`protected ODistributedRequest`	`readRequest()`
`void`	`run()`
`void`	`shutdown()`

Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

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

Field Detail

distributed

protected final ODistributedDatabaseImpl distributed

manager

protected final ODistributedServerManager manager

msgService

protected final ODistributedMessageServiceImpl msgService

localNodeName
```
protected final String localNodeName
```

databaseName
```
protected final String databaseName
```

localQueue

protected final ArrayBlockingQueue<ODistributedRequest> localQueue

id
```
protected final int id
```

database

protected volatile ODatabaseDocumentTx database

lastUser
```
protected volatile OUser lastUser
```

running
```
protected volatile boolean running
```

Constructor Detail

ODistributedWorker

public ODistributedWorker(ODistributedDatabaseImpl iDistributed,
                          String iDatabaseName,
                          int i)

Method Detail

processRequest

public void processRequest(ODistributedRequest request)

run
```
public void run()
```
Specified by:

run in interface Runnable

Overrides:

run in class Thread

initDatabaseInstance
```
public void initDatabaseInstance()
```

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

getDatabase

public ODatabaseDocumentTx getDatabase()

readRequest

protected ODistributedRequest readRequest()
                                   throws InterruptedException

Throws:: InterruptedException

nextMessage

protected ODistributedRequest nextMessage()
                                   throws InterruptedException

Throws:: InterruptedException

onMessage
```
protected void onMessage(ODistributedRequest iRequest)
```
Execute the remote call on the local node and send back the result

getLocalNodeName
```
protected String getLocalNodeName()
```

Class ODistributedWorker

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Field Summary

Fields inherited from class java.lang.Thread

Constructor Summary

Method Summary

Methods inherited from class java.lang.Thread

Methods inherited from class java.lang.Object

Field Detail

distributed

manager

msgService

localNodeName

databaseName

localQueue

id

database

lastUser

running

Constructor Detail

ODistributedWorker

Method Detail

processRequest

run

initDatabaseInstance

shutdown

getDatabase

readRequest

nextMessage

onMessage

getLocalNodeName