org.apache.ignite.internal.managers.communication

Class GridIoUserMessage

java.lang.Object

org.apache.ignite.internal.managers.communication.GridIoUserMessage

All Implemented Interfaces:

Serializable, Message

public class GridIoUserMessage
extends Object
implements Message

User message wrapper.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GridIoUserMessage() Default constructor, required for Externalizable.

Method Summary

Methods

Modifier and Type	Method and Description
Object	body()
void	body(Object body)
byte[]	bodyBytes()
IgniteUuid	classLoaderId()
GridDeployment	deployment()
void	deployment(GridDeployment dep)
String	deploymentClassName()
DeploymentMode	deploymentMode()
byte	directType() Gets message type.
byte	fieldsCount() Gets fields count.
Map<UUID,IgniteUuid>	loaderParticipants()
void	onAckReceived() Method called when ack message received.
boolean	readFrom(ByteBuffer buf, MessageReader reader) Reads this message from provided byte buffer.
Object	topic()
void	topic(Object topic)
byte[]	topicBytes()
String	toString()
String	userVersion()
boolean	writeTo(ByteBuffer buf, MessageWriter writer) Writes this message to provided byte buffer.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridIoUserMessage

public GridIoUserMessage()

Default constructor, required for Externalizable.

Method Detail

bodyBytes

@Nullable
public byte[] bodyBytes()

Returns:

Serialized message body.

classLoaderId

@Nullable
public IgniteUuid classLoaderId()

Returns:

the Class loader ID.

deploymentMode

@Nullable
public DeploymentMode deploymentMode()

Returns:

Deployment mode.

deploymentClassName

@Nullable
public String deploymentClassName()

Returns:

Message body class name.

userVersion

@Nullable
public String userVersion()

Returns:

User version.

loaderParticipants

@Nullable
public Map<UUID,IgniteUuid> loaderParticipants()

Returns:

Node class loader participant map.

topicBytes

@Nullable
public byte[] topicBytes()

Returns:

Serialized message topic.

topic

public void topic(Object topic)

Parameters:

topic - New message topic.

topic

@Nullable
public Object topic()

Returns:

Message topic.

body

public void body(Object body)

Parameters:

body - New message body.

body

@Nullable
public Object body()

Returns:

Message body.

deployment

public void deployment(GridDeployment dep)

Parameters:

dep - New message deployment.

deployment

@Nullable
public GridDeployment deployment()

Returns:

Message deployment.

onAckReceived

public void onAckReceived()

Method called when ack message received.

Specified by:

onAckReceived in interface Message

writeTo

public boolean writeTo(ByteBuffer buf,
              MessageWriter writer)

Writes this message to provided byte buffer.

Specified by:

writeTo in interface Message

Parameters:

buf - Byte buffer.

writer - Writer.

Returns:

Whether message was fully written.

readFrom

public boolean readFrom(ByteBuffer buf,
               MessageReader reader)

Reads this message from provided byte buffer.

Specified by:

readFrom in interface Message

Parameters:

buf - Byte buffer.

reader - Reader.

Returns:

Whether message was fully read.

directType

public byte directType()

Gets message type.

Specified by:

directType in interface Message

Returns:

Message type.

fieldsCount

public byte fieldsCount()

Gets fields count.

Specified by:

fieldsCount in interface Message

Returns:

Fields count.

toString

public String toString()

Overrides:

toString in class Object