本文整理了Java中org.elasticsearch.transport.TransportService.onResponseSent()方法的一些代码示例，展示了TransportService.onResponseSent()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。TransportService.onResponseSent()方法的具体详情如下：
包路径：org.elasticsearch.transport.TransportService
类名称：TransportService
方法名：onResponseSent

TransportService.onResponseSent介绍

[英]called by the Transport implementation after an exception was sent as a response to an incoming request
[中]在异常作为对传入请求的响应发送后，由传输实现调用

代码示例

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public void sendResponse(TransportResponse response) throws IOException {
  service.onResponseSent(requestId, action, response);
  final TransportResponseHandler handler = service.responseHandlers.onResponseReceived(requestId, service);
  // ignore if its null, the service logs it
  if (handler != null) {
    final String executor = handler.executor();
    if (ThreadPool.Names.SAME.equals(executor)) {
      processResponse(handler, response);
    } else {
      threadPool.executor(executor).execute(new Runnable() {
        @Override
        public void run() {
          processResponse(handler, response);
        }
        @Override
        public String toString() {
          return "delivery of response to [" + requestId + "][" + action + "]: " + response;
        }
      });
    }
  }
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public void sendResponse(Exception exception) throws IOException {
  service.onResponseSent(requestId, action, exception);
  final TransportResponseHandler handler = service.responseHandlers.onResponseReceived(requestId, service);
  // ignore if its null, the service logs it
  if (handler != null) {
    final RemoteTransportException rtx = wrapInRemote(exception);
    final String executor = handler.executor();
    if (ThreadPool.Names.SAME.equals(executor)) {
      processException(handler, rtx);
    } else {
      threadPool.executor(handler.executor()).execute(new Runnable() {
        @Override
        public void run() {
          processException(handler, rtx);
        }
        @Override
        public String toString() {
          return "delivery of failure response to [" + requestId + "][" + action + "]: " + exception;
        }
      });
    }
  }
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

@Override
public void sendResponse(final TransportResponse response, TransportResponseOptions options) throws IOException {
  service.onResponseSent(requestId, action, response, options);
  final TransportResponseHandler handler = service.responseHandlers.onResponseReceived(requestId, service);
  // ignore if its null, the service logs it
  if (handler != null) {
    final String executor = handler.executor();
    if (ThreadPool.Names.SAME.equals(executor)) {
      processResponse(handler, response);
    } else {
      threadPool.executor(executor).execute(new Runnable() {
        @Override
        public void run() {
          processResponse(handler, response);
        }
        @Override
        public String toString() {
          return "delivery of response to [" + requestId + "][" + action + "]: " + response;
        }
      });
    }
  }
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

@Override
public void sendResponse(Exception exception) throws IOException {
  service.onResponseSent(requestId, action, exception);
  final TransportResponseHandler handler = service.responseHandlers.onResponseReceived(requestId, service);
  // ignore if its null, the service logs it
  if (handler != null) {
    final RemoteTransportException rtx = wrapInRemote(exception);
    final String executor = handler.executor();
    if (ThreadPool.Names.SAME.equals(executor)) {
      processException(handler, rtx);
    } else {
      threadPool.executor(handler.executor()).execute(new Runnable() {
        @Override
        public void run() {
          processException(handler, rtx);
        }
        @Override
        public String toString() {
          return "delivery of failure response to [" + requestId + "][" + action + "]: " + exception;
        }
      });
    }
  }
}