Package com.orientechnologies.orient.client.remote

Class ORemotePushHandlerImpl

java.lang.Object

com.orientechnologies.orient.client.remote.ORemotePushHandlerImpl

All Implemented Interfaces:

ORemotePushHandler

public class ORemotePushHandlerImpl
extends Object
implements ORemotePushHandler

Constructor Summary

Constructors

Constructor	Description
ORemotePushHandlerImpl(ORemoteClient client, OMetadataPushListener handler)

Method Summary

Modifier and Type	Method	Description
OBinaryPushRequest	createPush(byte push)
void	executeLiveQueryPush(OLiveQueryPushRequest pushRequest)
OBinaryPushResponse	executeUpdateDistributedConfig(OPushDistributedConfigurationRequest request)
OBinaryPushResponse	executeUpdateFunction(OPushFunctionsRequest request)
OBinaryPushResponse	executeUpdateIndexManager(OPushIndexManagerRequest request)
OBinaryPushResponse	executeUpdateSchema(OPushSchemaRequest request)
OBinaryPushResponse	executeUpdateSequences(OPushSequencesRequest request)
OBinaryPushResponse	executeUpdateStorageConfig(OPushStorageConfigurationRequest payload)
OChannelBinary	getNetwork(String host)
void	onPushDisconnect(OChannelBinary network, Exception e)
void	onPushReconnect(String host)
void	returnSocket(OChannelBinary network)

Methods inherited from class java.lang.Object

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

Constructor Details

ORemotePushHandlerImpl

public ORemotePushHandlerImpl(ORemoteClient client,
 OMetadataPushListener handler)

Method Details

getNetwork

public OChannelBinary getNetwork(String host)

Specified by:

getNetwork in interface ORemotePushHandler

createPush

public OBinaryPushRequest createPush(byte push)

Specified by:

createPush in interface ORemotePushHandler

executeLiveQueryPush

public void executeLiveQueryPush(OLiveQueryPushRequest pushRequest)

Specified by:

executeLiveQueryPush in interface ORemotePushHandler

onPushReconnect

public void onPushReconnect(String host)

Specified by:

onPushReconnect in interface ORemotePushHandler

onPushDisconnect

public void onPushDisconnect(OChannelBinary network,
 Exception e)

Specified by:

onPushDisconnect in interface ORemotePushHandler

returnSocket

public void returnSocket(OChannelBinary network)

Specified by:

returnSocket in interface ORemotePushHandler

executeUpdateDistributedConfig

public OBinaryPushResponse executeUpdateDistributedConfig(OPushDistributedConfigurationRequest request)

Specified by:

executeUpdateDistributedConfig in interface ORemotePushHandler

executeUpdateFunction

public OBinaryPushResponse executeUpdateFunction(OPushFunctionsRequest request)

Specified by:

executeUpdateFunction in interface ORemotePushHandler

executeUpdateSequences

public OBinaryPushResponse executeUpdateSequences(OPushSequencesRequest request)

Specified by:

executeUpdateSequences in interface ORemotePushHandler

executeUpdateStorageConfig

public OBinaryPushResponse executeUpdateStorageConfig(OPushStorageConfigurationRequest payload)

Specified by:

executeUpdateStorageConfig in interface ORemotePushHandler

executeUpdateSchema

public OBinaryPushResponse executeUpdateSchema(OPushSchemaRequest request)

Specified by:

executeUpdateSchema in interface ORemotePushHandler

executeUpdateIndexManager

public OBinaryPushResponse executeUpdateIndexManager(OPushIndexManagerRequest request)

Specified by:

executeUpdateIndexManager in interface ORemotePushHandler