Java源码示例:org.apache.apex.shaded.ning19.com.ning.http.client.AsyncHttpClientConfigBean

示例1
/**
 * <p>Constructor for PubSubWebSocketClient.</p>
 */
public PubSubWebSocketClient()
{
  throwable = new AtomicReference<>();
  ioThreadMultiplier = 1;
  mapper = (new JacksonObjectMapperProvider()).getContext(null);
  codec = new PubSubMessageCodec<>(mapper);

  AsyncHttpClientConfigBean config = new AsyncHttpClientConfigBean();
  config.setIoThreadMultiplier(ioThreadMultiplier);
  config.setApplicationThreadPool(Executors.newCachedThreadPool(new NameableThreadFactory("AsyncHttpClient")));
  client = new AsyncHttpClient(config);
}
 
示例2
/**
 * <p>Constructor for PubSubWebSocketClient.</p>
 */
public PubSubWebSocketClient()
{
  throwable = new AtomicReference<>();
  ioThreadMultiplier = 1;
  mapper = (new JacksonObjectMapperProvider()).getContext(null);
  codec = new PubSubMessageCodec<>(mapper);

  AsyncHttpClientConfigBean config = new AsyncHttpClientConfigBean();
  config.setIoThreadMultiplier(ioThreadMultiplier);
  config.setApplicationThreadPool(Executors.newCachedThreadPool(new NameableThreadFactory("AsyncHttpClient")));
  client = new AsyncHttpClient(config);
}