java.lang.Object
- org.apache.ignite.internal.managers.communication.IgniteIoTestMessage

All Implemented Interfaces:: Serializable, Message

public class IgniteIoTestMessage
extends Object
implements Message

See Also:: Serialized Form

Field Summary
- Fields inherited from interface org.apache.ignite.plugin.extensions.communication.Message
  DIRECT_TYPE_SIZE

Constructor Summary

Constructors
Constructor Description

IgniteIoTestMessage()

IgniteIoTestMessage(long id, boolean req, byte[] payload)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`copyDataFromRequest(IgniteIoTestMessage req)`
`short`	`directType()`	Gets message type.
`byte`	`fieldsCount()`	Gets fields count.
`byte`	`flags()`
`void`	`flags(byte flags)`
`long`	`id()`
`void`	`onAckReceived()`	Method called when ack message received.
`void`	`onAfterRead()`	This method is called to initialize tracing variables.
`void`	`onBeforeWrite()`	This method is called to initialize tracing variables.
`void`	`onRequestProcessed()`
`void`	`onResponseProcessed()`
`boolean`	`processFromNioThread()`
`void`	`processFromNioThread(boolean procFromNioThread)`
`boolean`	`readFrom(ByteBuffer buf, MessageReader reader)`	Reads this message from provided byte buffer.
`boolean`	`request()`
`long`	`requestCreateTs()`
`long`	`requestProcessTs()`
`long`	`requestReceivedTsMillis()`
`long`	`requestReceiveTs()`
`long`	`requestSendTs()`
`long`	`requestSendTsMillis()`
`long`	`responseProcessedTs()`
`long`	`responseProcessTs()`
`long`	`responseReceivedTsMillis()`
`long`	`responseReceiveTs()`
`long`	`responseSendTs()`
`long`	`responseSendTsMillis()`
`UUID`	`senderNodeId()`
`void`	`senderNodeId(UUID sndNodeId)`
`String`	`toString()`
`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
  - IgniteIoTestMessage
```
public IgniteIoTestMessage()
```
  - IgniteIoTestMessage
```
public IgniteIoTestMessage(long id,
                           boolean req,
                           byte[] payload)
```
    Parameters:
    
    id - Message ID.
    
    req - Request flag.
    
    payload - Payload.
- Method Detail
  - processFromNioThread
```
public boolean processFromNioThread()
```
    Returns:
    
    True if message should be processed from NIO thread (otherwise message is submitted to system pool).
  - processFromNioThread
```
public void processFromNioThread(boolean procFromNioThread)
```
    Parameters:
    
    procFromNioThread - True if message should be processed from NIO thread.
  - flags
```
public void flags(byte flags)
```
    Parameters:
    
    flags - Flags.
  - flags
```
public byte flags()
```
    Returns:
    
    Flags.
  - request
```
public boolean request()
```
    Returns:
    
    true if this is request.
  - id
```
public long id()
```
    Returns:
    
    ID.
  - requestCreateTs
```
public long requestCreateTs()
```
    Returns:
    
    Request create timestamp.
  - requestSendTs
```
public long requestSendTs()
```
    Returns:
    
    Request send timestamp.
  - requestReceiveTs
```
public long requestReceiveTs()
```
    Returns:
    
    Request receive timestamp.
  - requestProcessTs
```
public long requestProcessTs()
```
    Returns:
    
    Request process started timestamp.
  - responseSendTs
```
public long responseSendTs()
```
    Returns:
    
    Response send timestamp.
  - responseReceiveTs
```
public long responseReceiveTs()
```
    Returns:
    
    Response receive timestamp.
  - responseProcessTs
```
public long responseProcessTs()
```
    Returns:
    
    Response process timestamp.
  - requestSendTsMillis
```
public long requestSendTsMillis()
```
    Returns:
    
    Request send timestamp (millis).
  - requestReceivedTsMillis
```
public long requestReceivedTsMillis()
```
    Returns:
    
    Request received timestamp (millis).
  - responseSendTsMillis
```
public long responseSendTsMillis()
```
    Returns:
    
    Response send timestamp (millis).
  - responseReceivedTsMillis
```
public long responseReceivedTsMillis()
```
    Returns:
    
    Response received timestamp (millis).
  - onAfterRead
```
public void onAfterRead()
```
    This method is called to initialize tracing variables. TODO: introduce direct message lifecycle API?
  - onBeforeWrite
```
public void onBeforeWrite()
```
    This method is called to initialize tracing variables. TODO: introduce direct message lifecycle API?
  - copyDataFromRequest
```
public void copyDataFromRequest(IgniteIoTestMessage req)
```
  - onRequestProcessed
```
public void onRequestProcessed()
```
  - onResponseProcessed
```
public void onResponseProcessed()
```
  - responseProcessedTs
```
public long responseProcessedTs()
```
    Returns:
    
    Response processed timestamp.
  - senderNodeId
```
public UUID senderNodeId()
```
    Returns:
    
    Sender node ID.
  - senderNodeId
```
public void senderNodeId(UUID sndNodeId)
```
    Parameters:
    
    sndNodeId - Sender node ID.
  - 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 short 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.
  - onAckReceived
```
public void onAckReceived()
```
    Method called when ack message received.
    
    Specified by:
    
    onAckReceived in interface Message
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object

Constructor	Description
`IgniteIoTestMessage()`
`IgniteIoTestMessage(long id, boolean req, byte[] payload)`

Class IgniteIoTestMessage

Field Summary

Fields inherited from interface org.apache.ignite.plugin.extensions.communication.Message

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

IgniteIoTestMessage

IgniteIoTestMessage

Method Detail

processFromNioThread

processFromNioThread

flags

flags

request

id

requestCreateTs

requestSendTs

requestReceiveTs

requestProcessTs

responseSendTs

responseReceiveTs

responseProcessTs

requestSendTsMillis

requestReceivedTsMillis

responseSendTsMillis

responseReceivedTsMillis

onAfterRead

onBeforeWrite

copyDataFromRequest

onRequestProcessed

onResponseProcessed

responseProcessedTs

senderNodeId

senderNodeId

writeTo

readFrom

directType

fieldsCount

onAckReceived

toString