本文整理汇总了Java中io.reactivex.netty.servo.ServoEventsListenerFactory类的典型用法代码示例。如果您正苦于以下问题:Java ServoEventsListenerFactory类的具体用法?Java ServoEventsListenerFactory怎么用?Java ServoEventsListenerFactory使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ServoEventsListenerFactory类属于io.reactivex.netty.servo包,在下文中一共展示了ServoEventsListenerFactory类的3个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: onInit
import io.reactivex.netty.servo.ServoEventsListenerFactory; //导入依赖的package包/类
@Override
protected void onInit() throws Exception {
if (cfg.isRxEnableNativeLinuxEpoll()) {
System.out.println("Enabling Native Linux Transport...");
RxNetty.useNativeTransportIfApplicable();
}
RxNetty.useMetricListenersFactory(new ServoEventsListenerFactory());
Builder builder = new AsyncDocumentClient.Builder()
.withServiceEndpoint(cfg.getServiceEndpoint())
.withMasterKey(cfg.getMasterKey())
.withConnectionPolicy(cfg.getConnectionPolicy())
.withConsistencyLevel(cfg.getConsistencyLevel());
this.rxDocumentClient = builder.build();
}
开发者ID:Azure,项目名称:azure-documentdb-java,代码行数:18,代码来源:RxAsyncBulkInsertBenchmark.java
示例2: onInit
import io.reactivex.netty.servo.ServoEventsListenerFactory; //导入依赖的package包/类
@Override
protected void onInit() throws Exception {
RxNetty.useMetricListenersFactory(new ServoEventsListenerFactory());
documentClient = new DocumentClient(cfg.getServiceEndpoint(), cfg.getMasterKey(),
cfg.getConnectionPolicy(), cfg.getConsistencyLevel());
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(cfg.getConcurrency(), cfg.getConcurrency(),
10, TimeUnit.MINUTES, new ArrayBlockingQueue<Runnable>(cfg.getConcurrency(), true),
new ThreadPoolExecutor.CallerRunsPolicy());
this.executor = MoreExecutors.listeningDecorator(threadPoolExecutor);
}
开发者ID:Azure,项目名称:azure-documentdb-rxjava,代码行数:13,代码来源:SyncBulkInsertBenchmark.java
示例3: configure
import io.reactivex.netty.servo.ServoEventsListenerFactory; //导入依赖的package包/类
@Override
protected void configure() {
RxNetty.useMetricListenersFactory(new ServoEventsListenerFactory());
}
开发者ID:Netflix,项目名称:karyon,代码行数:5,代码来源:KaryonServoModule.java
注:本文中的io.reactivex.netty.servo.ServoEventsListenerFactory类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论