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

Service.getExecutor介绍

暂无

代码示例

代码示例来源：origin: apache/cxf

public Executor getExecutor() {
  return wrappedService.getExecutor();
}

代码示例来源：origin: org.apache.cxf/cxf-api

public Executor getExecutor() {
  return executor == null ? service.getExecutor() : executor;
}

代码示例来源：origin: org.apache.cxf/cxf-bundle-jaxrs

public Executor getExecutor() {
  return executor == null ? service.getExecutor() : executor;
}

代码示例来源：origin: org.apache.openejb/openejb-cxf

public Executor getExecutor() {
  return service.getExecutor();
}

代码示例来源：origin: apache/cxf

public Executor getExecutor() {
  return executor == null ? service.getExecutor() : executor;
}

代码示例来源：origin: org.apache.cxf/cxf-core

public Executor getExecutor() {
  return executor == null ? service.getExecutor() : executor;
}

代码示例来源：origin: org.apache.tomee/openejb-cxf

public Executor getExecutor() {
  return service.getExecutor();
}

代码示例来源：origin: org.apache.geronimo.modules/geronimo-cxf

public Executor getExecutor() {
  return service.getExecutor();
}

代码示例来源：origin: org.apache.cxf/cxf-core

/**
 * Get the Executor for this invocation.
 * @param endpoint
 */
private Executor getExecutor(final Endpoint endpoint) {
  return endpoint.getService().getExecutor();
}

代码示例来源：origin: org.apache.cxf/cxf-bundle-jaxrs

/**
 * Get the Executor for this invocation.
 * @param endpoint
 * @return
 */
private Executor getExecutor(final Endpoint endpoint) {
  return endpoint.getService().getExecutor();
}

代码示例来源：origin: apache/cxf

/**
 * Get the Executor for this invocation.
 * @param endpoint
 */
private Executor getExecutor(final Endpoint endpoint) {
  return endpoint.getService().getExecutor();
}

代码示例来源：origin: org.apache.cxf/cxf-api

/**
 * Get the Executor for this invocation.
 * @param endpoint
 * @return
 */
private Executor getExecutor(final Endpoint endpoint) {
  return endpoint.getService().getExecutor();
}

代码示例来源：origin: apache/cxf

/**
 * Initiate redelivery asynchronsly.
 *
 */
protected void initiate() {
  pending = true;
  Endpoint ep = message.getExchange().get(Endpoint.class);
  Executor executor = ep.getExecutor();
  if (null == executor) {
    executor = ep.getService().getExecutor();
    LOG.log(Level.FINE, "Using service executor {0}", executor.getClass().getName());
  } else {
    LOG.log(Level.FINE, "Using endpoint executor {0}", executor.getClass().getName());
  }
  try {
    executor.execute(this);
  } catch (RejectedExecutionException ex) {
    LOG.log(Level.SEVERE, "RESEND_INITIATION_FAILED_MSG", ex);
  }
}

代码示例来源：origin: apache/cxf

/**
 * Initiate resend asynchronsly.
 *
 * @param requestAcknowledge true if a AckRequest header is to be sent
 *            with resend
 */
protected void initiate(boolean requestAcknowledge) {
  includeAckRequested = requestAcknowledge;
  pending = true;
  Endpoint ep = message.getExchange().getEndpoint();
  Executor executor = ep.getExecutor();
  if (null == executor) {
    executor = ep.getService().getExecutor();
    if (executor == null) {
      executor = SynchronousExecutor.getInstance();
    } else {
      LOG.log(Level.FINE, "Using service executor {0}", executor.getClass().getName());
    }
  } else {
    LOG.log(Level.FINE, "Using endpoint executor {0}", executor.getClass().getName());
  }
  try {
    executor.execute(this);
  } catch (RejectedExecutionException ex) {
    LOG.log(Level.SEVERE, "RESEND_INITIATION_FAILED_MSG", ex);
  }
}

代码示例来源：origin: apache/cxf

/**
 * Get the Executor for this invocation.
 * @param endpoint
 * @return
 */
private static Executor getExecutor(final Message message) {
  Endpoint endpoint = message.getExchange().getEndpoint();
  Executor executor = endpoint.getService().getExecutor();
  if (executor == null || SynchronousExecutor.isA(executor)) {
    // need true asynchrony
    Bus bus = message.getExchange().getBus();
    if (bus != null) {
      WorkQueueManager workQueueManager =
        bus.getExtension(WorkQueueManager.class);
      Executor autoWorkQueue =
        workQueueManager.getNamedWorkQueue("ws-addressing");
      executor = autoWorkQueue != null
            ? autoWorkQueue
            :  workQueueManager.getAutomaticWorkQueue();
    } else {
      executor = OneShotAsyncExecutor.getInstance();
    }
  }
  message.getExchange().put(Executor.class, executor);
  return executor;
}

代码示例来源：origin: apache/cxf

/**
 * Get the Executor for this invocation.
 * @param endpoint
 * @return
 */
private static Executor getExecutor(final Message message) {
  Endpoint endpoint = message.getExchange().getEndpoint();
  Executor executor = endpoint.getService().getExecutor();
  if (executor == null || SynchronousExecutor.isA(executor)) {
    // need true asynchrony
    Bus bus = message.getExchange().getBus();
    if (bus != null) {
      WorkQueueManager workQueueManager =
        bus.getExtension(WorkQueueManager.class);
      Executor autoWorkQueue =
        workQueueManager.getNamedWorkQueue("ws-addressing");
      executor = autoWorkQueue != null
            ? autoWorkQueue
            :  workQueueManager.getAutomaticWorkQueue();
    } else {
      executor = OneShotAsyncExecutor.getInstance();
    }
  }
  message.getExchange().put(Executor.class, executor);
  return executor;
}

代码示例来源：origin: org.apache.cxf/cxf-rt-ws-addr

/**
 * Get the Executor for this invocation.
 * @param endpoint
 * @return
 */
private static Executor getExecutor(final Message message) {
  Endpoint endpoint = message.getExchange().getEndpoint();
  Executor executor = endpoint.getService().getExecutor();
  if (executor == null || SynchronousExecutor.isA(executor)) {
    // need true asynchrony
    Bus bus = message.getExchange().getBus();
    if (bus != null) {
      WorkQueueManager workQueueManager =
        bus.getExtension(WorkQueueManager.class);
      Executor autoWorkQueue =
        workQueueManager.getNamedWorkQueue("ws-addressing");
      executor = autoWorkQueue != null
            ? autoWorkQueue
            :  workQueueManager.getAutomaticWorkQueue();
    } else {
      executor = OneShotAsyncExecutor.getInstance();
    }
  }
  message.getExchange().put(Executor.class, executor);
  return executor;
}