Uses of Interface
org.apache.ignite.plugin.extensions.communication.Message

Packages that use Message

Package	Description
org.apache.ignite.internal	Contains main implementation.
org.apache.ignite.internal.binary	Contains binary APIs internal implementation.
org.apache.ignite.internal.direct
org.apache.ignite.internal.direct.stream
org.apache.ignite.internal.direct.stream.v1
org.apache.ignite.internal.direct.stream.v2
org.apache.ignite.internal.managers.checkpoint	TODO.
org.apache.ignite.internal.managers.communication	TODO.
org.apache.ignite.internal.managers.deployment	TODO.
org.apache.ignite.internal.managers.eventstorage	TODO.
org.apache.ignite.internal.processors.affinity	Data affinity processor.
org.apache.ignite.internal.processors.authentication
org.apache.ignite.internal.processors.cache
org.apache.ignite.internal.processors.cache.binary	Implementation of binary processor.
org.apache.ignite.internal.processors.cache.distributed
org.apache.ignite.internal.processors.cache.distributed.dht
org.apache.ignite.internal.processors.cache.distributed.dht.atomic
org.apache.ignite.internal.processors.cache.distributed.dht.preloader
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch
org.apache.ignite.internal.processors.cache.distributed.near
org.apache.ignite.internal.processors.cache.persistence.tree
org.apache.ignite.internal.processors.cache.query
org.apache.ignite.internal.processors.cache.query.continuous
org.apache.ignite.internal.processors.cache.transactions
org.apache.ignite.internal.processors.cache.version
org.apache.ignite.internal.processors.cacheobject	Cache object processor.
org.apache.ignite.internal.processors.cluster
org.apache.ignite.internal.processors.continuous
org.apache.ignite.internal.processors.datastreamer	Data streamer processor.
org.apache.ignite.internal.processors.hadoop	Contains Hadoop APIs.
org.apache.ignite.internal.processors.hadoop.shuffle
org.apache.ignite.internal.processors.igfs	Contains high performance file system processor.
org.apache.ignite.internal.processors.marshaller
org.apache.ignite.internal.processors.query.h2.twostep.messages
org.apache.ignite.internal.processors.query.schema.message
org.apache.ignite.internal.processors.rest.handlers.task
org.apache.ignite.internal.util	System-wide utility routine and helper classes.
org.apache.ignite.internal.util.nio	NIO server interfaces and common utility classes for NIO.
org.apache.ignite.plugin.extensions.communication	Contains extendable components for communication.
org.apache.ignite.spi.collision.jobstealing	Contains job stealing collision SPI implementation.
org.apache.ignite.spi.communication.tcp	Contains default TCP/IP-based implementation for communication SPI.
org.apache.ignite.spi.communication.tcp.messages	Contains implementation messages.

Uses of Message in org.apache.ignite.internal

Subinterfaces of Message in org.apache.ignite.internal

Modifier and Type	Interface and Description
interface	ExecutorAwareMessage Message with specified custom executor must be processed in the appropriate thread pool.

Classes in org.apache.ignite.internal that implement Message

Modifier and Type	Class and Description
class	GridJobCancelRequest Job cancellation request.
class	GridJobExecuteRequest Job execution request.
class	GridJobExecuteResponse Job execution response.
class	GridJobSiblingsRequest Job siblings request.
class	GridJobSiblingsResponse Job siblings response.
class	GridTaskCancelRequest Request for cancelling tasks.
class	GridTaskSessionRequest Task session request.
class	IgniteDiagnosticMessage

Uses of Message in org.apache.ignite.internal.binary

Classes in org.apache.ignite.internal.binary that implement Message

Modifier and Type	Class and Description
class	BinaryEnumObjectImpl Binary enum object.
class	BinaryObjectImpl Binary object implementation.
class	BinaryObjectOffheapImpl Binary object implementation over offheap memory

Uses of Message in org.apache.ignite.internal.direct

Methods in org.apache.ignite.internal.direct with type parameters of type Message

Modifier and Type	Method and Description
<T extends Message> T	DirectMessageReader.readMessage(String name) Reads nested message.

Methods in org.apache.ignite.internal.direct with parameters of type Message

Modifier and Type	Method and Description
boolean	DirectMessageWriter.writeMessage(String name, Message msg) Writes nested message.

Method parameters in org.apache.ignite.internal.direct with type arguments of type Message

Modifier and Type	Method and Description
boolean	DirectMessageReader.afterMessageRead(Class<? extends Message> msgCls) Callback that must be invoked by a message implementation after message body finished decoding.
void	DirectMessageReader.setCurrentReadClass(Class<? extends Message> msgCls) Sets type of message currently read.
void	DirectMessageWriter.setCurrentWriteClass(Class<? extends Message> msgCls) Sets type of message currently written.

Uses of Message in org.apache.ignite.internal.direct.stream

Methods in org.apache.ignite.internal.direct.stream with type parameters of type Message

Modifier and Type	Method and Description
<T extends Message> T	DirectByteBufferStream.readMessage(MessageReader reader)

Methods in org.apache.ignite.internal.direct.stream with parameters of type Message

Modifier and Type	Method and Description
void	DirectByteBufferStream.writeMessage(Message msg, MessageWriter writer)

Uses of Message in org.apache.ignite.internal.direct.stream.v1

Methods in org.apache.ignite.internal.direct.stream.v1 with type parameters of type Message

Modifier and Type	Method and Description
<T extends Message> T	DirectByteBufferStreamImplV1.readMessage(MessageReader reader)

Methods in org.apache.ignite.internal.direct.stream.v1 with parameters of type Message

Modifier and Type	Method and Description
void	DirectByteBufferStreamImplV1.writeMessage(Message msg, MessageWriter writer)

Uses of Message in org.apache.ignite.internal.direct.stream.v2

Methods in org.apache.ignite.internal.direct.stream.v2 with type parameters of type Message

Modifier and Type	Method and Description
<T extends Message> T	DirectByteBufferStreamImplV2.readMessage(MessageReader reader)

Methods in org.apache.ignite.internal.direct.stream.v2 with parameters of type Message

Modifier and Type	Method and Description
void	DirectByteBufferStreamImplV2.writeMessage(Message msg, MessageWriter writer)

Uses of Message in org.apache.ignite.internal.managers.checkpoint

Classes in org.apache.ignite.internal.managers.checkpoint that implement Message

Modifier and Type	Class and Description
class	GridCheckpointRequest This class defines checkpoint request.

Uses of Message in org.apache.ignite.internal.managers.communication

Classes in org.apache.ignite.internal.managers.communication that implement Message

Modifier and Type	Class and Description
class	GridIoMessage Wrapper for all grid messages.
class	GridIoUserMessage User message wrapper.
class	IgniteIoTestMessage

Methods in org.apache.ignite.internal.managers.communication that return Message

Modifier and Type	Method and Description
Message	GridIoMessageFactory.create(short type) Creates new message instance of provided type.
Message	GridIoMessage.message()

Methods in org.apache.ignite.internal.managers.communication with parameters of type Message

Modifier and Type	Method and Description
void	GridIoManager.sendGeneric(ClusterNode node, Object topic, int topicOrd, Message msg, byte plc)
void	GridIoManager.sendOrderedMessage(ClusterNode node, Object topic, Message msg, byte plc, long timeout, boolean skipOnTimeout)
void	GridIoManager.sendOrderedMessage(ClusterNode node, Object topic, Message msg, byte plc, long timeout, boolean skipOnTimeout, IgniteInClosure<IgniteException> ackC)
void	GridIoManager.sendToCustomTopic(ClusterNode node, Object topic, Message msg, byte plc)
void	GridIoManager.sendToCustomTopic(UUID nodeId, Object topic, Message msg, byte plc)
void	GridIoManager.sendToGridTopic(ClusterNode node, GridTopic topic, Message msg, byte plc)
void	GridIoManager.sendToGridTopic(ClusterNode node, GridTopic topic, Message msg, byte plc, IgniteInClosure<IgniteException> ackC)
void	GridIoManager.sendToGridTopic(Collection<? extends ClusterNode> nodes, GridTopic topic, Message msg, byte plc)
void	GridIoManager.sendToGridTopic(UUID nodeId, GridTopic topic, Message msg, byte plc)

Method parameters in org.apache.ignite.internal.managers.communication with type arguments of type Message

Modifier and Type	Method and Description
static void	GridIoMessageFactory.registerCustom(short type, IgniteOutClosure<Message> c) Registers factory for custom message.

Constructors in org.apache.ignite.internal.managers.communication with parameters of type Message

Constructor and Description
GridIoMessage(byte plc, Object topic, int topicOrd, Message msg, boolean ordered, long timeout, boolean skipOnTimeout)

Uses of Message in org.apache.ignite.internal.managers.deployment

Classes in org.apache.ignite.internal.managers.deployment that implement Message

Modifier and Type	Class and Description
class	GridDeploymentInfoBean Deployment info bean.
class	GridDeploymentRequest Deployment request.
class	GridDeploymentResponse Grid deployment response containing requested resource bytes.

Uses of Message in org.apache.ignite.internal.managers.eventstorage

Classes in org.apache.ignite.internal.managers.eventstorage that implement Message

Modifier and Type	Class and Description
class	GridEventStorageMessage Event storage message.

Uses of Message in org.apache.ignite.internal.processors.affinity

Classes in org.apache.ignite.internal.processors.affinity that implement Message

Modifier and Type	Class and Description
class	AffinityTopologyVersion

Uses of Message in org.apache.ignite.internal.processors.authentication

Classes in org.apache.ignite.internal.processors.authentication that implement Message

Modifier and Type	Class and Description
class	UserAuthenticateRequestMessage Message is sent from client to coordinator node when a user needs to authorize on client node.
class	UserAuthenticateResponseMessage Is sent from coordinator node to client to deliver the results of the user authentication.
class	UserManagementOperationFinishedMessage Message indicating that user operation is finished locally on the node.

Uses of Message in org.apache.ignite.internal.processors.cache

Subinterfaces of Message in org.apache.ignite.internal.processors.cache

Modifier and Type	Interface and Description
interface	CacheEntryPredicate
interface	CacheObject
interface	KeyCacheObject

Classes in org.apache.ignite.internal.processors.cache that implement Message

Modifier and Type	Class and Description
class	CacheEntryInfoCollection
class	CacheEntryPredicateAdapter
class	CacheEntryPredicateContainsValue
class	CacheEntryPredicateHasValue
class	CacheEntryPredicateNoValue
class	CacheEntrySerializablePredicate
class	CacheEvictionEntry
class	CacheInvokeDirectResult
class	CacheObjectAdapter
class	CacheObjectByteArrayImpl Cache object over byte array.
class	CacheObjectImpl
class	GridCacheEntryInfo Entry information that gets passed over wire.
class	GridCacheGroupIdMessage Message related to particular cache group.
class	GridCacheIdMessage Message related to particular cache.
class	GridCacheMessage Parent of all cache messages.
class	GridCacheReturn Return value for cases where both, value and success flag need to be returned.
class	GridChangeGlobalStateMessageResponse
class	KeyCacheObjectImpl
class	WalStateAckMessage WAL state ack message (sent from participant node to coordinator).

Uses of Message in org.apache.ignite.internal.processors.cache.binary

Classes in org.apache.ignite.internal.processors.cache.binary that implement Message

Modifier and Type	Class and Description
class	MetadataRequestMessage As DiscoveryCustomMessage messages are delivered to client nodes asynchronously it is possible that server nodes are allowed to send to clients some BinaryObjects clients don't have metadata for.
class	MetadataResponseMessage Carries latest version of metadata to client as a response for MetadataRequestMessage.

Uses of Message in org.apache.ignite.internal.processors.cache.distributed

Classes in org.apache.ignite.internal.processors.cache.distributed that implement Message

Modifier and Type	Class and Description
class	GridCacheTtlUpdateRequest
class	GridCacheTxRecoveryRequest Message sent to check that transactions related to transaction were prepared on remote node.
class	GridCacheTxRecoveryResponse Transactions recovery check response.
class	GridDistributedBaseMessage Base for all messages in replicated cache.
class	GridDistributedLockRequest Lock request message.
class	GridDistributedLockResponse Lock response message.
class	GridDistributedTxFinishRequest Transaction completion message.
class	GridDistributedTxFinishResponse Transaction finish response.
class	GridDistributedTxPrepareRequest Transaction prepare request for optimistic and eventually consistent transactions.
class	GridDistributedTxPrepareResponse Response to prepare request.
class	GridDistributedUnlockRequest Lock request message.

Uses of Message in org.apache.ignite.internal.processors.cache.distributed.dht

Classes in org.apache.ignite.internal.processors.cache.distributed.dht that implement Message

Modifier and Type	Class and Description
class	GridDhtAffinityAssignmentRequest Affinity assignment request.
class	GridDhtAffinityAssignmentResponse Affinity assignment response.
class	GridDhtLockRequest DHT lock request.
class	GridDhtLockResponse DHT cache lock response.
class	GridDhtTxFinishRequest Near transaction finish request.
class	GridDhtTxFinishResponse DHT transaction finish response.
class	GridDhtTxOnePhaseCommitAckRequest One Phase Commit Near transaction ack request.
class	GridDhtTxPrepareRequest DHT prepare request.
class	GridDhtTxPrepareResponse DHT transaction prepare response.
class	GridDhtUnlockRequest DHT cache unlock request.

Uses of Message in org.apache.ignite.internal.processors.cache.distributed.dht.atomic

Classes in org.apache.ignite.internal.processors.cache.distributed.dht.atomic that implement Message

Modifier and Type	Class and Description
class	GridDhtAtomicAbstractUpdateRequest
class	GridDhtAtomicDeferredUpdateResponse Deferred dht atomic update response.
class	GridDhtAtomicNearResponse Message sent from DHT nodes to near node in FULL_SYNC mode.
class	GridDhtAtomicSingleUpdateRequest
class	GridDhtAtomicUpdateRequest Lite dht cache backup update request.
class	GridDhtAtomicUpdateResponse DHT atomic cache backup update response.
class	GridNearAtomicAbstractSingleUpdateRequest
class	GridNearAtomicAbstractUpdateRequest
class	GridNearAtomicCheckUpdateRequest
class	GridNearAtomicFullUpdateRequest Lite DHT cache update request sent from near node to primary node.
class	GridNearAtomicSingleUpdateFilterRequest
class	GridNearAtomicSingleUpdateInvokeRequest
class	GridNearAtomicSingleUpdateRequest
class	GridNearAtomicUpdateResponse DHT atomic cache near update response.
class	NearCacheUpdates
class	UpdateErrors

Uses of Message in org.apache.ignite.internal.processors.cache.distributed.dht.preloader

Classes in org.apache.ignite.internal.processors.cache.distributed.dht.preloader that implement Message

Modifier and Type	Class and Description
class	CacheGroupAffinityMessage Information about affinity assignment.
class	GridDhtForceKeysRequest Force keys request.
class	GridDhtForceKeysResponse Force keys response.
class	GridDhtPartitionDemandLegacyMessage Partition demand request.
class	GridDhtPartitionDemandMessage Partition demand request.
class	GridDhtPartitionExchangeId Exchange ID.
class	GridDhtPartitionsAbstractMessage Request for single partition info.
class	GridDhtPartitionsFullMessage Information about partitions of all nodes in topology.
class	GridDhtPartitionsSingleMessage Information about partitions of a single node.
class	GridDhtPartitionsSingleRequest Request for single partition info.
class	GridDhtPartitionSupplyMessage Partition supply message.

Uses of Message in org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch

Classes in org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch that implement Message

Modifier and Type	Class and Description
class	LatchAckMessage Message is used to send acks for Latch instances management.

Uses of Message in org.apache.ignite.internal.processors.cache.distributed.near

Classes in org.apache.ignite.internal.processors.cache.distributed.near that implement Message

Modifier and Type	Class and Description
class	CacheVersionedValue Cache object and version.
class	GridNearGetRequest Get request.
class	GridNearGetResponse Get response.
class	GridNearLockRequest Near cache lock request to primary node.
class	GridNearLockResponse Near cache lock response.
class	GridNearSingleGetRequest
class	GridNearSingleGetResponse
class	GridNearTxFinishRequest Near transaction finish request.
class	GridNearTxFinishResponse Reply for synchronous phase 2.
class	GridNearTxPrepareRequest Near transaction prepare request to primary node.
class	GridNearTxPrepareResponse Near cache prepare response.
class	GridNearUnlockRequest Near cache unlock request.

Methods in org.apache.ignite.internal.processors.cache.distributed.near that return Message

Modifier and Type	Method and Description
Message	GridNearSingleGetResponse.result()

Constructors in org.apache.ignite.internal.processors.cache.distributed.near with parameters of type Message

Constructor and Description
GridNearSingleGetResponse(int cacheId, long futId, AffinityTopologyVersion topVer, Message res, boolean invalidPartitions, boolean addDepInfo)

Uses of Message in org.apache.ignite.internal.processors.cache.persistence.tree

Classes in org.apache.ignite.internal.processors.cache.persistence.tree that implement Message

Modifier and Type	Class and Description
protected static class	BPlusTree.DestroyBag Reuse bag for destroy.

Uses of Message in org.apache.ignite.internal.processors.cache.query

Classes in org.apache.ignite.internal.processors.cache.query that implement Message

Modifier and Type	Class and Description
class	GridCacheQueryRequest Query request.
class	GridCacheQueryResponse Query request.
class	GridCacheSqlQuery Query.

Uses of Message in org.apache.ignite.internal.processors.cache.query.continuous

Classes in org.apache.ignite.internal.processors.cache.query.continuous that implement Message

Modifier and Type	Class and Description
class	CacheContinuousQueryBatchAck Batch acknowledgement.
class	CacheContinuousQueryEntry Continuous query entry.

Uses of Message in org.apache.ignite.internal.processors.cache.transactions

Classes in org.apache.ignite.internal.processors.cache.transactions that implement Message

Modifier and Type	Class and Description
class	IgniteTxEntry Transaction entry.
class	IgniteTxKey Cache transaction key.
class	TxEntryValueHolder Auxiliary class to hold value, value-has-been-set flag, value update operation, value bytes.
class	TxLock Corresponds to one GridCacheMvccCandidate from local MVCC candidates queue.
class	TxLockList List of transaction locks for particular key.
class	TxLocksRequest Transactions lock list request.
class	TxLocksResponse Transactions lock list response.

Uses of Message in org.apache.ignite.internal.processors.cache.version

Classes in org.apache.ignite.internal.processors.cache.version that implement Message

Modifier and Type	Class and Description
class	GridCacheRawVersionedEntry<K,V> Raw versioned entry.
class	GridCacheVersion Grid unique version.
class	GridCacheVersionEx Extended cache version which also has additional DR version.

Uses of Message in org.apache.ignite.internal.processors.cacheobject

Classes in org.apache.ignite.internal.processors.cacheobject that implement Message

Modifier and Type	Class and Description
class	UserCacheObjectByteArrayImpl Wraps value provided by user, must be copied before stored in cache.
class	UserCacheObjectImpl Wraps value provided by user, must be serialized before stored in cache.
class	UserKeyCacheObjectImpl Wraps key provided by user, must be serialized before stored in cache.

Uses of Message in org.apache.ignite.internal.processors.cluster

Classes in org.apache.ignite.internal.processors.cluster that implement Message

Modifier and Type	Class and Description
class	ClusterMetricsUpdateMessage

Uses of Message in org.apache.ignite.internal.processors.continuous

Classes in org.apache.ignite.internal.processors.continuous that implement Message

Modifier and Type	Class and Description
class	ContinuousRoutineStartResultMessage
class	GridContinuousMessage Continuous processor message.

Uses of Message in org.apache.ignite.internal.processors.datastreamer

Classes in org.apache.ignite.internal.processors.datastreamer that implement Message

Modifier and Type	Class and Description
class	DataStreamerEntry
class	DataStreamerRequest
class	DataStreamerResponse

Uses of Message in org.apache.ignite.internal.processors.hadoop

Classes in org.apache.ignite.internal.processors.hadoop that implement Message

Modifier and Type	Class and Description
class	HadoopJobId Job ID.

Uses of Message in org.apache.ignite.internal.processors.hadoop.shuffle

Classes in org.apache.ignite.internal.processors.hadoop.shuffle that implement Message

Modifier and Type	Class and Description
class	HadoopDirectShuffleMessage Direct shuffle message.
class	HadoopShuffleAck Acknowledgement message.
class	HadoopShuffleFinishRequest Shuffle finish request.
class	HadoopShuffleFinishResponse Shuffle finish response.
class	HadoopShuffleMessage Shuffle message.

Uses of Message in org.apache.ignite.internal.processors.igfs

Classes in org.apache.ignite.internal.processors.igfs that implement Message

Modifier and Type	Class and Description
class	IgfsAckMessage Block write request acknowledgement message.
class	IgfsBlockKey File's binary data block key.
class	IgfsBlocksMessage IGFS write blocks message.
class	IgfsCommunicationMessage Base class for all IGFS communication messages sent between nodes.
class	IgfsDeleteMessage Indicates that entry scheduled for delete was actually deleted.
class	IgfsFileAffinityRange Affinity range.
class	IgfsFragmentizerRequest Fragmentizer request.
class	IgfsFragmentizerResponse Fragmentizer response.
class	IgfsSyncMessage Basic sync message.

Uses of Message in org.apache.ignite.internal.processors.marshaller

Classes in org.apache.ignite.internal.processors.marshaller that implement Message

Modifier and Type	Class and Description
class	MissingMappingRequestMessage Client node receives discovery messages in asynchronous mode so it is possible that all server nodes already accepted new mapping but clients are unaware about it.
class	MissingMappingResponseMessage On receiving a MissingMappingRequestMessage mapping request server node looks up class name for requested platformId and typeId in its local marshaller cache and sends back a MissingMappingResponseMessage mapping response with resolved class name.

Uses of Message in org.apache.ignite.internal.processors.query.h2.twostep.messages

Classes in org.apache.ignite.internal.processors.query.h2.twostep.messages that implement Message

Modifier and Type	Class and Description
class	GridQueryCancelRequest Cancel request.
class	GridQueryFailResponse Error message.
class	GridQueryNextPageRequest Request to fetch next page.
class	GridQueryNextPageResponse Next page response.

Methods in org.apache.ignite.internal.processors.query.h2.twostep.messages that return types with arguments of type Message

Modifier and Type	Method and Description
Collection<Message>	GridQueryNextPageResponse.values()

Constructor parameters in org.apache.ignite.internal.processors.query.h2.twostep.messages with type arguments of type Message

Constructor and Description
GridQueryNextPageResponse(long qryReqId, int segmentId, int qry, int page, int allRows, int cols, Collection<Message> vals, Collection<?> plainRows, boolean last)

Uses of Message in org.apache.ignite.internal.processors.query.schema.message

Classes in org.apache.ignite.internal.processors.query.schema.message that implement Message

Modifier and Type	Class and Description
class	SchemaOperationStatusMessage Schema operation status message.

Uses of Message in org.apache.ignite.internal.processors.rest.handlers.task

Classes in org.apache.ignite.internal.processors.rest.handlers.task that implement Message

Modifier and Type	Class and Description
class	GridTaskResultRequest Task result request.
class	GridTaskResultResponse Task result response.

Uses of Message in org.apache.ignite.internal.util

Classes in org.apache.ignite.internal.util with type parameters of type Message

Modifier and Type	Class and Description
class	GridMessageCollection<M extends Message> Collection of messages.

Classes in org.apache.ignite.internal.util that implement Message

Modifier and Type	Class and Description
class	GridByteArrayList Re-sizable array implementation of the byte list (eliminating auto-boxing of primitive byte type).
class	GridIntList Minimal list API to work with primitive ints.
class	GridLongList Minimal list API to work with primitive longs.
class	GridMessageCollection<M extends Message> Collection of messages.
class	UUIDCollectionMessage Collection of UUIDs.

Methods in org.apache.ignite.internal.util with type parameters of type Message

Modifier and Type	Method and Description
static <X extends Message> GridMessageCollection<X>	GridMessageCollection.of(X... msgs)

Methods in org.apache.ignite.internal.util with parameters of type Message

Modifier and Type	Method and Description
static <X extends Message> GridMessageCollection<X>	GridMessageCollection.of(X... msgs)
static int	IgniteUtils.writeMessageFully(Message msg, OutputStream out, ByteBuffer buf, MessageWriter writer) Fully writes communication message to provided stream.

Uses of Message in org.apache.ignite.internal.util.nio

Methods in org.apache.ignite.internal.util.nio with parameters of type Message

Modifier and Type	Method and Description
boolean	GridNioMessageReader.read(UUID nodeId, Message msg, ByteBuffer buf)
boolean	GridTcpNioCommunicationClient.sendMessage(UUID nodeId, Message msg, IgniteInClosure<IgniteException> c)
boolean	GridCommunicationClient.sendMessage(UUID nodeId, Message msg, IgniteInClosure<IgniteException> c)
boolean	GridShmemCommunicationClient.sendMessage(UUID nodeId, Message msg, IgniteInClosure<IgniteException> c)
void	GridNioServer.sendSystem(GridNioSession ses, Message msg) Adds message at the front of the queue without acquiring back pressure semaphore.
void	GridNioServer.sendSystem(GridNioSession ses, Message msg, IgniteInClosure<? super IgniteInternalFuture<?>> lsnr) Adds message at the front of the queue without acquiring back pressure semaphore.
boolean	GridNioMessageWriter.write(UUID nodeId, Message msg, ByteBuffer buf)
int	GridNioMessageWriter.writeFully(UUID nodeId, Message msg, OutputStream out, ByteBuffer buf)

Method parameters in org.apache.ignite.internal.util.nio with type arguments of type Message

Modifier and Type	Method and Description
GridNioServer.Builder<T>	GridNioServer.Builder.skipRecoveryPredicate(IgnitePredicate<Message> skipRecoveryPred)

Uses of Message in org.apache.ignite.plugin.extensions.communication

Methods in org.apache.ignite.plugin.extensions.communication with type parameters of type Message

Modifier and Type	Method and Description
<T extends Message> T	MessageReader.readMessage(String name) Reads nested message.

Methods in org.apache.ignite.plugin.extensions.communication that return Message

Modifier and Type	Method and Description
Message	MessageFactory.create(short type) Creates new message instance of provided type.

Methods in org.apache.ignite.plugin.extensions.communication with parameters of type Message

Modifier and Type	Method and Description
boolean	MessageWriter.writeMessage(String name, Message val) Writes nested message.

Method parameters in org.apache.ignite.plugin.extensions.communication with type arguments of type Message

Modifier and Type	Method and Description
boolean	MessageReader.afterMessageRead(Class<? extends Message> msgCls) Callback that must be invoked by a message implementation after message body finished decoding.
void	MessageReader.setCurrentReadClass(Class<? extends Message> msgCls) Sets type of message currently read.
void	MessageWriter.setCurrentWriteClass(Class<? extends Message> msgCls) Sets type of message currently written.

Uses of Message in org.apache.ignite.spi.collision.jobstealing

Classes in org.apache.ignite.spi.collision.jobstealing that implement Message

Modifier and Type	Class and Description
class	JobStealingRequest Job stealing request.

Uses of Message in org.apache.ignite.spi.communication.tcp

Methods in org.apache.ignite.spi.communication.tcp with parameters of type Message

Modifier and Type	Method and Description
protected void	TcpCommunicationSpi.notifyListener(UUID sndId, Message msg, IgniteRunnable msgC)
void	TcpCommunicationMetricsListener.onMessageReceived(Message msg, UUID nodeId) Collects statistics for message received by SPI.
void	TcpCommunicationMetricsListener.onMessageSent(Message msg, UUID nodeId) Collects statistics for message sent by SPI.
void	TcpCommunicationSpi.sendMessage(ClusterNode node, Message msg) Sends given message to destination node.
void	TcpCommunicationSpi.sendMessage(ClusterNode node, Message msg, IgniteInClosure<IgniteException> ackC) Sends given message to destination node.

Method parameters in org.apache.ignite.spi.communication.tcp with type arguments of type Message

Modifier and Type	Method and Description
void	TcpCommunicationSpi.setListener(CommunicationListener<Message> lsnr) Set communication listener.

Uses of Message in org.apache.ignite.spi.communication.tcp.messages

Classes in org.apache.ignite.spi.communication.tcp.messages that implement Message

Modifier and Type	Class and Description
class	HandshakeMessage Handshake message.
class	HandshakeMessage2 Updated handshake message.
class	NodeIdMessage Node ID message.
class	RecoveryLastReceivedMessage Recovery acknowledgment message.