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.managers.checkpoint	TODO.
org.apache.ignite.internal.managers.communication	TODO.
org.apache.ignite.internal.managers.deployment	TODO.
org.apache.ignite.internal.managers.encryption	Encryption manager classes.
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	This package contain cache-related processors & persistence implementation.
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.snapshot
org.apache.ignite.internal.processors.cache.persistence.tree.reuse
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.marshaller
org.apache.ignite.internal.processors.odbc
org.apache.ignite.internal.processors.query.h2.twostep.messages
org.apache.ignite.internal.processors.query.messages
org.apache.ignite.internal.processors.query.schema.message
org.apache.ignite.internal.processors.query.stat.messages
org.apache.ignite.internal.processors.rest.handlers.task
org.apache.ignite.internal.processors.service
org.apache.ignite.internal.util	System-wide utility routine and helper classes.
org.apache.ignite.internal.util.distributed
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.internal	Contains connection health-checkers for TCP/IP-based implementation of 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	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	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	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	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	Description
boolean	DirectMessageWriter.writeMessage(String name, @Nullable Message msg)	Writes nested message.

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

Modifier and Type	Method	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	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	Description
void	DirectByteBufferStream.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	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	Description
class	GridIoMessage	Wrapper for all grid messages.
class	GridIoSecurityAwareMessage
class	GridIoUserMessage	User message wrapper.
class	IgniteIoTestMessage

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

Modifier and Type	Method	Description
@Nullable Message	IgniteMessageFactoryImpl.create(short directType)	Creates new message instance of provided direct type.
Message	GridIoMessage.message()

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

Modifier and Type	Method	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(UUID nodeId, Object topic, Message msg, byte plc)
void	GridIoManager.sendToCustomTopic(ClusterNode node, Object topic, Message msg, byte plc)
void	GridIoManager.sendToGridTopic(Collection<? extends ClusterNode> nodes, GridTopic topic, Message msg, byte plc)
void	GridIoManager.sendToGridTopic(UUID nodeId, GridTopic 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, Span span)
void	GridIoManager.sendToGridTopic(ClusterNode node, GridTopic topic, Message msg, byte plc, IgniteInClosure<IgniteException> ackC)

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

Modifier and Type	Method	Description
void	IgniteMessageFactoryImpl.register(short directType, Supplier<Message> supplier)	Register message factory with given direct type.

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

Constructor	Description
GridIoMessage(byte plc, Object topic, int topicOrd, Message msg, boolean ordered, long timeout, boolean skipOnTimeout)
GridIoSecurityAwareMessage(UUID secSubjId, 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	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.encryption

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

Modifier and Type	Class	Description
class	GenerateEncryptionKeyRequest	Generate encryption key request.
class	GenerateEncryptionKeyResponse	Generate encryption key response.

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	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	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	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	Description
interface	CacheEntryPredicate
interface	CacheObject
interface	KeyCacheObject

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

Modifier and Type	Class	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
protected static class	IgniteCacheOffheapManagerImpl.ExpiredKeyCacheObject	This entry key is used to indicate that an expired entry has already been deleted from PendingEntriesTree and doesn't need to participate in PendingEntriesTree cleanup again.
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	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	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	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.
class	PartitionUpdateCountersMessage	Partition update counters message.

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	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	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.
class	GridDhtPartitionSupplyMessageV2	Supply message with supplier error transfer support.

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	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	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	Description
Message	GridNearSingleGetResponse.result()

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

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

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

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

Modifier and Type	Class	Description
class	IncrementalSnapshotAwareMessage	Message that holds a transaction message and incremental snapshot ID.
class	SnapshotFilesFailureMessage	Message indicating a failure occurred during processing snapshot files request.
class	SnapshotFilesRequestMessage

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

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

Modifier and Type	Class	Description
class	LongListReuseBag	GridLongList-based reuse bag.

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	Description
class	GridCacheQueryRequest	Query request.
class	GridCacheQueryResponse	Page of cache query response.
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	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	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	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	Description
class	PlatformCacheObjectImpl	Wraps value provided by platform, must be transformed before stored in cache.
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	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	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	Description
class	DataStreamerEntry
class	DataStreamerRequest
class	DataStreamerResponse

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

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

Modifier and Type	Class	Description
class	ClientMessage

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	Description
class	GridQueryCancelRequest	Cancel map part of query 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	Description
Collection<Message>	GridQueryNextPageResponse.values()

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

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

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

Modifier and Type	Class	Description
class	GridQueryKillRequest	Query kill request.
class	GridQueryKillResponse	Query kill response.

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	Description
class	SchemaOperationStatusMessage	Schema operation status message.

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

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

Modifier and Type	Class	Description
class	StatisticsColumnData	Statistics by column (or by set of columns, if they collected together)
class	StatisticsDecimalMessage	H2 Decimal.
class	StatisticsKeyMessage	Key, describing the object of statistics.
class	StatisticsObjectData	Statistics for some object (index or table) in database.
class	StatisticsRequest	Request for statistics.
class	StatisticsResponse	Response for statistics request.

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	Description
class	GridTaskResultRequest	Task result request.
class	GridTaskResultResponse	Task result response.

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

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

Modifier and Type	Class	Description
class	ServiceDeploymentProcessId	Service deployment process' identifier.
class	ServiceSingleNodeDeploymentResult	Service single node deployment result.
class	ServiceSingleNodeDeploymentResultBatch	Batch of service single node deployment result.

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	Description
class	GridMessageCollection<M extends Message>	Collection of messages.

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

Modifier and Type	Class	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	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	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.distributed

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

Modifier and Type	Class	Description
class	SingleNodeMessage<R extends Serializable>	Single node result message.

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	Description
boolean	GridCommunicationClient.sendMessage(@Nullable UUID nodeId, Message msg, @Nullable IgniteInClosure<IgniteException> c)
boolean	GridTcpNioCommunicationClient.sendMessage(@Nullable 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, @Nullable IgniteInClosure<? super IgniteInternalFuture<?>> lsnr)	Adds message at the front of the queue without acquiring back pressure semaphore.

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

Modifier and Type	Method	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	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	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	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	Description
boolean	MessageReader.afterMessageRead(Class<? extends Message> msgCls)	Callback that must be invoked by a message implementation after message body finished decoding.
void	MessageFactory.register(short directType, Supplier<Message> supplier)	Register message factory with given direct type.
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	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	Description
protected void	TcpCommunicationSpi.notifyListener(UUID sndId, Message msg, IgniteRunnable msgC)
void	TcpCommunicationMetricsListener.onMessageReceived(Message msg, Object consistentId)	Collects statistics for message received by SPI.
void	TcpCommunicationMetricsListener.onMessageSent(Message msg, Object consistentId)	Collects statistics for message sent by SPI.
IgniteInternalFuture<Channel>	TcpCommunicationSpi.openChannel(ClusterNode remote, Message initMsg)
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	Description
void	TcpCommunicationSpi.setListener(CommunicationListener<Message> lsnr)	Deprecated.

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

Subinterfaces of Message in org.apache.ignite.spi.communication.tcp.internal

Modifier and Type	Interface	Description
interface	TcpConnectionIndexAwareMessage

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

Modifier and Type	Class	Description
class	TcpInverseConnectionResponseMessage	Inverse connection response message sent by client node as a response to inverse connection request received by discovery.

Methods in org.apache.ignite.spi.communication.tcp.internal that return types with arguments of type Message

Modifier and Type	Method	Description
GridNioServer<Message>	GridNioServerWrapper.nio()	Deprecated. Returns original nio server instance.
GridNioServer<Message>	GridNioServerWrapper.resetNioServer()	Deprecated. Recreates tpcSrvr socket instance.

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

Modifier and Type	Method	Description
void	GridNioServerWrapper.onChannelCreate(GridSelectorNioSessionImpl ses, ConnectionKey connKey, Message msg)	Deprecated.
void	InboundConnectionHandler.onMessage(GridNioSession ses, Message msg)	This method is called whenever a GridNioParser returns non-null value.
void	InboundConnectionHandler.onMessageSent(GridNioSession ses, Message msg)	Handle message sent.
IgniteInternalFuture<Channel>	GridNioServerWrapper.openChannel(ClusterNode remote, Message initMsg)	Deprecated.

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

Modifier and Type	Method	Description
void	GridNioServerWrapper.nio(GridNioServer<Message> srv)	Deprecated.

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

Constructor	Description
GridNioServerWrapper(IgniteLogger log, TcpCommunicationConfiguration cfg, AttributeNames attributeNames, Tracing tracing, Function<UUID,ClusterNode> nodeGetter, Supplier<ClusterNode> locNodeSupplier, ConnectGateway connectGate, ClusterStateProvider stateProvider, Supplier<IgniteExceptionRegistry> eRegistrySupplier, CommunicationWorker commWorker, IgniteConfiguration igniteCfg, GridNioServerListener<Message> srvLsnr, String igniteInstanceName, WorkersRegistry workersRegistry, @Nullable GridMetricManager metricMgr, ThrowableBiFunction<ClusterNode,Integer,GridCommunicationClient,IgniteCheckedException> createTcpClientFun, CommunicationListener<Message> lsnr, TcpHandshakeExecutor tcpHandshakeExecutor)	Deprecated.
GridNioServerWrapper(IgniteLogger log, TcpCommunicationConfiguration cfg, AttributeNames attributeNames, Tracing tracing, Function<UUID,ClusterNode> nodeGetter, Supplier<ClusterNode> locNodeSupplier, ConnectGateway connectGate, ClusterStateProvider stateProvider, Supplier<IgniteExceptionRegistry> eRegistrySupplier, CommunicationWorker commWorker, IgniteConfiguration igniteCfg, GridNioServerListener<Message> srvLsnr, String igniteInstanceName, WorkersRegistry workersRegistry, @Nullable GridMetricManager metricMgr, ThrowableBiFunction<ClusterNode,Integer,GridCommunicationClient,IgniteCheckedException> createTcpClientFun, CommunicationListener<Message> lsnr, TcpHandshakeExecutor tcpHandshakeExecutor)	Deprecated.
InboundConnectionHandler(IgniteLogger log, TcpCommunicationConfiguration cfg, Function<UUID,ClusterNode> nodeGetter, Supplier<ClusterNode> locNodeSupplier, ClusterStateProvider stateProvider, ConnectionClientPool clientPool, CommunicationWorker commWorker, ConnectGateway connectGate, Supplier<FailureProcessor> failureProcessorSupplier, AttributeNames attributeNames, TcpCommunicationMetricsListener metricsLsnr, GridNioServerWrapper nioSrvWrapper, CountDownLatch ctxInitLatch, boolean client, Supplier<Ignite> igniteExSupplier, CommunicationListener<Message> lsnr)

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	Description
class	HandshakeMessage	Handshake message.
class	HandshakeMessage2	Updated handshake message.
class	HandshakeWaitMessage	Message requesting to wait until node's SPI context initialize.
class	NodeIdMessage	Node ID message.
class	RecoveryLastReceivedMessage	Recovery acknowledgment message.