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

TransportService.createAdapter介绍

暂无

代码示例

代码示例来源：origin: harbby/presto-connectors

@Inject
public TransportService(Settings settings, Transport transport, ThreadPool threadPool) {
  super(settings);
  this.transport = transport;
  this.threadPool = threadPool;
  this.tracerLogInclude = settings.getAsArray(SETTING_TRACE_LOG_INCLUDE, Strings.EMPTY_ARRAY, true);
  this.tracelLogExclude = settings.getAsArray(SETTING_TRACE_LOG_EXCLUDE, new String[]{"internal:discovery/zen/fd*", TransportLivenessAction.NAME}, true);
  tracerLog = Loggers.getLogger(logger, ".tracer");
  adapter = createAdapter();
  taskManager = createTaskManager();
}

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

/**
 * Build the service.
 *
 * @param clusterSettings if non null the the {@linkplain TransportService} will register with the {@link ClusterSettings} for settings
 *        updates for {@link #TRACE_LOG_EXCLUDE_SETTING} and {@link #TRACE_LOG_INCLUDE_SETTING}.
 */
public TransportService(Settings settings, Transport transport, ThreadPool threadPool, TransportInterceptor transportInterceptor,
            Function<BoundTransportAddress, DiscoveryNode> localNodeFactory, @Nullable ClusterSettings clusterSettings) {
  super(settings);
  this.transport = transport;
  this.threadPool = threadPool;
  this.localNodeFactory = localNodeFactory;
  this.clusterName = ClusterName.CLUSTER_NAME_SETTING.get(settings);
  setTracerLogInclude(TRACE_LOG_INCLUDE_SETTING.get(settings));
  setTracerLogExclude(TRACE_LOG_EXCLUDE_SETTING.get(settings));
  tracerLog = Loggers.getLogger(logger, ".tracer");
  adapter = createAdapter();
  taskManager = createTaskManager();
  this.interceptor = transportInterceptor;
  this.asyncSender = interceptor.interceptSender(this::sendRequestInternal);
  this.connectToRemoteCluster = RemoteClusterService.ENABLE_REMOTE_CLUSTERS.get(settings);
  remoteClusterService = new RemoteClusterService(settings, this);
  if (clusterSettings != null) {
    clusterSettings.addSettingsUpdateConsumer(TRACE_LOG_INCLUDE_SETTING, this::setTracerLogInclude);
    clusterSettings.addSettingsUpdateConsumer(TRACE_LOG_EXCLUDE_SETTING, this::setTracerLogExclude);
    if (connectToRemoteCluster) {
      remoteClusterService.listenForUpdates(clusterSettings);
    }
  }
}