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

Configuration.getNettyOptions介绍

[英]Returns the NettyOptions instance for this configuration.
[中]返回此配置的NettyOptions实例。

代码示例

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

/**
 * Copy constructor.
 *
 * @param toCopy the object to copy from.
 */
protected Configuration(Configuration toCopy) {
 this(
   toCopy.getPolicies(),
   toCopy.getProtocolOptions(),
   toCopy.getPoolingOptions(),
   toCopy.getSocketOptions(),
   toCopy.getMetricsOptions(),
   toCopy.getQueryOptions(),
   toCopy.getThreadingOptions(),
   toCopy.getNettyOptions(),
   toCopy.getCodecRegistry());
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

Factory(Cluster.Manager manager, Configuration configuration) {
 this.defaultHandler = manager;
 this.manager = manager;
 this.reaper = manager.reaper;
 this.configuration = configuration;
 this.authProvider = configuration.getProtocolOptions().getAuthProvider();
 this.protocolVersion = configuration.getProtocolOptions().initialProtocolVersion;
 this.nettyOptions = configuration.getNettyOptions();
 this.eventLoopGroup =
   nettyOptions.eventLoopGroup(
     manager
       .configuration
       .getThreadingOptions()
       .createThreadFactory(manager.clusterName, "nio-worker"));
 this.channelClass = nettyOptions.channelClass();
 this.timer =
   nettyOptions.timer(
     manager
       .configuration
       .getThreadingOptions()
       .createThreadFactory(manager.clusterName, "timeouter"));
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

protocolOptions.getSSLOptions(),
factory.configuration.getPoolingOptions().getHeartbeatIntervalSeconds(),
factory.configuration.getNettyOptions(),
factory.configuration.getCodecRegistry(),
factory.configuration.getMetricsOptions().isEnabled()

代码示例来源：origin: io.prestosql.cassandra/cassandra-driver

/**
 * Copy constructor.
 *
 * @param toCopy the object to copy from.
 */
protected Configuration(Configuration toCopy) {
  this(
      toCopy.getPolicies(),
      toCopy.getProtocolOptions(),
      toCopy.getPoolingOptions(),
      toCopy.getSocketOptions(),
      toCopy.getMetricsOptions(),
      toCopy.getQueryOptions(),
      toCopy.getThreadingOptions(),
      toCopy.getNettyOptions(),
      toCopy.getCodecRegistry()
  );
}

代码示例来源：origin: com.yugabyte/cassandra-driver-core

/**
 * Copy constructor.
 *
 * @param toCopy the object to copy from.
 */
protected Configuration(Configuration toCopy) {
  this(
      toCopy.getPolicies(),
      toCopy.getProtocolOptions(),
      toCopy.getPoolingOptions(),
      toCopy.getSocketOptions(),
      toCopy.getMetricsOptions(),
      toCopy.getQueryOptions(),
      toCopy.getThreadingOptions(),
      toCopy.getNettyOptions(),
      toCopy.getCodecRegistry()
  );
}

代码示例来源：origin: com.yugabyte/cassandra-driver-core

new Initializer(this, protocolVersion, protocolOptions.getCompression().compressor(), protocolOptions.getSSLOptions(),
    factory.configuration.getPoolingOptions().getHeartbeatIntervalSeconds(),
    factory.configuration.getNettyOptions(),
    factory.configuration.getCodecRegistry()));

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-driver

/**
 * Copy constructor.
 *
 * @param toCopy the object to copy from.
 */
protected Configuration(Configuration toCopy) {
  this(
      toCopy.getPolicies(),
      toCopy.getProtocolOptions(),
      toCopy.getPoolingOptions(),
      toCopy.getSocketOptions(),
      toCopy.getMetricsOptions(),
      toCopy.getQueryOptions(),
      toCopy.getThreadingOptions(),
      toCopy.getNettyOptions(),
      toCopy.getCodecRegistry()
  );
}

代码示例来源：origin: com.yugabyte/cassandra-driver-core

Factory(Cluster.Manager manager, Configuration configuration) {
  this.defaultHandler = manager;
  this.manager = manager;
  this.reaper = manager.reaper;
  this.configuration = configuration;
  this.authProvider = configuration.getProtocolOptions().getAuthProvider();
  this.protocolVersion = configuration.getProtocolOptions().initialProtocolVersion;
  this.nettyOptions = configuration.getNettyOptions();
  this.eventLoopGroup = nettyOptions.eventLoopGroup(
      manager.configuration.getThreadingOptions().createThreadFactory(manager.clusterName, "nio-worker"));
  this.channelClass = nettyOptions.channelClass();
  this.timer = nettyOptions.timer(
      manager.configuration.getThreadingOptions().createThreadFactory(manager.clusterName, "timeouter"));
}

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-driver

Factory(Cluster.Manager manager, Configuration configuration) {
  this.defaultHandler = manager;
  this.manager = manager;
  this.reaper = manager.reaper;
  this.configuration = configuration;
  this.authProvider = configuration.getProtocolOptions().getAuthProvider();
  this.protocolVersion = configuration.getProtocolOptions().initialProtocolVersion;
  this.nettyOptions = configuration.getNettyOptions();
  this.eventLoopGroup = nettyOptions.eventLoopGroup(
      manager.configuration.getThreadingOptions().createThreadFactory(manager.clusterName, "nio-worker"));
  this.channelClass = nettyOptions.channelClass();
  this.timer = nettyOptions.timer(
      manager.configuration.getThreadingOptions().createThreadFactory(manager.clusterName, "timeouter"));
}

代码示例来源：origin: io.prestosql.cassandra/cassandra-driver

Factory(Cluster.Manager manager, Configuration configuration) {
  this.defaultHandler = manager;
  this.manager = manager;
  this.reaper = manager.reaper;
  this.configuration = configuration;
  this.authProvider = configuration.getProtocolOptions().getAuthProvider();
  this.protocolVersion = configuration.getProtocolOptions().initialProtocolVersion;
  this.nettyOptions = configuration.getNettyOptions();
  this.eventLoopGroup = nettyOptions.eventLoopGroup(
      manager.configuration.getThreadingOptions().createThreadFactory(manager.clusterName, "nio-worker"));
  this.channelClass = nettyOptions.channelClass();
  this.timer = nettyOptions.timer(
      manager.configuration.getThreadingOptions().createThreadFactory(manager.clusterName, "timeouter"));
}

代码示例来源：origin: io.prestosql.cassandra/cassandra-driver

new Initializer(this, protocolVersion, protocolOptions.getCompression().compressor(), protocolOptions.getSSLOptions(),
    factory.configuration.getPoolingOptions().getHeartbeatIntervalSeconds(),
    factory.configuration.getNettyOptions(),
    factory.configuration.getCodecRegistry()));

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-driver

new Initializer(this, protocolVersion, protocolOptions.getCompression().compressor(), protocolOptions.getSSLOptions(),
    factory.configuration.getPoolingOptions().getHeartbeatIntervalSeconds(),
    factory.configuration.getNettyOptions(),
    factory.configuration.getCodecRegistry()));

代码示例来源：origin: com.github.ddth/ddth-cql-utils

NettyOptions nOpt = conf != null ? conf.getNettyOptions() : null;
if (nOpt != null) {
  builder.withNettyOptions(nOpt);