Package org.elasticsearch.action.support.replication

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReplicaOperationTransportHandler

public ReplicaOperationTransportHandler()

Method Detail

messageReceived

public void messageReceived(TransportReplicationAction.ConcreteReplicaRequest<ReplicaRequest> replicaRequest,
                            TransportChannel channel)
                     throws java.lang.Exception

Specified by:

messageReceived in interface TransportRequestHandler<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 interface TransportRequestHandler<TransportReplicationAction.ConcreteReplicaRequest<ReplicaRequest extends ReplicationRequest<ReplicaRequest>>>

Throws:

java.lang.Exception