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.direct
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.cache
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.near
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.clock
org.apache.ignite.internal.processors.continuous
org.apache.ignite.internal.processors.datastreamer	Data streamer processor.
org.apache.ignite.internal.processors.igfs	Contains high performance file system processer.
org.apache.ignite.internal.processors.rest.handlers.task
org.apache.ignite.internal.processors.streamer	TODO.
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.

Uses of Message in org.apache.ignite.internal

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.

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	DirectByteBufferStream.readMessage()
<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
void	DirectByteBufferStream.writeMessage(Message msg, MessageWriter writer)
boolean	DirectMessageWriter.writeMessage(String name, Message msg) Writes nested message.

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.

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

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

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

Modifier and Type	Method and Description
void	GridIoManager.send(ClusterNode node, GridTopic topic, Message msg, GridIoPolicy plc)
void	GridIoManager.send(ClusterNode node, Object topic, Message msg, GridIoPolicy plc)
void	GridIoManager.send(Collection<? extends ClusterNode> nodes, GridTopic topic, Message msg, GridIoPolicy plc)
void	GridIoManager.send(Collection<? extends ClusterNode> nodes, Object topic, Message msg, GridIoPolicy plc)
void	GridIoManager.send(UUID nodeId, GridTopic topic, Message msg, GridIoPolicy plc)
void	GridIoManager.send(UUID nodeId, Object topic, Message msg, GridIoPolicy plc)
void	GridIoManager.sendOrderedMessage(ClusterNode node, Object topic, Message msg, GridIoPolicy plc, long timeout, boolean skipOnTimeout)
void	GridIoManager.sendOrderedMessage(Collection<? extends ClusterNode> nodes, Object topic, Message msg, GridIoPolicy plc, long timeout, boolean skipOnTimeout)
void	GridIoManager.sendOrderedMessage(UUID nodeId, Object topic, Message msg, GridIoPolicy plc, long timeout, boolean skipOnTimeout)

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(byte 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(GridIoPolicy 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.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	GridCacheEvictionRequest Cache eviction request.
class	GridCacheEvictionResponse Cache eviction response.
class	GridCacheMessage Parent of all cache messages.
class	GridCacheReturn Return value for cases where both, value and success flag need to be returned.
class	KeyCacheObjectImpl

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	GridCacheOptimisticCheckPreparedTxRequest Message sent to check that transactions related to some optimistic transaction were prepared on remote node.
class	GridCacheOptimisticCheckPreparedTxResponse Check prepared transactions response.
class	GridCacheTtlUpdateRequest
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	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	GridDhtAtomicDeferredUpdateResponse Deferred dht atomic update response.
class	GridDhtAtomicUpdateRequest Lite dht cache backup update request.
class	GridDhtAtomicUpdateResponse DHT atomic cache backup update response.
class	GridNearAtomicUpdateRequest Lite DHT cache update request sent from near node to primary node.
class	GridNearAtomicUpdateResponse DHT atomic cache near update response.

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	GridDhtForceKeysRequest Force keys request.
class	GridDhtForceKeysResponse Force keys response.
class	GridDhtPartitionDemandMessage Partition demand request.
class	GridDhtPartitionExchangeId Exchange ID.
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.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.
class	GridNearLockResponse Near cache lock response.
class	GridNearTxFinishRequest Near transaction finish request.
class	GridNearTxFinishResponse Reply for synchronous phase 2.
class	GridNearTxPrepareRequest Near transaction prepare request.
class	GridNearTxPrepareResponse Near cache prepare response.
class	GridNearUnlockRequest Near cache unlock request.

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.

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	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.

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.clock

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

Modifier and Type	Class and Description
class	GridClockDeltaSnapshotMessage Message containing time delta map for all nodes.
class	GridClockDeltaVersion Version for time delta snapshot.

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	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.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.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.processors.streamer

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

Modifier and Type	Class and Description
class	GridStreamerCancelRequest Streamer cancel request.
class	GridStreamerExecutionRequest
class	GridStreamerResponse

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

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	GridLongList Minimal list API to work with primitive longs.

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

Modifier and Type	Method and Description
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	GridCommunicationClient.sendMessage(UUID nodeId, Message msg)
boolean	GridTcpCommunicationClient.sendMessage(UUID nodeId, Message msg)
boolean	GridTcpNioCommunicationClient.sendMessage(UUID nodeId, Message msg)
GridNioFuture<?>	GridNioServer.sendSystem(GridNioSession ses, Message msg) Adds message at the front of the queue without acquiring back pressure semaphore.
GridNioFuture<?>	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(byte 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.

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

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

Modifier and Type	Class and Description
static class	TcpCommunicationSpi.HandshakeMessage Handshake message.
static class	TcpCommunicationSpi.NodeIdMessage Node ID message.
static class	TcpCommunicationSpi.RecoveryLastReceivedMessage Recovery acknowledgment message.

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	TcpCommunicationSpi.sendMessage(ClusterNode node, Message msg) 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.