Package org.elasticsearch.rest.action

Class DispatchingRestToXContentListener<Response extends StatusToXContentObject>

java.lang.Object

org.elasticsearch.rest.action.RestActionListener<Response>

org.elasticsearch.rest.action.DispatchingRestToXContentListener<Response>

All Implemented Interfaces:

ActionListener<Response>

public class DispatchingRestToXContentListener<Response extends StatusToXContentObject>
extends RestActionListener<Response>

Response listener for REST requests which dispatches the serialization of the response off of the thread on which the response was received, since that thread is often a transport thread and XContent serialization might be expensive.

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.action.ActionListener

ActionListener.Delegating<Response,DelegateResponse>, ActionListener.DelegatingActionListener<T>, ActionListener.DelegatingFailureActionListener<T,R>, ActionListener.MappedActionListener<Response,MappedResponse>, ActionListener.RunAfterActionListener<T>, ActionListener.RunBeforeActionListener<T>

Field Summary

Fields inherited from class org.elasticsearch.rest.action.RestActionListener

channel

Constructor Summary

Constructors

Constructor	Description
DispatchingRestToXContentListener(ExecutorService executor, RestChannel channel, RestRequest restRequest)

Method Summary

Modifier and Type	Method	Description
protected ToXContent.Params	getParams()
protected void	processResponse(Response response)

Methods inherited from class org.elasticsearch.rest.action.RestActionListener

ensureOpen, onFailure, onResponse

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.action.ActionListener

delegateFailure, delegateResponse, map

Constructor Details

DispatchingRestToXContentListener

public DispatchingRestToXContentListener(ExecutorService executor,
 RestChannel channel,
 RestRequest restRequest)

Method Details

getParams

protected ToXContent.Params getParams()

processResponse

protected void processResponse(Response response)

Specified by:

processResponse in class RestActionListener<Response extends StatusToXContentObject>