org.gridgain.grid.kernal

Class GridJobExecuteResponse

java.lang.Object

org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

org.gridgain.grid.kernal.GridJobExecuteResponse

All Implemented Interfaces:

Serializable, Cloneable, GridTaskMessage

public class GridJobExecuteResponse
extends GridTcpCommunicationMessageAdapter
implements GridTaskMessage

Job execution response.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

BIT_SET_NOT_READ, BOOLEAN_ARR_NOT_READ, BYTE_ARR_LIST_NOT_READ, BYTE_ARR_NOT_READ, CACHE_VER_NOT_READ, CHAR_ARR_NOT_READ, CLOCK_DELTA_VER_NOT_READ, commState, DHT_PART_EXCHANGE_ID_NOT_READ, DOUBLE_ARR_NOT_READ, DR_INT_REQ_ENTRY_NOT_READ, ENUM_NOT_READ, FLOAT_ARR_NOT_READ, GRID_UUID_NOT_READ, INT_ARR_NOT_READ, LONG_ARR_NOT_READ, LONG_LIST_NOT_READ, MSG_NOT_READ, NULL, SHORT_ARR_NOT_READ, STR_NOT_READ, UUID_NOT_READ, VAL_BYTES_NOT_READ

Constructor Summary

Constructors

Constructor and Description
GridJobExecuteResponse() No-op constructor to support Externalizable interface.
GridJobExecuteResponse(UUID nodeId, GridUuid sesId, GridUuid jobId, byte[] gridExBytes, GridException gridEx, byte[] resBytes, Object res, byte[] jobAttrsBytes, Map<Object,Object> jobAttrs, boolean isCancelled)

Method Summary

Methods

Modifier and Type	Method and Description
GridTcpCommunicationMessageAdapter	clone()
protected void	clone0(GridTcpCommunicationMessageAdapter _msg) Clones all fields of the provided message to this.
byte	directType()
GridException	getException()
byte[]	getExceptionBytes()
GridException	getFakeException()
Map<Object,Object>	getJobAttributes()
byte[]	getJobAttributesBytes()
GridUuid	getJobId()
Object	getJobResult()
byte[]	getJobResultBytes()
UUID	getNodeId()
GridUuid	getSessionId()
boolean	isCancelled()
boolean	readFrom(ByteBuffer buf)
void	setFakeException(GridException fakeEx)
String	toString()
boolean	writeTo(ByteBuffer buf)

Methods inherited from class org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

arrayIterator, messageReader, messageWriter

Methods inherited from class java.lang.Object

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

Constructor Detail

GridJobExecuteResponse

public GridJobExecuteResponse()

No-op constructor to support Externalizable interface. This constructor is not meant to be used for other purposes.

GridJobExecuteResponse

public GridJobExecuteResponse(UUID nodeId,
                      GridUuid sesId,
                      GridUuid jobId,
                      byte[] gridExBytes,
                      GridException gridEx,
                      byte[] resBytes,
                      Object res,
                      byte[] jobAttrsBytes,
                      Map<Object,Object> jobAttrs,
                      boolean isCancelled)

Parameters:

nodeId - Sender node ID.

sesId - Task session ID

jobId - Job ID.

gridExBytes - Serialized grid exception.

gridEx - Grid exception.

resBytes - Serialized result.

res - Result.

jobAttrsBytes - Serialized job attributes.

jobAttrs - Job attributes.

isCancelled - Whether job was cancelled or not.

Method Detail

getSessionId

public GridUuid getSessionId()

Specified by:

getSessionId in interface GridTaskMessage

Returns:

Task session ID.

getJobId

public GridUuid getJobId()

Returns:

Job ID.

getJobResultBytes

@Nullable
public byte[] getJobResultBytes()

Returns:

Serialized job result.

getJobResult

@Nullable
public Object getJobResult()

Returns:

Job result.

getExceptionBytes

@Nullable
public byte[] getExceptionBytes()

Returns:

Serialized job exception.

getException

@Nullable
public GridException getException()

Returns:

Job exception.

getJobAttributesBytes

@Nullable
public byte[] getJobAttributesBytes()

Returns:

Serialized job attributes.

getJobAttributes

@Nullable
public Map<Object,Object> getJobAttributes()

Returns:

Job attributes.

isCancelled

public boolean isCancelled()

Returns:

Job cancellation status.

getNodeId

public UUID getNodeId()

Returns:

Sender node ID.

getFakeException

public GridException getFakeException()

Returns:

Fake exception.

setFakeException

public void setFakeException(GridException fakeEx)

Parameters:

fakeEx - Fake exception.

clone

public GridTcpCommunicationMessageAdapter clone()

Specified by:

clone in class GridTcpCommunicationMessageAdapter

clone0

protected void clone0(GridTcpCommunicationMessageAdapter _msg)

Clones all fields of the provided message to this.

Specified by:

clone0 in class GridTcpCommunicationMessageAdapter

Parameters:

_msg - Message to clone from.

writeTo

public boolean writeTo(ByteBuffer buf)

Specified by:

writeTo in class GridTcpCommunicationMessageAdapter

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully written.

readFrom

public boolean readFrom(ByteBuffer buf)

Specified by:

readFrom in class GridTcpCommunicationMessageAdapter

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully read.

directType

public byte directType()

Specified by:

directType in class GridTcpCommunicationMessageAdapter

Returns:

Message type.

toString

public String toString()

Overrides:

toString in class Object