Class TransportReplicationAction.ReplicaOperationTransportHandler
- java.lang.Object
-
- org.elasticsearch.action.support.replication.TransportReplicationAction.ReplicaOperationTransportHandler
-
- All Implemented Interfaces:
TransportRequestHandler<TransportReplicationAction.ConcreteReplicaRequest<ReplicaRequest>>
- Enclosing class:
- TransportReplicationAction<Request extends ReplicationRequest<Request>,ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>
public class TransportReplicationAction.ReplicaOperationTransportHandler extends java.lang.Object implements TransportRequestHandler<TransportReplicationAction.ConcreteReplicaRequest<ReplicaRequest>>
-
-
Constructor Summary
Constructors Constructor Description ReplicaOperationTransportHandler()
-
Method Summary
Modifier and Type Method Description void
messageReceived(TransportReplicationAction.ConcreteReplicaRequest<ReplicaRequest> replicaRequest, TransportChannel channel)
void
messageReceived(TransportReplicationAction.ConcreteReplicaRequest<ReplicaRequest> replicaRequest, TransportChannel channel, Task task)
Override this method if access to the Task parameter is needed
-
-
-
Method Detail
-
messageReceived
public void messageReceived(TransportReplicationAction.ConcreteReplicaRequest<ReplicaRequest> replicaRequest, TransportChannel channel) throws java.lang.Exception
- Specified by:
messageReceived
in interfaceTransportRequestHandler<TransportReplicationAction.ConcreteReplicaRequest<ReplicaRequest extends ReplicationRequest<ReplicaRequest>>>
- Throws:
java.lang.Exception
-
messageReceived
public void messageReceived(TransportReplicationAction.ConcreteReplicaRequest<ReplicaRequest> replicaRequest, TransportChannel channel, Task task) throws java.lang.Exception
Description copied from interface:TransportRequestHandler
Override this method if access to the Task parameter is needed- Specified by:
messageReceived
in interfaceTransportRequestHandler<TransportReplicationAction.ConcreteReplicaRequest<ReplicaRequest extends ReplicationRequest<ReplicaRequest>>>
- Throws:
java.lang.Exception
-
-