This is an automated email from the ASF dual-hosted git repository.
namelchev pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 049a977ce04 IGNITE-28082 Refactor DiscoveryCustomMessage default
methods usages (#12865)
049a977ce04 is described below
commit 049a977ce048d2c369bf1dd49bb2c9851fdb6538
Author: Nikita Amelchev <[email protected]>
AuthorDate: Fri Mar 6 14:12:55 2026 +0300
IGNITE-28082 Refactor DiscoveryCustomMessage default methods usages (#12865)
---
.../managers/discovery/DiscoveryCustomMessage.java | 12 ++++++++++--
.../processors/authentication/UserAcceptedMessage.java | 14 --------------
.../processors/authentication/UserProposedMessage.java | 14 --------------
.../processors/cache/CacheStatisticsClearMessage.java | 14 --------------
.../cache/CacheStatisticsModeChangeMessage.java | 14 --------------
.../cache/ClientCacheChangeDiscoveryMessage.java | 14 --------------
.../cache/ClientCacheChangeDummyDiscoveryMessage.java | 14 --------------
.../processors/cache/DynamicCacheChangeBatch.java | 5 -----
.../processors/cache/ExchangeFailureMessage.java | 5 -----
.../TxTimeoutOnPartitionMapExchangeChangeMessage.java | 14 --------------
.../processors/cache/WalStateAbstractMessage.java | 5 -----
.../cache/binary/MetadataRemoveAcceptedMessage.java | 9 ---------
.../cache/binary/MetadataRemoveProposedMessage.java | 10 ----------
.../cache/binary/MetadataUpdateAcceptedMessage.java | 9 ---------
.../cache/binary/MetadataUpdateProposedMessage.java | 9 ---------
.../cluster/ChangeGlobalStateFinishMessage.java | 14 --------------
.../processors/cluster/ChangeGlobalStateMessage.java | 5 -----
.../continuous/AbstractContinuousMessage.java | 15 ---------------
.../processors/marshaller/MappingAcceptedMessage.java | 14 --------------
.../processors/marshaller/MappingProposedMessage.java | 9 ---------
.../DistributedMetaStorageUpdateAckMessage.java | 17 -----------------
.../DistributedMetaStorageUpdateMessage.java | 12 ------------
.../schema/message/SchemaAbstractDiscoveryMessage.java | 9 ---------
.../schema/message/SchemaFinishDiscoveryMessage.java | 5 -----
.../processors/service/ServiceChangeBatchRequest.java | 15 ---------------
.../service/ServiceClusterDeploymentResultBatch.java | 15 ---------------
.../ignite/internal/util/distributed/FullMessage.java | 14 --------------
.../ignite/internal/util/distributed/InitMessage.java | 5 -----
.../internal/TcpConnectionRequestDiscoveryMessage.java | 17 -----------------
.../ignite/failure/FailureHandlerTriggeredTest.java | 4 ----
.../IncompleteDeserializationExceptionTest.java | 12 ------------
.../internal/metric/OutboundIoMessageQueueSizeTest.java | 14 --------------
.../security/NodeSecurityContextPropagationTest.java | 17 -----------------
.../discovery/FilterDataForClientNodeDiscoveryTest.java | 13 -------------
.../tcp/TcpDiscoveryPendingMessageDeliveryTest.java | 15 ---------------
.../ZkCommunicationErrorResolveFinishMessage.java | 5 -----
.../ZkCommunicationErrorResolveStartMessage.java | 5 -----
.../discovery/zk/internal/ZkForceNodeFailMessage.java | 5 -----
.../spi/discovery/zk/internal/ZkNoServersMessage.java | 5 -----
39 files changed, 10 insertions(+), 413 deletions(-)
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/DiscoveryCustomMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/DiscoveryCustomMessage.java
index 3df16a103b7..b82a317515e 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/DiscoveryCustomMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/DiscoveryCustomMessage.java
@@ -19,7 +19,9 @@ package org.apache.ignite.internal.managers.discovery;
import java.io.Serializable;
import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
+import org.apache.ignite.internal.processors.cache.GridCacheProcessor;
import org.apache.ignite.lang.IgniteUuid;
+import org.apache.ignite.spi.discovery.DiscoverySpiMutableCustomMessageSupport;
import
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryNodeAddFinishedMessage;
import
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryNodeAddedMessage;
import org.jetbrains.annotations.Nullable;
@@ -88,8 +90,11 @@ public interface DiscoveryCustomMessage extends Serializable
{
/**
* @return {@code True} if message can be modified during listener
notification. Changes will be sent to next nodes.
+ * @see DiscoverySpiMutableCustomMessageSupport
*/
- public boolean isMutable();
+ default boolean isMutable() {
+ return false;
+ }
/**
* @return {@code True} if message should not be sent to others nodes
after it was processed on coordinator.
@@ -105,6 +110,9 @@ public interface DiscoveryCustomMessage extends
Serializable {
* @param topVer New topology version.
* @param discoCache Current discovery cache.
* @return Reused discovery cache.
+ * @see GridCacheProcessor#onCustomEvent
*/
- public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer, DiscoCache discoCache);
+ default DiscoCache createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer, DiscoCache discoCache) {
+ throw new UnsupportedOperationException();
+ }
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/authentication/UserAcceptedMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/authentication/UserAcceptedMessage.java
index c0b49fefb2f..bda470bb5fa 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/authentication/UserAcceptedMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/authentication/UserAcceptedMessage.java
@@ -19,10 +19,7 @@ package org.apache.ignite.internal.processors.authentication;
import org.apache.ignite.internal.Order;
import org.apache.ignite.internal.managers.communication.ErrorMessage;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.tostring.GridToStringInclude;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
@@ -80,17 +77,6 @@ public class UserAcceptedMessage implements
DiscoveryCustomMessage, Message {
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Nullable @Override public DiscoCache
createDiscoCache(GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer, DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
-
/**
* @return User operation ID.
*/
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/authentication/UserProposedMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/authentication/UserProposedMessage.java
index 1c8e44299e8..9478f7130e4 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/authentication/UserProposedMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/authentication/UserProposedMessage.java
@@ -18,11 +18,8 @@
package org.apache.ignite.internal.processors.authentication;
import org.apache.ignite.internal.Order;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
import
org.apache.ignite.internal.managers.discovery.DiscoveryServerOnlyCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.tostring.GridToStringInclude;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
@@ -76,17 +73,6 @@ public class UserProposedMessage implements
DiscoveryServerOnlyCustomMessage, Me
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Nullable @Override public DiscoCache
createDiscoCache(GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer, DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
-
/**
* @return User operation.
*/
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheStatisticsClearMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheStatisticsClearMessage.java
index 228bb1f171b..f360a6acc70 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheStatisticsClearMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheStatisticsClearMessage.java
@@ -19,10 +19,7 @@ package org.apache.ignite.internal.processors.cache;
import java.util.Collection;
import java.util.UUID;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
import org.jetbrains.annotations.Nullable;
@@ -76,17 +73,6 @@ public class CacheStatisticsClearMessage implements
DiscoveryCustomMessage {
return this.id;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Override public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
- DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
-
/** {@inheritDoc} */
@Nullable @Override public DiscoveryCustomMessage ackMessage() {
return initial() ? new CacheStatisticsClearMessage(this) : null;
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheStatisticsModeChangeMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheStatisticsModeChangeMessage.java
index 308af19b0e9..7864f566c4c 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheStatisticsModeChangeMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheStatisticsModeChangeMessage.java
@@ -21,11 +21,8 @@ import java.util.Collection;
import java.util.Collections;
import java.util.UUID;
import org.apache.ignite.internal.Order;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
import org.apache.ignite.internal.managers.discovery.DiscoveryMessageFactory;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
import org.apache.ignite.plugin.extensions.communication.Message;
@@ -111,17 +108,6 @@ public class CacheStatisticsModeChangeMessage implements
DiscoveryCustomMessage,
return initial() ? new CacheStatisticsModeChangeMessage(this) : null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Override public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
- DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
-
/**
* @return Cache names.
*/
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ClientCacheChangeDiscoveryMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ClientCacheChangeDiscoveryMessage.java
index 60f1cce3a11..6f5640a23f6 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ClientCacheChangeDiscoveryMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ClientCacheChangeDiscoveryMessage.java
@@ -22,10 +22,7 @@ import java.util.HashSet;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.tostring.GridToStringInclude;
import org.apache.ignite.internal.util.typedef.F;
import org.apache.ignite.internal.util.typedef.internal.S;
@@ -167,17 +164,6 @@ public class ClientCacheChangeDiscoveryMessage implements
DiscoveryCustomMessage
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Nullable @Override public DiscoCache
createDiscoCache(GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer, DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
-
/** {@inheritDoc} */
@Override public String toString() {
return S.toString(ClientCacheChangeDiscoveryMessage.class, this);
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ClientCacheChangeDummyDiscoveryMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ClientCacheChangeDummyDiscoveryMessage.java
index 918995b0967..5a31a26a8ba 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ClientCacheChangeDummyDiscoveryMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ClientCacheChangeDummyDiscoveryMessage.java
@@ -20,10 +20,7 @@ package org.apache.ignite.internal.processors.cache;
import java.util.Map;
import java.util.Set;
import java.util.UUID;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.processors.security.SecurityContext;
import org.apache.ignite.internal.util.tostring.GridToStringInclude;
import org.apache.ignite.internal.util.typedef.internal.S;
@@ -106,17 +103,6 @@ public class ClientCacheChangeDummyDiscoveryMessage
extends AbstractCachePartiti
throw new UnsupportedOperationException();
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- throw new UnsupportedOperationException();
- }
-
- /** {@inheritDoc} */
- @Nullable @Override public DiscoCache
createDiscoCache(GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer, DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
-
/** {@inheritDoc} */
@Override public String toString() {
return S.toString(ClientCacheChangeDummyDiscoveryMessage.class, this,
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheChangeBatch.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheChangeBatch.java
index 6b89424462b..2e70e956f07 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheChangeBatch.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheChangeBatch.java
@@ -77,11 +77,6 @@ public class DynamicCacheChangeBatch implements
DiscoveryCustomMessage {
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
/** {@inheritDoc} */
@Override public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache) {
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ExchangeFailureMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ExchangeFailureMessage.java
index 764bd717d1c..8d6c3d3310f 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ExchangeFailureMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ExchangeFailureMessage.java
@@ -141,11 +141,6 @@ public class ExchangeFailureMessage implements
DiscoveryCustomMessage {
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
/** {@inheritDoc} */
@Override public DiscoCache createDiscoCache(
GridDiscoveryManager mgr,
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/TxTimeoutOnPartitionMapExchangeChangeMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/TxTimeoutOnPartitionMapExchangeChangeMessage.java
index a36c5f30f1c..6b1016ab1ef 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/TxTimeoutOnPartitionMapExchangeChangeMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/TxTimeoutOnPartitionMapExchangeChangeMessage.java
@@ -19,10 +19,7 @@ package org.apache.ignite.internal.processors.cache;
import java.util.UUID;
import org.apache.ignite.internal.Order;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
import org.apache.ignite.plugin.extensions.communication.Message;
@@ -91,17 +88,6 @@ public class TxTimeoutOnPartitionMapExchangeChangeMessage
implements DiscoveryCu
return isInit() ? new
TxTimeoutOnPartitionMapExchangeChangeMessage(this) : null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Override public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
- DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
-
/**
* Gets request ID.
*
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateAbstractMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateAbstractMessage.java
index d079905ae7b..d6451a2b349 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateAbstractMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateAbstractMessage.java
@@ -128,11 +128,6 @@ public abstract class WalStateAbstractMessage implements
DiscoveryCustomMessage,
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
/** {@inheritDoc} */
@Override public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache) {
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveAcceptedMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveAcceptedMessage.java
index 52392fdfd7e..7b26654040d 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveAcceptedMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveAcceptedMessage.java
@@ -18,10 +18,7 @@
package org.apache.ignite.internal.processors.cache.binary;
import org.apache.ignite.internal.Order;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
import org.apache.ignite.plugin.extensions.communication.Message;
@@ -77,12 +74,6 @@ public class MetadataRemoveAcceptedMessage implements
DiscoveryCustomMessage, Me
return true;
}
- /** {@inheritDoc} */
- @Nullable @Override public DiscoCache
createDiscoCache(GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer, DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
-
/** */
public int typeId() {
return typeId;
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveProposedMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveProposedMessage.java
index 57aacddd75f..580333bcb52 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveProposedMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveProposedMessage.java
@@ -20,10 +20,7 @@ package org.apache.ignite.internal.processors.cache.binary;
import java.util.UUID;
import org.apache.ignite.internal.Order;
import org.apache.ignite.internal.binary.BinaryMetadata;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
import org.apache.ignite.plugin.extensions.communication.Message;
@@ -94,13 +91,6 @@ public final class MetadataRemoveProposedMessage implements
DiscoveryCustomMessa
return true;
}
-
- /** {@inheritDoc} */
- @Nullable @Override public DiscoCache
createDiscoCache(GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer, DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
-
/**
* @param errMsg Error message caused this update to be rejected.
*/
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateAcceptedMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateAcceptedMessage.java
index 0edbc2e67ae..fc9e1e5380b 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateAcceptedMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateAcceptedMessage.java
@@ -17,10 +17,7 @@
package org.apache.ignite.internal.processors.cache.binary;
import org.apache.ignite.internal.Order;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
import org.apache.ignite.plugin.extensions.communication.Message;
@@ -80,12 +77,6 @@ public class MetadataUpdateAcceptedMessage implements
DiscoveryCustomMessage, Me
return true;
}
- /** {@inheritDoc} */
- @Nullable @Override public DiscoCache
createDiscoCache(GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer, DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
-
/** */
int acceptedVersion() {
return acceptedVer;
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateProposedMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateProposedMessage.java
index 4da098ab101..b73be5f2c13 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateProposedMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateProposedMessage.java
@@ -20,10 +20,7 @@ import java.util.UUID;
import org.apache.ignite.binary.BinaryObjectException;
import org.apache.ignite.internal.binary.BinaryMetadata;
import org.apache.ignite.internal.binary.BinaryMetadataHandler;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
import org.jetbrains.annotations.Nullable;
@@ -133,12 +130,6 @@ public final class MetadataUpdateProposedMessage
implements DiscoveryCustomMessa
return true;
}
- /** {@inheritDoc} */
- @Nullable @Override public DiscoCache
createDiscoCache(GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer, DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
-
/**
* @param err Error caused this update to be rejected.
*/
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ChangeGlobalStateFinishMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ChangeGlobalStateFinishMessage.java
index c4cb43c9b1a..c23ca0f9c7f 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ChangeGlobalStateFinishMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ChangeGlobalStateFinishMessage.java
@@ -20,10 +20,7 @@ package org.apache.ignite.internal.processors.cluster;
import java.util.UUID;
import org.apache.ignite.cluster.ClusterState;
import org.apache.ignite.internal.Order;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
import org.apache.ignite.plugin.extensions.communication.Message;
@@ -116,17 +113,6 @@ public class ChangeGlobalStateFinishMessage implements
DiscoveryCustomMessage, M
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Nullable @Override public DiscoCache
createDiscoCache(GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer, DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
-
/** {@inheritDoc} */
@Override public String toString() {
return S.toString(ChangeGlobalStateFinishMessage.class, this);
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ChangeGlobalStateMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ChangeGlobalStateMessage.java
index 31a51c09dea..be4e628b18c 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ChangeGlobalStateMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ChangeGlobalStateMessage.java
@@ -150,11 +150,6 @@ public class ChangeGlobalStateMessage implements
DiscoveryCustomMessage {
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
/** {@inheritDoc} */
@Override public DiscoCache createDiscoCache(
GridDiscoveryManager mgr,
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/AbstractContinuousMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/AbstractContinuousMessage.java
index e9754d12cd9..eab346afd7b 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/AbstractContinuousMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/AbstractContinuousMessage.java
@@ -18,12 +18,8 @@
package org.apache.ignite.internal.processors.continuous;
import java.util.UUID;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.lang.IgniteUuid;
-import org.jetbrains.annotations.Nullable;
/**
*
@@ -56,15 +52,4 @@ public abstract class AbstractContinuousMessage implements
DiscoveryCustomMessag
public UUID routineId() {
return routineId;
}
-
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Nullable @Override public DiscoCache
createDiscoCache(GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer, DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/marshaller/MappingAcceptedMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/marshaller/MappingAcceptedMessage.java
index 7af0559752b..e40815f31f4 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/marshaller/MappingAcceptedMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/marshaller/MappingAcceptedMessage.java
@@ -17,10 +17,7 @@
package org.apache.ignite.internal.processors.marshaller;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
import org.jetbrains.annotations.Nullable;
@@ -57,17 +54,6 @@ public class MappingAcceptedMessage implements
DiscoveryCustomMessage {
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Nullable @Override public DiscoCache
createDiscoCache(GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer, DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
-
/** */
MarshallerMappingItem getMappingItem() {
return item;
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/marshaller/MappingProposedMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/marshaller/MappingProposedMessage.java
index b4e13fba14b..33a2168c226 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/marshaller/MappingProposedMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/marshaller/MappingProposedMessage.java
@@ -18,10 +18,7 @@
package org.apache.ignite.internal.processors.marshaller;
import java.util.UUID;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.tostring.GridToStringInclude;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
@@ -97,12 +94,6 @@ public class MappingProposedMessage implements
DiscoveryCustomMessage {
return true;
}
- /** {@inheritDoc} */
- @Nullable @Override public DiscoCache
createDiscoCache(GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer, DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
-
/** */
MarshallerMappingItem mappingItem() {
return mappingItem;
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/metastorage/persistence/DistributedMetaStorageUpdateAckMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/metastorage/persistence/DistributedMetaStorageUpdateAckMessage.java
index 9008f8b7257..e0fda7bb4bc 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/metastorage/persistence/DistributedMetaStorageUpdateAckMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/metastorage/persistence/DistributedMetaStorageUpdateAckMessage.java
@@ -18,10 +18,7 @@
package org.apache.ignite.internal.processors.metastorage.persistence;
import java.util.UUID;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
import org.jetbrains.annotations.Nullable;
@@ -66,20 +63,6 @@ class DistributedMetaStorageUpdateAckMessage implements
DiscoveryCustomMessage {
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Override public DiscoCache createDiscoCache(
- GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer,
- DiscoCache discoCache
- ) {
- throw new UnsupportedOperationException();
- }
-
/** {@inheritDoc} */
@Override public String toString() {
return S.toString(DistributedMetaStorageUpdateAckMessage.class, this);
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/metastorage/persistence/DistributedMetaStorageUpdateMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/metastorage/persistence/DistributedMetaStorageUpdateMessage.java
index 3b9e4622001..1d2cc6bc7bd 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/metastorage/persistence/DistributedMetaStorageUpdateMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/metastorage/persistence/DistributedMetaStorageUpdateMessage.java
@@ -18,10 +18,7 @@
package org.apache.ignite.internal.processors.metastorage.persistence;
import java.util.UUID;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.tostring.GridToStringInclude;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
@@ -91,15 +88,6 @@ class DistributedMetaStorageUpdateMessage implements
DiscoveryCustomMessage {
return true;
}
- /** {@inheritDoc} */
- @Override public DiscoCache createDiscoCache(
- GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer,
- DiscoCache discoCache
- ) {
- throw new UnsupportedOperationException("createDiscoCache");
- }
-
/** {@inheritDoc} */
@Override public String toString() {
return S.toString(DistributedMetaStorageUpdateMessage.class, this);
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/message/SchemaAbstractDiscoveryMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/message/SchemaAbstractDiscoveryMessage.java
index fc4642aa514..d4b7ef01a44 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/message/SchemaAbstractDiscoveryMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/message/SchemaAbstractDiscoveryMessage.java
@@ -20,10 +20,7 @@ package
org.apache.ignite.internal.processors.query.schema.message;
import org.apache.ignite.IgniteCheckedException;
import org.apache.ignite.IgniteException;
import org.apache.ignite.internal.Order;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import
org.apache.ignite.internal.processors.query.schema.SchemaOperationException;
import
org.apache.ignite.internal.processors.query.schema.operation.SchemaAbstractOperation;
import org.apache.ignite.internal.util.tostring.GridToStringInclude;
@@ -91,12 +88,6 @@ public abstract class SchemaAbstractDiscoveryMessage
implements DiscoveryCustomM
return id;
}
- /** {@inheritDoc} */
- @Nullable @Override public DiscoCache
createDiscoCache(GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer, DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
-
/**
* @return Operation.
*/
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/message/SchemaFinishDiscoveryMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/message/SchemaFinishDiscoveryMessage.java
index a0204816560..38a12f2dc58 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/message/SchemaFinishDiscoveryMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/message/SchemaFinishDiscoveryMessage.java
@@ -58,11 +58,6 @@ public class SchemaFinishDiscoveryMessage extends
SchemaAbstractDiscoveryMessage
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
/** {@inheritDoc} */
@Override public boolean exchange() {
return false;
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceChangeBatchRequest.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceChangeBatchRequest.java
index f474aa86b9a..854bf368226 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceChangeBatchRequest.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceChangeBatchRequest.java
@@ -19,10 +19,7 @@ package org.apache.ignite.internal.processors.service;
import java.util.Collection;
import java.util.Collections;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.tostring.GridToStringExclude;
import org.apache.ignite.internal.util.tostring.GridToStringInclude;
import org.apache.ignite.internal.util.typedef.F;
@@ -89,18 +86,6 @@ public class ServiceChangeBatchRequest implements
DiscoveryCustomMessage {
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Override public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
- DiscoCache discoCache) {
- // No-op.
- return null;
- }
-
/** {@inheritDoc} */
@Override public String toString() {
return S.toString(ServiceChangeBatchRequest.class, this);
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceClusterDeploymentResultBatch.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceClusterDeploymentResultBatch.java
index 9225ea93676..3c4f1cc785d 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceClusterDeploymentResultBatch.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceClusterDeploymentResultBatch.java
@@ -18,10 +18,7 @@
package org.apache.ignite.internal.processors.service;
import java.util.Collection;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.tostring.GridToStringExclude;
import org.apache.ignite.internal.util.tostring.GridToStringInclude;
import org.apache.ignite.internal.util.typedef.internal.S;
@@ -101,18 +98,6 @@ public class ServiceClusterDeploymentResultBatch implements
DiscoveryCustomMessa
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Override public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
- DiscoCache discoCache) {
- // No-op.
- return null;
- }
-
/** {@inheritDoc} */
@Override public String toString() {
return S.toString(ServiceClusterDeploymentResultBatch.class, this);
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/distributed/FullMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/distributed/FullMessage.java
index 3522c463def..eaca62e3594 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/distributed/FullMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/distributed/FullMessage.java
@@ -20,10 +20,7 @@ package org.apache.ignite.internal.util.distributed;
import java.io.Serializable;
import java.util.Map;
import java.util.UUID;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import
org.apache.ignite.internal.util.distributed.DistributedProcess.DistributedProcessType;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
@@ -79,17 +76,6 @@ public class FullMessage<R extends Serializable> implements
DiscoveryCustomMessa
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Override public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
- DiscoCache discoCache) {
- return null;
- }
-
/** @return Process id. */
public UUID processId() {
return processId;
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/distributed/InitMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/distributed/InitMessage.java
index 3106b25acce..f98e2715aae 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/distributed/InitMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/distributed/InitMessage.java
@@ -77,11 +77,6 @@ public class InitMessage<I extends Serializable> implements
DiscoveryCustomMessa
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
/** {@inheritDoc} */
@Override public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
DiscoCache discoCache) {
diff --git
a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpConnectionRequestDiscoveryMessage.java
b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpConnectionRequestDiscoveryMessage.java
index 9a4e10c68bf..187f867618e 100644
---
a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpConnectionRequestDiscoveryMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpConnectionRequestDiscoveryMessage.java
@@ -19,11 +19,8 @@ package org.apache.ignite.spi.communication.tcp.internal;
import java.util.UUID;
import org.apache.ignite.internal.Order;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
import org.apache.ignite.internal.managers.discovery.DiscoveryMessageFactory;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.tostring.GridToStringInclude;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
@@ -91,20 +88,6 @@ public class TcpConnectionRequestDiscoveryMessage implements
DiscoveryCustomMess
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Override public DiscoCache createDiscoCache(
- GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer,
- DiscoCache discoCache
- ) {
- throw new UnsupportedOperationException("createDiscoCache");
- }
-
/** {@inheritDoc} */
@Override public short directType() {
return 23;
diff --git
a/modules/core/src/test/java/org/apache/ignite/failure/FailureHandlerTriggeredTest.java
b/modules/core/src/test/java/org/apache/ignite/failure/FailureHandlerTriggeredTest.java
index f19b39ea6bc..a71ab3010b4 100644
---
a/modules/core/src/test/java/org/apache/ignite/failure/FailureHandlerTriggeredTest.java
+++
b/modules/core/src/test/java/org/apache/ignite/failure/FailureHandlerTriggeredTest.java
@@ -125,10 +125,6 @@ public class FailureHandlerTriggeredTest extends
GridCommonAbstractTest {
return null;
}
- @Override public boolean isMutable() {
- return false;
- }
-
@Override public short directType() {
return 0;
}
diff --git
a/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/IncompleteDeserializationExceptionTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/IncompleteDeserializationExceptionTest.java
index c90e8b39d4a..e79af4f287a 100644
---
a/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/IncompleteDeserializationExceptionTest.java
+++
b/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/IncompleteDeserializationExceptionTest.java
@@ -22,7 +22,6 @@ import java.io.ObjectInputStream;
import java.nio.file.Files;
import java.nio.file.Path;
import java.util.UUID;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.lang.IgniteUuid;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
import org.jetbrains.annotations.Nullable;
@@ -102,17 +101,6 @@ public class IncompleteDeserializationExceptionTest
extends GridCommonAbstractTe
@Override public @Nullable DiscoveryCustomMessage ackMessage() {
return null;
}
-
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Override public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
- DiscoCache discoCache) {
- return null;
- }
}
// Commented lines were used to prepare serialized object
diff --git
a/modules/core/src/test/java/org/apache/ignite/internal/metric/OutboundIoMessageQueueSizeTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/metric/OutboundIoMessageQueueSizeTest.java
index 92cc272d2cc..c7d11d53ae7 100644
---
a/modules/core/src/test/java/org/apache/ignite/internal/metric/OutboundIoMessageQueueSizeTest.java
+++
b/modules/core/src/test/java/org/apache/ignite/internal/metric/OutboundIoMessageQueueSizeTest.java
@@ -23,10 +23,7 @@ import org.apache.ignite.IgniteSystemProperties;
import org.apache.ignite.cache.query.ContinuousQuery;
import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.internal.IgniteEx;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.processors.metric.impl.MaxValueMetric;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.lang.IgniteUuid;
@@ -175,16 +172,5 @@ public class OutboundIoMessageQueueSizeTest extends
GridCommonAbstractTest {
@Nullable @Override public DiscoveryCustomMessage ackMessage() {
return null;
}
-
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Override public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
- DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
}
}
diff --git
a/modules/core/src/test/java/org/apache/ignite/internal/processors/security/NodeSecurityContextPropagationTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/security/NodeSecurityContextPropagationTest.java
index c2d9d2dc5fc..ff19efb9c5f 100644
---
a/modules/core/src/test/java/org/apache/ignite/internal/processors/security/NodeSecurityContextPropagationTest.java
+++
b/modules/core/src/test/java/org/apache/ignite/internal/processors/security/NodeSecurityContextPropagationTest.java
@@ -34,11 +34,8 @@ import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.failure.StopNodeOrHaltFailureHandler;
import org.apache.ignite.internal.IgniteEx;
import org.apache.ignite.internal.events.DiscoveryCustomEvent;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
import
org.apache.ignite.internal.managers.discovery.SecurityAwareCustomMessageWrapper;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.lang.IgniteUuid;
import org.apache.ignite.spi.discovery.DiscoverySpi;
@@ -242,20 +239,6 @@ public class NodeSecurityContextPropagationTest extends
GridCommonAbstractTest {
@Override public @Nullable DiscoveryCustomMessage ackMessage() {
return null;
}
-
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Override public DiscoCache createDiscoCache(
- GridDiscoveryManager mgr,
- AffinityTopologyVersion topVer,
- DiscoCache discoCache
- ) {
- throw new UnsupportedOperationException();
- }
}
/** */
diff --git
a/modules/core/src/test/java/org/apache/ignite/spi/discovery/FilterDataForClientNodeDiscoveryTest.java
b/modules/core/src/test/java/org/apache/ignite/spi/discovery/FilterDataForClientNodeDiscoveryTest.java
index ef32bdd7318..a4025d614a1 100644
---
a/modules/core/src/test/java/org/apache/ignite/spi/discovery/FilterDataForClientNodeDiscoveryTest.java
+++
b/modules/core/src/test/java/org/apache/ignite/spi/discovery/FilterDataForClientNodeDiscoveryTest.java
@@ -21,10 +21,8 @@ import java.util.Arrays;
import org.apache.ignite.cluster.ClusterNode;
import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.internal.managers.discovery.CustomEventListener;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
import
org.apache.ignite.internal.managers.discovery.DiscoveryServerOnlyCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.lang.IgniteUuid;
import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
@@ -193,16 +191,5 @@ public class FilterDataForClientNodeDiscoveryTest extends
GridCommonAbstractTest
@Nullable @Override public DiscoveryCustomMessage ackMessage() {
return null;
}
-
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Override public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
- DiscoCache discoCache) {
- return null;
- }
}
}
diff --git
a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryPendingMessageDeliveryTest.java
b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryPendingMessageDeliveryTest.java
index 0d156464075..e388778cf1b 100644
---
a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryPendingMessageDeliveryTest.java
+++
b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryPendingMessageDeliveryTest.java
@@ -24,10 +24,7 @@ import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCheckedException;
import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.internal.IgniteEx;
-import org.apache.ignite.internal.managers.discovery.DiscoCache;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
-import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.GridConcurrentHashSet;
import org.apache.ignite.lang.IgniteUuid;
import
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage;
@@ -311,17 +308,5 @@ public class TcpDiscoveryPendingMessageDeliveryTest
extends GridCommonAbstractTe
@Nullable @Override public DiscoveryCustomMessage ackMessage() {
return null;
}
-
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Override public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
AffinityTopologyVersion topVer,
- DiscoCache discoCache) {
- throw new UnsupportedOperationException();
- }
}
}
-
diff --git
a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkCommunicationErrorResolveFinishMessage.java
b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkCommunicationErrorResolveFinishMessage.java
index 29459ff7591..471d7939220 100644
---
a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkCommunicationErrorResolveFinishMessage.java
+++
b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkCommunicationErrorResolveFinishMessage.java
@@ -53,11 +53,6 @@ class ZkCommunicationErrorResolveFinishMessage extends
DiscoverySpiCustomMessage
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
/** {@inheritDoc} */
@Override public boolean stopProcess() {
return false;
diff --git
a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkCommunicationErrorResolveStartMessage.java
b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkCommunicationErrorResolveStartMessage.java
index 323e41bcf9b..d420d8bbfbe 100644
---
a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkCommunicationErrorResolveStartMessage.java
+++
b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkCommunicationErrorResolveStartMessage.java
@@ -45,11 +45,6 @@ public class ZkCommunicationErrorResolveStartMessage extends
DiscoverySpiCustomM
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
/** {@inheritDoc} */
@Override public boolean stopProcess() {
return false;
diff --git
a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkForceNodeFailMessage.java
b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkForceNodeFailMessage.java
index 025d7afa46f..f24ff535484 100644
---
a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkForceNodeFailMessage.java
+++
b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkForceNodeFailMessage.java
@@ -49,11 +49,6 @@ public class ZkForceNodeFailMessage extends
DiscoverySpiCustomMessage implements
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
/** {@inheritDoc} */
@Override public boolean stopProcess() {
return false;
diff --git
a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkNoServersMessage.java
b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkNoServersMessage.java
index 0079ab11b71..96706754a2d 100644
---
a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkNoServersMessage.java
+++
b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkNoServersMessage.java
@@ -34,11 +34,6 @@ class ZkNoServersMessage extends DiscoverySpiCustomMessage
implements ZkInternal
return null;
}
- /** {@inheritDoc} */
- @Override public boolean isMutable() {
- return false;
- }
-
/** {@inheritDoc} */
@Override public boolean stopProcess() {
return false;
