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 and Description
static interface	ORemoteServerChannel.OStorageRemoteOperation<T>

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	checkReconnect()
void	close()
void	connect()
Date	getCreatedOn()
int	getDistributedProtocolVersion()
String	getServer()
protected <T> T	networkOperation(byte operationId, ORemoteServerChannel.OStorageRemoteOperation<T> operation, String errorMessage, int maxRetry, boolean autoReconnect)
void	sendBinaryRequest(OBinaryRequest request)
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 Detail

ORemoteServerChannel

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

Throws:

IOException

Method Detail

getDistributedProtocolVersion

public int getDistributedProtocolVersion()

sendBinaryRequest

public void sendBinaryRequest(OBinaryRequest request)

checkReconnect

public void checkReconnect()

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.OStorageRemoteOperation<T> operation,
                                 String errorMessage,
                                 int maxRetry,
                                 boolean autoReconnect)

getServer

public String getServer()

getCreatedOn

public Date getCreatedOn()