This is an automated email from the ASF dual-hosted git repository.
agoncharuk pushed a commit to branch ignite-2.9-revert-12568
in repository https://gitbox.apache.org/repos/asf/ignite.git
commit 31d324e3ea8c1b87a29b64b1506f91efeae2c9d4
Author: Alexey Goncharuk <alexey.goncha...@gmail.com>
AuthorDate: Thu Sep 10 14:39:33 2020 +0300
Explicitly inline core messages in message factory
---
.../communication/IgniteMessageFactoryImpl.java | 1055 ++++++++++++++++++++
1 file changed, 1055 insertions(+)
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/IgniteMessageFactoryImpl.java
b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/IgniteMessageFactoryImpl.java
index 68ce797..c5abe21 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/IgniteMessageFactoryImpl.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/IgniteMessageFactoryImpl.java
@@ -23,10 +23,180 @@ import java.util.List;
import java.util.function.Supplier;
import org.apache.ignite.IgniteException;
+import org.apache.ignite.internal.GridJobCancelRequest;
+import org.apache.ignite.internal.GridJobExecuteRequest;
+import org.apache.ignite.internal.GridJobExecuteResponse;
+import org.apache.ignite.internal.GridJobSiblingsRequest;
+import org.apache.ignite.internal.GridJobSiblingsResponse;
+import org.apache.ignite.internal.GridTaskCancelRequest;
+import org.apache.ignite.internal.GridTaskSessionRequest;
+import org.apache.ignite.internal.IgniteDiagnosticMessage;
+import org.apache.ignite.internal.binary.BinaryEnumObjectImpl;
+import org.apache.ignite.internal.binary.BinaryObjectImpl;
+import org.apache.ignite.internal.managers.checkpoint.GridCheckpointRequest;
+import org.apache.ignite.internal.managers.deployment.GridDeploymentInfoBean;
+import org.apache.ignite.internal.managers.deployment.GridDeploymentRequest;
+import org.apache.ignite.internal.managers.deployment.GridDeploymentResponse;
+import
org.apache.ignite.internal.managers.encryption.GenerateEncryptionKeyRequest;
+import
org.apache.ignite.internal.managers.encryption.GenerateEncryptionKeyResponse;
+import
org.apache.ignite.internal.managers.eventstorage.GridEventStorageMessage;
+import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
+import
org.apache.ignite.internal.processors.authentication.UserAuthenticateRequestMessage;
+import
org.apache.ignite.internal.processors.authentication.UserAuthenticateResponseMessage;
+import
org.apache.ignite.internal.processors.authentication.UserManagementOperationFinishedMessage;
+import org.apache.ignite.internal.processors.cache.CacheEntryInfoCollection;
+import
org.apache.ignite.internal.processors.cache.CacheEntryPredicateContainsValue;
+import
org.apache.ignite.internal.processors.cache.CacheEntrySerializablePredicate;
+import org.apache.ignite.internal.processors.cache.CacheEvictionEntry;
+import org.apache.ignite.internal.processors.cache.CacheInvokeDirectResult;
+import org.apache.ignite.internal.processors.cache.CacheObjectByteArrayImpl;
+import org.apache.ignite.internal.processors.cache.CacheObjectImpl;
+import org.apache.ignite.internal.processors.cache.GridCacheEntryInfo;
+import org.apache.ignite.internal.processors.cache.GridCacheMvccEntryInfo;
+import org.apache.ignite.internal.processors.cache.GridCacheReturn;
+import
org.apache.ignite.internal.processors.cache.GridChangeGlobalStateMessageResponse;
+import org.apache.ignite.internal.processors.cache.KeyCacheObjectImpl;
+import org.apache.ignite.internal.processors.cache.WalStateAckMessage;
+import
org.apache.ignite.internal.processors.cache.binary.MetadataRequestMessage;
+import
org.apache.ignite.internal.processors.cache.binary.MetadataResponseMessage;
+import
org.apache.ignite.internal.processors.cache.distributed.GridCacheTtlUpdateRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.GridCacheTxRecoveryRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.GridCacheTxRecoveryResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.GridDistributedLockRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.GridDistributedLockResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.GridDistributedTxFinishRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.GridDistributedTxFinishResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.GridDistributedTxPrepareRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.GridDistributedTxPrepareResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.GridDistributedUnlockRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtAffinityAssignmentRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtAffinityAssignmentResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLockRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLockResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxFinishRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxFinishResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxOnePhaseCommitAckRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxPrepareRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxPrepareResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxQueryEnlistRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxQueryEnlistResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxQueryFirstEnlistRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtUnlockRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.GridInvokeValue;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.PartitionUpdateCountersMessage;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicDeferredUpdateResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicNearResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicSingleUpdateRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicUpdateRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicUpdateResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicCheckUpdateRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicFullUpdateRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicSingleUpdateFilterRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicSingleUpdateInvokeRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicSingleUpdateRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.NearCacheUpdates;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.UpdateErrors;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.CacheGroupAffinityMessage;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtForceKeysRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtForceKeysResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandLegacyMessage;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandMessage;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionExchangeId;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplyMessage;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplyMessageV2;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsFullMessage;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsSingleMessage;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsSingleRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.LatchAckMessage;
+import
org.apache.ignite.internal.processors.cache.distributed.near.CacheVersionedValue;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearGetRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearGetResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearLockRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearLockResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearSingleGetRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearSingleGetResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxEnlistRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxEnlistResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxPrepareRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxPrepareResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxQueryEnlistRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxQueryEnlistResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxQueryResultsEnlistRequest;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxQueryResultsEnlistResponse;
+import
org.apache.ignite.internal.processors.cache.distributed.near.GridNearUnlockRequest;
+import org.apache.ignite.internal.processors.cache.mvcc.DeadlockProbe;
+import org.apache.ignite.internal.processors.cache.mvcc.MvccSnapshotWithoutTxs;
+import org.apache.ignite.internal.processors.cache.mvcc.MvccVersionImpl;
+import org.apache.ignite.internal.processors.cache.mvcc.ProbedTx;
+import
org.apache.ignite.internal.processors.cache.mvcc.msg.MvccAckRequestQueryCntr;
+import
org.apache.ignite.internal.processors.cache.mvcc.msg.MvccAckRequestQueryId;
+import org.apache.ignite.internal.processors.cache.mvcc.msg.MvccAckRequestTx;
+import
org.apache.ignite.internal.processors.cache.mvcc.msg.MvccAckRequestTxAndQueryCntr;
+import
org.apache.ignite.internal.processors.cache.mvcc.msg.MvccAckRequestTxAndQueryId;
+import
org.apache.ignite.internal.processors.cache.mvcc.msg.MvccActiveQueriesMessage;
+import org.apache.ignite.internal.processors.cache.mvcc.msg.MvccFutureResponse;
+import
org.apache.ignite.internal.processors.cache.mvcc.msg.MvccQuerySnapshotRequest;
+import
org.apache.ignite.internal.processors.cache.mvcc.msg.MvccRecoveryFinishedMessage;
+import
org.apache.ignite.internal.processors.cache.mvcc.msg.MvccSnapshotResponse;
+import
org.apache.ignite.internal.processors.cache.mvcc.msg.MvccTxSnapshotRequest;
+import
org.apache.ignite.internal.processors.cache.mvcc.msg.PartitionCountersNeighborcastRequest;
+import
org.apache.ignite.internal.processors.cache.mvcc.msg.PartitionCountersNeighborcastResponse;
+import org.apache.ignite.internal.processors.cache.query.GridCacheQueryRequest;
+import
org.apache.ignite.internal.processors.cache.query.GridCacheQueryResponse;
+import org.apache.ignite.internal.processors.cache.query.GridCacheSqlQuery;
+import
org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryBatchAck;
+import
org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryEntry;
+import org.apache.ignite.internal.processors.cache.transactions.IgniteTxEntry;
+import org.apache.ignite.internal.processors.cache.transactions.IgniteTxKey;
+import
org.apache.ignite.internal.processors.cache.transactions.TxEntryValueHolder;
+import org.apache.ignite.internal.processors.cache.transactions.TxLock;
+import org.apache.ignite.internal.processors.cache.transactions.TxLockList;
+import org.apache.ignite.internal.processors.cache.transactions.TxLocksRequest;
+import
org.apache.ignite.internal.processors.cache.transactions.TxLocksResponse;
+import
org.apache.ignite.internal.processors.cache.version.GridCacheRawVersionedEntry;
+import org.apache.ignite.internal.processors.cache.version.GridCacheVersion;
+import org.apache.ignite.internal.processors.cache.version.GridCacheVersionEx;
+import
org.apache.ignite.internal.processors.cluster.ClusterMetricsUpdateMessage;
+import
org.apache.ignite.internal.processors.continuous.ContinuousRoutineStartResultMessage;
+import org.apache.ignite.internal.processors.continuous.GridContinuousMessage;
+import org.apache.ignite.internal.processors.datastreamer.DataStreamerEntry;
+import org.apache.ignite.internal.processors.datastreamer.DataStreamerRequest;
+import org.apache.ignite.internal.processors.datastreamer.DataStreamerResponse;
+import
org.apache.ignite.internal.processors.marshaller.MissingMappingRequestMessage;
+import
org.apache.ignite.internal.processors.marshaller.MissingMappingResponseMessage;
+import
org.apache.ignite.internal.processors.query.h2.twostep.messages.GridQueryCancelRequest;
+import
org.apache.ignite.internal.processors.query.h2.twostep.messages.GridQueryFailResponse;
+import
org.apache.ignite.internal.processors.query.h2.twostep.messages.GridQueryNextPageRequest;
+import
org.apache.ignite.internal.processors.query.h2.twostep.messages.GridQueryNextPageResponse;
+import
org.apache.ignite.internal.processors.query.messages.GridQueryKillRequest;
+import
org.apache.ignite.internal.processors.query.messages.GridQueryKillResponse;
+import
org.apache.ignite.internal.processors.query.schema.message.SchemaOperationStatusMessage;
+import
org.apache.ignite.internal.processors.rest.handlers.task.GridTaskResultRequest;
+import
org.apache.ignite.internal.processors.rest.handlers.task.GridTaskResultResponse;
+import
org.apache.ignite.internal.processors.service.ServiceDeploymentProcessId;
+import
org.apache.ignite.internal.processors.service.ServiceSingleNodeDeploymentResult;
+import
org.apache.ignite.internal.processors.service.ServiceSingleNodeDeploymentResultBatch;
+import org.apache.ignite.internal.util.GridByteArrayList;
+import org.apache.ignite.internal.util.GridIntList;
+import org.apache.ignite.internal.util.GridLongList;
+import org.apache.ignite.internal.util.GridMessageCollection;
+import org.apache.ignite.internal.util.UUIDCollectionMessage;
+import org.apache.ignite.internal.util.distributed.SingleNodeMessage;
import org.apache.ignite.plugin.extensions.communication.IgniteMessageFactory;
import org.apache.ignite.plugin.extensions.communication.Message;
import org.apache.ignite.plugin.extensions.communication.MessageFactory;
import
org.apache.ignite.plugin.extensions.communication.MessageFactoryProvider;
+import org.apache.ignite.spi.collision.jobstealing.JobStealingRequest;
+import org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi;
+import
org.apache.ignite.spi.communication.tcp.internal.TcpInverseConnectionResponseMessage;
+import org.apache.ignite.spi.communication.tcp.messages.HandshakeMessage;
+import org.apache.ignite.spi.communication.tcp.messages.HandshakeMessage2;
+import org.apache.ignite.spi.communication.tcp.messages.HandshakeWaitMessage;
+import org.apache.ignite.spi.communication.tcp.messages.NodeIdMessage;
+import
org.apache.ignite.spi.communication.tcp.messages.RecoveryLastReceivedMessage;
import org.jetbrains.annotations.Nullable;
/**
@@ -127,6 +297,891 @@ public class IgniteMessageFactoryImpl implements
IgniteMessageFactory {
* @throws IgniteException If there are no any message factory for given
{@code directType}.
*/
@Override public @Nullable Message create(short directType) {
+ Message msg = null;
+
+ switch (directType) {
+ // -54 is reserved for SQL.
+ // -46 ... -51 - snapshot messages.
+ case -61:
+ msg = new IgniteDiagnosticMessage();
+
+ break;
+
+ case -53:
+ msg = new SchemaOperationStatusMessage();
+
+ break;
+
+ case -52:
+ msg = new GridIntList();
+
+ break;
+
+ case -51:
+ msg = new NearCacheUpdates();
+
+ break;
+
+ case -50:
+ msg = new GridNearAtomicCheckUpdateRequest();
+
+ break;
+
+ case -49:
+ msg = new UpdateErrors();
+
+ break;
+
+ case -48:
+ msg = new GridDhtAtomicNearResponse();
+
+ break;
+
+ case -45:
+ msg = new GridChangeGlobalStateMessageResponse();
+
+ break;
+
+ case -44:
+ msg = new HandshakeMessage2();
+
+ break;
+
+ case -43:
+ msg = new IgniteIoTestMessage();
+
+ break;
+
+ case -36:
+ msg = new GridDhtAtomicSingleUpdateRequest();
+
+ break;
+
+ case -27:
+ msg = new GridDhtTxOnePhaseCommitAckRequest();
+
+ break;
+
+ case -26:
+ msg = new TxLockList();
+
+ break;
+
+ case -25:
+ msg = new TxLock();
+
+ break;
+
+ case -24:
+ msg = new TxLocksRequest();
+
+ break;
+
+ case -23:
+ msg = new TxLocksResponse();
+
+ break;
+
+ case TcpCommunicationSpi.NODE_ID_MSG_TYPE:
+ msg = new NodeIdMessage();
+
+ break;
+
+ case TcpCommunicationSpi.RECOVERY_LAST_ID_MSG_TYPE:
+ msg = new RecoveryLastReceivedMessage();
+
+ break;
+
+ case TcpCommunicationSpi.HANDSHAKE_MSG_TYPE:
+ msg = new HandshakeMessage();
+
+ break;
+
+ case TcpCommunicationSpi.HANDSHAKE_WAIT_MSG_TYPE:
+ msg = new HandshakeWaitMessage();
+
+ break;
+
+ case 0:
+ msg = new GridJobCancelRequest();
+
+ break;
+
+ case 1:
+ msg = new GridJobExecuteRequest();
+
+ break;
+
+ case 2:
+ msg = new GridJobExecuteResponse();
+
+ break;
+
+ case 3:
+ msg = new GridJobSiblingsRequest();
+
+ break;
+
+ case 4:
+ msg = new GridJobSiblingsResponse();
+
+ break;
+
+ case 5:
+ msg = new GridTaskCancelRequest();
+
+ break;
+
+ case 6:
+ msg = new GridTaskSessionRequest();
+
+ break;
+
+ case 7:
+ msg = new GridCheckpointRequest();
+
+ break;
+
+ case 8:
+ msg = new GridIoMessage();
+
+ break;
+
+ case 9:
+ msg = new GridIoUserMessage();
+
+ break;
+
+ case 10:
+ msg = new GridDeploymentInfoBean();
+
+ break;
+
+ case 11:
+ msg = new GridDeploymentRequest();
+
+ break;
+
+ case 12:
+ msg = new GridDeploymentResponse();
+
+ break;
+
+ case 13:
+ msg = new GridEventStorageMessage();
+
+ break;
+
+ case 16:
+ msg = new GridCacheTxRecoveryRequest();
+
+ break;
+
+ case 17:
+ msg = new GridCacheTxRecoveryResponse();
+
+ break;
+
+ case 20:
+ msg = new GridCacheTtlUpdateRequest();
+
+ break;
+
+ case 21:
+ msg = new GridDistributedLockRequest();
+
+ break;
+
+ case 22:
+ msg = new GridDistributedLockResponse();
+
+ break;
+
+ case 23:
+ msg = new GridDistributedTxFinishRequest();
+
+ break;
+
+ case 24:
+ msg = new GridDistributedTxFinishResponse();
+
+ break;
+
+ case 25:
+ msg = new GridDistributedTxPrepareRequest();
+
+ break;
+
+ case 26:
+ msg = new GridDistributedTxPrepareResponse();
+
+ break;
+
+ case 27:
+ msg = new GridDistributedUnlockRequest();
+
+ break;
+
+ case 28:
+ msg = new GridDhtAffinityAssignmentRequest();
+
+ break;
+
+ case 29:
+ msg = new GridDhtAffinityAssignmentResponse();
+
+ break;
+
+ case 30:
+ msg = new GridDhtLockRequest();
+
+ break;
+
+ case 31:
+ msg = new GridDhtLockResponse();
+
+ break;
+
+ case 32:
+ msg = new GridDhtTxFinishRequest();
+
+ break;
+
+ case 33:
+ msg = new GridDhtTxFinishResponse();
+
+ break;
+
+ case 34:
+ msg = new GridDhtTxPrepareRequest();
+
+ break;
+
+ case 35:
+ msg = new GridDhtTxPrepareResponse();
+
+ break;
+
+ case 36:
+ msg = new GridDhtUnlockRequest();
+
+ break;
+
+ case 37:
+ msg = new GridDhtAtomicDeferredUpdateResponse();
+
+ break;
+
+ case 38:
+ msg = new GridDhtAtomicUpdateRequest();
+
+ break;
+
+ case 39:
+ msg = new GridDhtAtomicUpdateResponse();
+
+ break;
+
+ case 40:
+ msg = new GridNearAtomicFullUpdateRequest();
+
+ break;
+
+ case 41:
+ msg = new GridNearAtomicUpdateResponse();
+
+ break;
+
+ case 42:
+ msg = new GridDhtForceKeysRequest();
+
+ break;
+
+ case 43:
+ msg = new GridDhtForceKeysResponse();
+
+ break;
+
+ case 44:
+ msg = new GridDhtPartitionDemandLegacyMessage();
+
+ break;
+
+ case 45:
+ msg = new GridDhtPartitionDemandMessage();
+
+ break;
+
+ case 46:
+ msg = new GridDhtPartitionsFullMessage();
+
+ break;
+
+ case 47:
+ msg = new GridDhtPartitionsSingleMessage();
+
+ break;
+
+ case 48:
+ msg = new GridDhtPartitionsSingleRequest();
+
+ break;
+
+ case 49:
+ msg = new GridNearGetRequest();
+
+ break;
+
+ case 50:
+ msg = new GridNearGetResponse();
+
+ break;
+
+ case 51:
+ msg = new GridNearLockRequest();
+
+ break;
+
+ case 52:
+ msg = new GridNearLockResponse();
+
+ break;
+
+ case 53:
+ msg = new GridNearTxFinishRequest();
+
+ break;
+
+ case 54:
+ msg = new GridNearTxFinishResponse();
+
+ break;
+
+ case 55:
+ msg = new GridNearTxPrepareRequest();
+
+ break;
+
+ case 56:
+ msg = new GridNearTxPrepareResponse();
+
+ break;
+
+ case 57:
+ msg = new GridNearUnlockRequest();
+
+ break;
+
+ case 58:
+ msg = new GridCacheQueryRequest();
+
+ break;
+
+ case 59:
+ msg = new GridCacheQueryResponse();
+
+ break;
+
+ case 61:
+ msg = new GridContinuousMessage();
+
+ break;
+
+ case 62:
+ msg = new DataStreamerRequest();
+
+ break;
+
+ case 63:
+ msg = new DataStreamerResponse();
+
+ break;
+
+ case 76:
+ msg = new GridTaskResultRequest();
+
+ break;
+
+ case 77:
+ msg = new GridTaskResultResponse();
+
+ break;
+
+ case 78:
+ msg = new MissingMappingRequestMessage();
+
+ break;
+
+ case 79:
+ msg = new MissingMappingResponseMessage();
+
+ break;
+
+ case 80:
+ msg = new MetadataRequestMessage();
+
+ break;
+
+ case 81:
+ msg = new MetadataResponseMessage();
+
+ break;
+
+ case 82:
+ msg = new JobStealingRequest();
+
+ break;
+
+ case 84:
+ msg = new GridByteArrayList();
+
+ break;
+
+ case 85:
+ msg = new GridLongList();
+
+ break;
+
+ case 86:
+ msg = new GridCacheVersion();
+
+ break;
+
+ case 87:
+ msg = new GridDhtPartitionExchangeId();
+
+ break;
+
+ case 88:
+ msg = new GridCacheReturn();
+
+ break;
+
+ case 89:
+ msg = new CacheObjectImpl();
+
+ break;
+
+ case 90:
+ msg = new KeyCacheObjectImpl();
+
+ break;
+
+ case 91:
+ msg = new GridCacheEntryInfo();
+
+ break;
+
+ case 92:
+ msg = new CacheEntryInfoCollection();
+
+ break;
+
+ case 93:
+ msg = new CacheInvokeDirectResult();
+
+ break;
+
+ case 94:
+ msg = new IgniteTxKey();
+
+ break;
+
+ case 95:
+ msg = new DataStreamerEntry();
+
+ break;
+
+ case 96:
+ msg = new CacheContinuousQueryEntry();
+
+ break;
+
+ case 97:
+ msg = new CacheEvictionEntry();
+
+ break;
+
+ case 98:
+ msg = new CacheEntryPredicateContainsValue();
+
+ break;
+
+ case 99:
+ msg = new CacheEntrySerializablePredicate();
+
+ break;
+
+ case 100:
+ msg = new IgniteTxEntry();
+
+ break;
+
+ case 101:
+ msg = new TxEntryValueHolder();
+
+ break;
+
+ case 102:
+ msg = new CacheVersionedValue();
+
+ break;
+
+ case 103:
+ msg = new GridCacheRawVersionedEntry<>();
+
+ break;
+
+ case 104:
+ msg = new GridCacheVersionEx();
+
+ break;
+
+ case 105:
+ msg = new CacheObjectByteArrayImpl();
+
+ break;
+
+ case 106:
+ msg = new GridQueryCancelRequest();
+
+ break;
+
+ case 107:
+ msg = new GridQueryFailResponse();
+
+ break;
+
+ case 108:
+ msg = new GridQueryNextPageRequest();
+
+ break;
+
+ case 109:
+ msg = new GridQueryNextPageResponse();
+
+ break;
+
+ case 110:
+ // EMPTY type
+ // GridQueryRequest was removed
+ break;
+
+ case 111:
+ msg = new AffinityTopologyVersion();
+
+ break;
+
+ case 112:
+ msg = new GridCacheSqlQuery();
+
+ break;
+
+ case 113:
+ msg = new BinaryObjectImpl();
+
+ break;
+
+ case 114:
+ msg = new GridDhtPartitionSupplyMessage();
+
+ break;
+
+ case 115:
+ msg = new UUIDCollectionMessage();
+
+ break;
+
+ case 116:
+ msg = new GridNearSingleGetRequest();
+
+ break;
+
+ case 117:
+ msg = new GridNearSingleGetResponse();
+
+ break;
+
+ case 118:
+ msg = new CacheContinuousQueryBatchAck();
+
+ break;
+
+ case 119:
+ msg = new BinaryEnumObjectImpl();
+
+ break;
+
+ // [120..123] - DR
+ case 124:
+ msg = new GridMessageCollection<>();
+
+ break;
+
+ case 125:
+ msg = new GridNearAtomicSingleUpdateRequest();
+
+ break;
+
+ case 126:
+ msg = new GridNearAtomicSingleUpdateInvokeRequest();
+
+ break;
+
+ case 127:
+ msg = new GridNearAtomicSingleUpdateFilterRequest();
+
+ break;
+
+ case 128:
+ msg = new CacheGroupAffinityMessage();
+
+ break;
+
+ case 129:
+ msg = new WalStateAckMessage();
+
+ break;
+
+ case 130:
+ msg = new UserManagementOperationFinishedMessage();
+
+ break;
+
+ case 131:
+ msg = new UserAuthenticateRequestMessage();
+
+ break;
+
+ case 132:
+ msg = new UserAuthenticateResponseMessage();
+
+ break;
+
+ case 133:
+ msg = new ClusterMetricsUpdateMessage();
+
+ break;
+
+ case 134:
+ msg = new ContinuousRoutineStartResultMessage();
+
+ break;
+
+ case 135:
+ msg = new LatchAckMessage();
+
+ break;
+
+ case 136:
+ msg = new MvccTxSnapshotRequest();
+
+ break;
+
+ case 137:
+ msg = new MvccAckRequestTx();
+
+ break;
+
+ case 138:
+ msg = new MvccFutureResponse();
+
+ break;
+
+ case 139:
+ msg = new MvccQuerySnapshotRequest();
+
+ break;
+
+ case 140:
+ msg = new MvccAckRequestQueryCntr();
+
+ break;
+
+ case 141:
+ msg = new MvccSnapshotResponse();
+
+ break;
+
+ case 143:
+ msg = new GridCacheMvccEntryInfo();
+
+ break;
+
+ case 144:
+ msg = new GridDhtTxQueryEnlistResponse();
+
+ break;
+
+ case 145:
+ msg = new MvccAckRequestQueryId();
+
+ break;
+
+ case 146:
+ msg = new MvccAckRequestTxAndQueryCntr();
+
+ break;
+
+ case 147:
+ msg = new MvccAckRequestTxAndQueryId();
+
+ break;
+
+ case 148:
+ msg = new MvccVersionImpl();
+
+ break;
+
+ case 149:
+ msg = new MvccActiveQueriesMessage();
+
+ break;
+
+ case 150:
+ msg = new MvccSnapshotWithoutTxs();
+
+ break;
+
+ case 151:
+ msg = new GridNearTxQueryEnlistRequest();
+
+ break;
+
+ case 152:
+ msg = new GridNearTxQueryEnlistResponse();
+
+ break;
+
+ case 153:
+ msg = new GridNearTxQueryResultsEnlistRequest();
+
+ break;
+
+ case 154:
+ msg = new GridNearTxQueryResultsEnlistResponse();
+
+ break;
+
+ case 155:
+ msg = new GridDhtTxQueryEnlistRequest();
+
+ break;
+
+ case 156:
+ msg = new GridDhtTxQueryFirstEnlistRequest();
+
+ break;
+
+ case 157:
+ msg = new PartitionUpdateCountersMessage();
+
+ break;
+
+ case 158:
+ msg = new GridDhtPartitionSupplyMessageV2();
+
+ break;
+
+ case 159:
+ msg = new GridNearTxEnlistRequest();
+
+ break;
+
+ case 160:
+ msg = new GridNearTxEnlistResponse();
+
+ break;
+
+ case 161:
+ msg = new GridInvokeValue();
+
+ break;
+
+ case 162:
+ msg = new GenerateEncryptionKeyRequest();
+
+ break;
+
+ case 163:
+ msg = new GenerateEncryptionKeyResponse();
+
+ break;
+
+ case 164:
+ msg = new MvccRecoveryFinishedMessage();
+
+ break;
+
+ case 165:
+ msg = new PartitionCountersNeighborcastRequest();
+
+ break;
+
+ case 166:
+ msg = new PartitionCountersNeighborcastResponse();
+
+ break;
+
+ case 167:
+ msg = new ServiceDeploymentProcessId();
+
+ break;
+
+ case 168:
+ msg = new ServiceSingleNodeDeploymentResultBatch();
+
+ break;
+
+ case 169:
+ msg = new ServiceSingleNodeDeploymentResult();
+
+ break;
+
+ case 170:
+ msg = new DeadlockProbe();
+
+ break;
+
+ case 171:
+ msg = new ProbedTx();
+
+ break;
+
+ case GridQueryKillRequest.TYPE_CODE:
+ msg = new GridQueryKillRequest();
+
+ break;
+
+ case GridQueryKillResponse.TYPE_CODE:
+ msg = new GridQueryKillResponse();
+
+ break;
+
+ case GridIoSecurityAwareMessage.TYPE_CODE:
+ msg = new GridIoSecurityAwareMessage();
+
+ break;
+
+ case SessionChannelMessage.TYPE_CODE:
+ msg = new SessionChannelMessage();
+
+ break;
+
+ case SingleNodeMessage.TYPE_CODE:
+ msg = new SingleNodeMessage<>();
+
+ break;
+
+ case 177:
+ msg = new TcpInverseConnectionResponseMessage();
+
+ break;
+ }
+
+ if (msg != null)
+ return msg;
+
Supplier<Message> supplier =
msgSuppliers[directTypeToIndex(directType)];
if (supplier == null)
