Package | Description |
---|---|
org.elasticsearch.transport | |
org.elasticsearch.transport.local | |
org.elasticsearch.transport.netty |
Modifier and Type | Class and Description |
---|---|
class |
BaseTransportResponseHandler<T extends TransportResponse>
A simple based class that always spawns.
|
class |
EmptyTransportResponseHandler |
class |
FutureTransportResponseHandler<T extends TransportResponse>
A response handler to be used when all interaction will be done through the
TransportFuture . |
class |
PlainTransportFuture<V extends TransportResponse> |
Modifier and Type | Method and Description |
---|---|
TransportResponseHandler |
TransportServiceAdapter.onResponseReceived(long requestId)
called by the {@link Transport) implementation when a response or an exception has been recieved for a previously
sent request (before any processing or deserialization was done).
|
TransportResponseHandler |
TransportService.Adapter.onResponseReceived(long requestId) |
Modifier and Type | Method and Description |
---|---|
<T extends TransportResponse> |
TransportService.sendRequest(DiscoveryNode node,
String action,
TransportRequest request,
TransportRequestOptions options,
TransportResponseHandler<T> handler) |
<T extends TransportResponse> |
TransportService.sendRequest(DiscoveryNode node,
String action,
TransportRequest request,
TransportResponseHandler<T> handler) |
<T extends TransportResponse> |
TransportService.submitRequest(DiscoveryNode node,
String action,
TransportRequest request,
TransportRequestOptions options,
TransportResponseHandler<T> handler) |
<T extends TransportResponse> |
TransportService.submitRequest(DiscoveryNode node,
String action,
TransportRequest request,
TransportResponseHandler<T> handler) |
Constructor and Description |
---|
PlainTransportFuture(TransportResponseHandler<V> handler) |
Modifier and Type | Method and Description |
---|---|
protected void |
LocalTransport.handleParsedResponse(TransportResponse response,
TransportResponseHandler handler) |
protected void |
LocalTransport.handleResponse(StreamInput buffer,
LocalTransport sourceTransport,
TransportResponseHandler handler) |
Modifier and Type | Method and Description |
---|---|
protected void |
MessageChannelHandler.handleResponse(org.jboss.netty.channel.Channel channel,
StreamInput buffer,
TransportResponseHandler handler) |
Copyright © 2009–2015. All rights reserved.