org.elasticsearch.action.support.replication

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 and Description
PrimaryOperationTransportHandler()

Method Summary

Modifier and Type	Method and 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

Methods inherited from class java.lang.Object

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

Constructor Detail

PrimaryOperationTransportHandler

public PrimaryOperationTransportHandler()

Method Detail

messageReceived

public void messageReceived(TransportReplicationAction.ConcreteShardRequest<Request> request,
                            TransportChannel channel)
                     throws java.lang.Exception

Specified by:

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