Package com.orientechnologies.orient.client.remote.message

Class OLiveQueryPushRequest

java.lang.Object

com.orientechnologies.orient.client.remote.message.OLiveQueryPushRequest

All Implemented Interfaces:

OBinaryPushRequest

public class OLiveQueryPushRequest
extends Object
implements OBinaryPushRequest

Created by tglman on 17/05/17.

Field Summary

Fields

Modifier and Type	Field	Description
static final byte	END
static final byte	ERROR
static final byte	HAS_MORE

Constructor Summary

Constructors

Constructor	Description
OLiveQueryPushRequest()
OLiveQueryPushRequest(int monitorId, byte status, List<OLiveQueryResult> events)
OLiveQueryPushRequest(int monitorId, int errorIdentifier, OErrorCode errorCode, String errorMessage)

Method Summary

Modifier and Type	Method	Description
OBinaryPushResponse	createResponse()
OBinaryPushResponse	execute(ORemotePushHandler remote)
OErrorCode	getErrorCode()
int	getErrorIdentifier()
String	getErrorMessage()
List<OLiveQueryResult>	getEvents()
int	getMonitorId()
byte	getPushCommand()
byte	getStatus()
void	read(OChannelDataInput network)
void	setStatus(byte status)
void	write(OChannelDataOutput channel)

Methods inherited from class java.lang.Object

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

Field Details

HAS_MORE

public static final byte HAS_MORE

See Also:

• Constant Field Values

END

public static final byte END

See Also:

• Constant Field Values

ERROR

public static final byte ERROR

See Also:

• Constant Field Values

Constructor Details

OLiveQueryPushRequest

public OLiveQueryPushRequest(int monitorId,
 int errorIdentifier,
 OErrorCode errorCode,
 String errorMessage)

OLiveQueryPushRequest

public OLiveQueryPushRequest(int monitorId,
 byte status,
 List<OLiveQueryResult> events)

OLiveQueryPushRequest

public OLiveQueryPushRequest()

Method Details

write

public void write(OChannelDataOutput channel)
           throws IOException

Specified by:

write in interface OBinaryPushRequest

Throws:

IOException

read

public void read(OChannelDataInput network)
          throws IOException

Specified by:

read in interface OBinaryPushRequest

Throws:

IOException

execute

public OBinaryPushResponse execute(ORemotePushHandler remote)

Specified by:

execute in interface OBinaryPushRequest

createResponse

public OBinaryPushResponse createResponse()

Specified by:

createResponse in interface OBinaryPushRequest

getPushCommand

public byte getPushCommand()

Specified by:

getPushCommand in interface OBinaryPushRequest

getMonitorId

public int getMonitorId()

getEvents

public List<OLiveQueryResult> getEvents()

getStatus

public byte getStatus()

setStatus

public void setStatus(byte status)

getErrorIdentifier

public int getErrorIdentifier()

getErrorMessage

public String getErrorMessage()

getErrorCode

public OErrorCode getErrorCode()