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