Uses of Class
org.apache.ignite.plugin.extensions.communication.MessageAdapter

Packages that use MessageAdapter

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.version
org.apache.ignite.internal.processors.clock
org.apache.ignite.internal.processors.continuous
org.apache.ignite.internal.processors.dataload	Data loader 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 MessageAdapter in org.apache.ignite.internal

Subclasses of MessageAdapter in org.apache.ignite.internal

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 MessageAdapter in org.apache.ignite.internal.direct

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

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

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

Modifier and Type	Method and Description
void	DirectByteBufferStream.writeMessage(MessageAdapter msg, MessageWriter writer)
boolean	DirectMessageWriter.writeMessage(String name, MessageAdapter msg) Writes nested message.

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

Subclasses of MessageAdapter in org.apache.ignite.internal.managers.checkpoint

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

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

Subclasses of MessageAdapter in org.apache.ignite.internal.managers.communication

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 MessageAdapter

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

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

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

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

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

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

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

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

Subclasses of MessageAdapter in org.apache.ignite.internal.managers.deployment

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 MessageAdapter in org.apache.ignite.internal.managers.eventstorage

Subclasses of MessageAdapter in org.apache.ignite.internal.managers.eventstorage

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

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

Subclasses of MessageAdapter in org.apache.ignite.internal.processors.cache

Modifier and Type	Class and Description
class	GridCacheEvictionRequest<K,V> Cache eviction request.
class	GridCacheEvictionResponse<K,V> Cache eviction response.
class	GridCacheMessage<K,V> Parent of all cache messages.
class	GridCacheValueBytes Wrapped value bytes of cache entry.

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

Subclasses of MessageAdapter in org.apache.ignite.internal.processors.cache.distributed

Modifier and Type	Class and Description
class	GridCacheOptimisticCheckPreparedTxRequest<K,V> Message sent to check that transactions related to some optimistic transaction were prepared on remote node.
class	GridCacheOptimisticCheckPreparedTxResponse<K,V> Check prepared transactions response.
class	GridCacheTtlUpdateRequest<K,V>
class	GridDistributedBaseMessage<K,V> Base for all messages in replicated cache.
class	GridDistributedLockRequest<K,V> Lock request message.
class	GridDistributedLockResponse<K,V> Lock response message.
class	GridDistributedTxFinishRequest<K,V> Transaction completion message.
class	GridDistributedTxFinishResponse<K,V> Transaction finish response.
class	GridDistributedTxPrepareRequest<K,V> Transaction prepare request for optimistic and eventually consistent transactions.
class	GridDistributedTxPrepareResponse<K,V> Response to prepare request.
class	GridDistributedUnlockRequest<K,V> Lock request message.

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

Subclasses of MessageAdapter in org.apache.ignite.internal.processors.cache.distributed.dht

Modifier and Type	Class and Description
class	GridDhtAffinityAssignmentRequest<K,V> Affinity assignment request.
class	GridDhtAffinityAssignmentResponse<K,V> Affinity assignment response.
class	GridDhtLockRequest<K,V> DHT lock request.
class	GridDhtLockResponse<K,V> DHT cache lock response.
class	GridDhtTxFinishRequest<K,V> Near transaction finish request.
class	GridDhtTxFinishResponse<K,V> DHT transaction finish response.
class	GridDhtTxPrepareRequest<K,V> DHT prepare request.
class	GridDhtTxPrepareResponse<K,V> DHT transaction prepare response.
class	GridDhtUnlockRequest<K,V> DHT cache unlock request.

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

Subclasses of MessageAdapter in org.apache.ignite.internal.processors.cache.distributed.dht.atomic

Modifier and Type	Class and Description
class	GridDhtAtomicDeferredUpdateResponse<K,V> Deferred dht atomic update response.
class	GridDhtAtomicUpdateRequest<K,V> Lite dht cache backup update request.
class	GridDhtAtomicUpdateResponse<K,V> DHT atomic cache backup update response.
class	GridNearAtomicUpdateRequest<K,V> Lite DHT cache update request sent from near node to primary node.
class	GridNearAtomicUpdateResponse<K,V> DHT atomic cache near update response.

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

Subclasses of MessageAdapter in org.apache.ignite.internal.processors.cache.distributed.dht.preloader

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

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

Subclasses of MessageAdapter in org.apache.ignite.internal.processors.cache.distributed.near

Modifier and Type	Class and Description
class	GridNearGetRequest<K,V> Get request.
class	GridNearGetResponse<K,V> Get response.
class	GridNearLockRequest<K,V> Near cache lock request.
class	GridNearLockResponse<K,V> Near cache lock response.
class	GridNearTxFinishRequest<K,V> Near transaction finish request.
class	GridNearTxFinishResponse<K,V> Reply for synchronous phase 2.
class	GridNearTxPrepareRequest<K,V> Near transaction prepare request.
class	GridNearTxPrepareResponse<K,V> Near cache prepare response.
class	GridNearUnlockRequest<K,V> Near cache unlock request.

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

Subclasses of MessageAdapter in org.apache.ignite.internal.processors.cache.query

Modifier and Type	Class and Description
class	GridCacheQueryRequest<K,V> Query request.
class	GridCacheQueryResponse<K,V> Query request.

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

Subclasses of MessageAdapter in org.apache.ignite.internal.processors.cache.version

Modifier and Type	Class and Description
class	GridCacheVersion Grid unique version.
class	GridCacheVersionEx Extended cache version which also has additional DR version.

Uses of MessageAdapter in org.apache.ignite.internal.processors.clock

Subclasses of MessageAdapter in org.apache.ignite.internal.processors.clock

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 MessageAdapter in org.apache.ignite.internal.processors.continuous

Subclasses of MessageAdapter in org.apache.ignite.internal.processors.continuous

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

Uses of MessageAdapter in org.apache.ignite.internal.processors.dataload

Subclasses of MessageAdapter in org.apache.ignite.internal.processors.dataload

Modifier and Type	Class and Description
class	GridDataLoadRequest
class	GridDataLoadResponse

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

Subclasses of MessageAdapter in org.apache.ignite.internal.processors.igfs

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 MessageAdapter in org.apache.ignite.internal.processors.rest.handlers.task

Subclasses of MessageAdapter in org.apache.ignite.internal.processors.rest.handlers.task

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

Uses of MessageAdapter in org.apache.ignite.internal.processors.streamer

Subclasses of MessageAdapter in org.apache.ignite.internal.processors.streamer

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

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

Subclasses of MessageAdapter in org.apache.ignite.internal.util

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 MessageAdapter

Modifier and Type	Method and Description
static int	IgniteUtils.writeMessageFully(MessageAdapter msg, OutputStream out, ByteBuffer buf, MessageWriter writer) Fully writes communication message to provided stream.

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

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

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

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

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

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

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

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

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

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

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

Subclasses of MessageAdapter in org.apache.ignite.spi.collision.jobstealing

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

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

Subclasses of MessageAdapter in org.apache.ignite.spi.communication.tcp

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 MessageAdapter

Modifier and Type	Method and Description
protected void	TcpCommunicationSpi.notifyListener(UUID sndId, MessageAdapter msg, IgniteRunnable msgC)
void	TcpCommunicationSpi.sendMessage(ClusterNode node, MessageAdapter msg) Sends given message to destination node.

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

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