Skip to content

Commit 7c2b7bd

Browse files
committed
IGNITE-24963 Revert previous change
1 parent fb34694 commit 7c2b7bd

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/ReplicaStoppingException.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,11 +22,12 @@
2222
import java.util.UUID;
2323
import org.apache.ignite.internal.network.InternalClusterNode;
2424
import org.apache.ignite.internal.replicator.ReplicationGroupId;
25+
import org.apache.ignite.tx.RetriableTransactionException;
2526

2627
/**
2728
* The exception is thrown for unhandled requests that wait for the replica, but it is already stopping.
2829
*/
29-
public class ReplicaStoppingException extends ReplicationException {
30+
public class ReplicaStoppingException extends ReplicationException implements RetriableTransactionException {
3031
/**
3132
* The constructor.
3233
*

modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/ReplicaUnavailableException.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,11 +21,12 @@
2121

2222
import org.apache.ignite.internal.network.InternalClusterNode;
2323
import org.apache.ignite.internal.replicator.ReplicationGroupId;
24+
import org.apache.ignite.tx.RetriableTransactionException;
2425

2526
/**
2627
* The exception is thrown when a replica is not ready to handle a request.
2728
*/
28-
public class ReplicaUnavailableException extends ReplicationException {
29+
public class ReplicaUnavailableException extends ReplicationException implements RetriableTransactionException {
2930
private static final long serialVersionUID = 9142077461528136559L;
3031

3132
/**

modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/ReplicationException.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -23,13 +23,11 @@
2323
import org.apache.ignite.internal.lang.IgniteInternalException;
2424
import org.apache.ignite.internal.replicator.ReplicationGroupId;
2525
import org.apache.ignite.tx.RetriableReplicaRequestException;
26-
import org.apache.ignite.tx.RetriableTransactionException;
2726

2827
/**
2928
* The exception is thrown when some issue happened during a replication.
3029
*/
31-
public class ReplicationException extends IgniteInternalException implements RetriableTransactionException,
32-
RetriableReplicaRequestException {
30+
public class ReplicationException extends IgniteInternalException implements RetriableReplicaRequestException {
3331
/**
3432
* Constructor.
3533
*

0 commit comments

Comments
 (0)