(ignite-3) branch main updated: IGNITE-28339 Move non-direct RO handlers to the request handler registry in `PartitionReplicaListener` (#7858)

[ibessonov]

This is an automated email from the ASF dual-hosted git repository.

ibessonov pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 24cfb8eb755 IGNITE-28339 Move non-direct RO handlers to the request 
handler registry in `PartitionReplicaListener` (#7858)
24cfb8eb755 is described below

commit 24cfb8eb755d0767d969876b60ad0b3ace6a2623
Author: Ivan Zlenko <241953+ivanzle...@users.noreply.github.com>
AuthorDate: Tue Mar 24 12:51:12 2026 +0500

    IGNITE-28339 Move non-direct RO handlers to the request handler registry in 
`PartitionReplicaListener` (#7858)
---
 .../replicator/PartitionReplicaListener.java       | 24 ++++++++++++++++------
 1 file changed, 18 insertions(+), 6 deletions(-)

diff --git 
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
 
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
index c67df68cab6..f314455fe27 100644
--- 
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
+++ 
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
@@ -469,6 +469,24 @@ public class PartitionReplicaListener implements 
ReplicaTableProcessor {
                 
PartitionReplicationMessageGroup.RO_DIRECT_MULTI_ROW_REPLICA_REQUEST,
                 
(ReadOnlyReplicaRequestHandler<ReadOnlyDirectMultiRowReplicaRequest>) 
this::processReadOnlyDirectMultiEntryAction);
 
+        handlersBuilder.addHandler(
+                PartitionReplicationMessageGroup.GROUP_TYPE,
+                PartitionReplicationMessageGroup.RO_SINGLE_ROW_REPLICA_REQUEST,
+                (ReplicaRequestHandler<ReadOnlySingleRowPkReplicaRequest>) 
(req, primacy) ->
+                        processReadOnlySingleEntryAction(req, 
primacy.isPrimary()));
+
+        handlersBuilder.addHandler(
+                PartitionReplicationMessageGroup.GROUP_TYPE,
+                PartitionReplicationMessageGroup.RO_MULTI_ROW_REPLICA_REQUEST,
+                (ReplicaRequestHandler<ReadOnlyMultiRowPkReplicaRequest>) 
(req, primacy) ->
+                        processReadOnlyMultiEntryAction(req, 
primacy.isPrimary()));
+
+        handlersBuilder.addHandler(
+                PartitionReplicationMessageGroup.GROUP_TYPE,
+                
PartitionReplicationMessageGroup.RO_SCAN_RETRIEVE_BATCH_REPLICA_REQUEST,
+                
(ReplicaRequestHandler<ReadOnlyScanRetrieveBatchReplicaRequest>) (req, primacy) 
->
+                        processReadOnlyScanRetrieveBatchAction(req, 
primacy.isPrimary()));
+
         requestHandlers = handlersBuilder.build();
     }
 
@@ -646,12 +664,6 @@ public class PartitionReplicaListener implements 
ReplicaTableProcessor {
                             releaseTxLocks(req.transactionId());
                         }
                     });
-        } else if (request instanceof ReadOnlySingleRowPkReplicaRequest) {
-            return 
processReadOnlySingleEntryAction((ReadOnlySingleRowPkReplicaRequest) request, 
replicaPrimacy.isPrimary());
-        } else if (request instanceof ReadOnlyMultiRowPkReplicaRequest) {
-            return 
processReadOnlyMultiEntryAction((ReadOnlyMultiRowPkReplicaRequest) request, 
replicaPrimacy.isPrimary());
-        } else if (request instanceof ReadOnlyScanRetrieveBatchReplicaRequest) 
{
-            return 
processReadOnlyScanRetrieveBatchAction((ReadOnlyScanRetrieveBatchReplicaRequest)
 request, replicaPrimacy.isPrimary());
         }
 
         // Unknown request.