Skip to content

Commit fb34694

Browse files
committed
IGNITE-24963 Make ReplicationException retriable again
1 parent cb21922 commit fb34694

2 files changed

Lines changed: 4 additions & 3 deletions

File tree

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

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

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

2625
/**
2726
* The exception is thrown when a replica is not ready to handle a request.
2827
*/
29-
public class ReplicaUnavailableException extends ReplicationException implements RetriableTransactionException {
28+
public class ReplicaUnavailableException extends ReplicationException {
3029
private static final long serialVersionUID = 9142077461528136559L;
3130

3231
/**

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,11 +23,13 @@
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;
2627

2728
/**
2829
* The exception is thrown when some issue happened during a replication.
2930
*/
30-
public class ReplicationException extends IgniteInternalException implements RetriableReplicaRequestException {
31+
public class ReplicationException extends IgniteInternalException implements RetriableTransactionException,
32+
RetriableReplicaRequestException {
3133
/**
3234
* Constructor.
3335
*

0 commit comments

Comments
 (0)