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.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.mvcc
org.apache.ignite.internal.processors.cache.mvcc.msg
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 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, @Nullable 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	GridIoSecurityAwareMessage
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) Always throws UnsupportedOperationException.
@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 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(ClusterNode node, GridTopic topic, Message msg, byte plc, Span span)
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
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 and 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 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.encryption

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

Modifier and Type	Class and 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 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	GridCacheMvccEntryInfo
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	GridDhtTxQueryEnlistRequest
class	GridDhtTxQueryEnlistResponse
class	GridDhtTxQueryFirstEnlistRequest First enlist request.
class	GridDhtUnlockRequest DHT cache unlock request.
class	GridInvokeValue
class	PartitionUpdateCountersMessage Partition update counters message.

Methods in org.apache.ignite.internal.processors.cache.distributed.dht that return types with arguments of type Message

Modifier and Type	Method and Description
List<Message>	GridDhtTxQueryEnlistRequest.values()

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.
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 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	GridNearTxEnlistRequest Request to enlist into transaction and acquire locks for entries produced with Cache API operations.
class	GridNearTxEnlistResponse A response to GridNearTxEnlistRequest.
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	GridNearTxQueryEnlistRequest
class	GridNearTxQueryEnlistResponse A response to GridNearTxQueryEnlistRequest.
class	GridNearTxQueryResultsEnlistRequest Request to enlist into transaction and acquire locks for entries produced with complex DML queries with reducer step.
class	GridNearTxQueryResultsEnlistResponse A response to GridNearTxQueryResultsEnlistRequest.
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, @Nullable Message res, boolean invalidPartitions, boolean addDepInfo)

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

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

Modifier and Type	Interface and Description
interface	MvccSnapshot MVCC snapshot which holds the following information: - Current MVCC version which should be used for visibility checks - List of active transactions which should not be visible to current transaction - Cleanup version which is used to help vacuum process.

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

Modifier and Type	Class and Description
class	DeadlockProbe Probe message travelling between transactions (from waiting to blocking) during deadlock detection.
class	MvccSnapshotWithoutTxs
class	MvccVersionImpl Base MVCC version implementation.
class	ProbedTx Contains attributes of tx visited during deadlock detection.

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

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

Modifier and Type	Interface and Description
interface	MvccMessage Common interface for all MVCC-related messages.

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

Modifier and Type	Class and Description
class	MvccAckRequestQueryCntr
class	MvccAckRequestQueryId
class	MvccAckRequestTx
class	MvccAckRequestTxAndQueryCntr
class	MvccAckRequestTxAndQueryId
class	MvccActiveQueriesMessage
class	MvccFutureResponse
class	MvccQuerySnapshotRequest Request to get MVCC snapshot for a query.
class	MvccRecoveryFinishedMessage
class	MvccSnapshotResponse
class	MvccTxSnapshotRequest Request to get MVCC snapshot for a new transaction.

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

Method parameters in org.apache.ignite.internal.processors.cache.transactions with type arguments of type Message

Modifier and Type	Method and Description
void	IgniteTxHandler.mvccEnlistBatch(GridDhtTxRemote tx, GridCacheContext ctx, EnlistOperation op, List<KeyCacheObject> keys, List<Message> vals, MvccSnapshot snapshot, IgniteUuid futId, int batchNum) Writes updated values on the backup node.

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

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

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

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

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

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

Modifier and Type	Class and 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 and Description
boolean	GridNioMessageReader.read(@Nullable UUID nodeId, Message msg, ByteBuffer buf)
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.
boolean	GridNioMessageWriter.write(@Nullable UUID nodeId, Message msg, ByteBuffer buf)
int	GridNioMessageWriter.writeFully(@Nullable 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
default @Nullable Message	MessageFactoryProvider.create(short type) Always throws UnsupportedOperationException.
@Nullable Message	MessageFactory.create(short type) Deprecated. 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	IgniteMessageFactory.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 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, 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 and 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 and Description
interface	TcpConnectionIndexAwareMessage

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

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