Package com.orientechnologies.orient.server.distributed

Class ORemoteServerChannel

java.lang.Object

com.orientechnologies.orient.server.distributed.ORemoteServerChannel

public class ORemoteServerChannel
extends Object

Remote server channel.

Author:

Luca Garulli

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ORemoteServerChannel.ORemoteClientOperation<T>

Constructor Summary

Constructors

Constructor	Description
ORemoteServerChannel(ORemoteServerAvailabilityCheck check, String localNodeName, String iServer, String iURL, String user, String passwd, int currentProtocolVersion)

Method Summary

Modifier and Type	Method	Description
void	checkReconnect()
void	close()
void	connect()
Date	getCreatedOn()
int	getDistributedProtocolVersion()
String	getServer()
protected <T> T	networkOperation(byte operationId, ORemoteServerChannel.ORemoteClientOperation<T> operation, String errorMessage, int maxRetry, boolean autoReconnect)
void	sendBinaryRequest(OBinaryRequest request)
void	sendMessage(ONetworkMessage message)
void	sendRequest(ODistributedRequest request)
void	sendResponse(ODistributedResponse response)

Methods inherited from class java.lang.Object

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

Constructor Details

ORemoteServerChannel

public ORemoteServerChannel(ORemoteServerAvailabilityCheck check,
 String localNodeName,
 String iServer,
 String iURL,
 String user,
 String passwd,
 int currentProtocolVersion)
                     throws IOException

Throws:

IOException

Method Details

getDistributedProtocolVersion

public int getDistributedProtocolVersion()

sendBinaryRequest

public void sendBinaryRequest(OBinaryRequest request)

checkReconnect

public void checkReconnect()

sendMessage

public void sendMessage(ONetworkMessage message)

sendRequest

public void sendRequest(ODistributedRequest request)

sendResponse

public void sendResponse(ODistributedResponse response)

connect

public void connect()
             throws IOException

Throws:

IOException

close

public void close()

networkOperation

protected <T> T networkOperation(byte operationId,
 ORemoteServerChannel.ORemoteClientOperation<T> operation,
 String errorMessage,
 int maxRetry,
 boolean autoReconnect)

getServer

public String getServer()

getCreatedOn

public Date getCreatedOn()