本文整理了Java中io.airlift.bootstrap.Bootstrap.quiet()
方法的一些代码示例,展示了Bootstrap.quiet()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Bootstrap.quiet()
方法的具体详情如下:
包路径:io.airlift.bootstrap.Bootstrap
类名称:Bootstrap
方法名:quiet
暂无
代码示例来源:origin: prestodb/presto
.setRequiredConfigurationProperties(serverProperties.build())
.setOptionalConfigurationProperties(optionalProperties)
.quiet()
.initialize();
代码示例来源:origin: prestodb/presto
@Override
public ResourceGroupConfigurationManager<VariableMap> create(Map<String, String> config, ResourceGroupConfigurationManagerContext context)
{
try (ThreadContextClassLoader ignored = new ThreadContextClassLoader(classLoader)) {
Bootstrap app = new Bootstrap(
new JsonModule(),
new H2ResourceGroupsModule(),
new NodeModule(),
binder -> binder.bind(ResourceGroupConfigurationManagerContext.class).toInstance(context),
binder -> binder.bind(ClusterMemoryPoolManager.class).toInstance(context.getMemoryPoolManager()));
Injector injector = app
.strictConfig()
.doNotInitializeLogging()
.setRequiredConfigurationProperties(config)
.quiet()
.initialize();
return injector.getInstance(DbResourceGroupConfigurationManager.class);
}
catch (Exception e) {
throwIfUnchecked(e);
throw new RuntimeException(e);
}
}
}
代码示例来源:origin: prestodb/presto
.strictConfig()
.doNotInitializeLogging()
.quiet()
.initialize();
代码示例来源:origin: prestodb/presto
.setRequiredConfigurationProperty("proxy.uri", server.getBaseUrl().toString())
.setRequiredConfigurationProperty("proxy.shared-secret-file", sharedSecretFile.toString())
.quiet()
.initialize();
代码示例来源:origin: prestodb/presto
.strictConfig()
.doNotInitializeLogging()
.quiet()
.initialize();
HandleResolver handleResolver = injector.getInstance(HandleResolver.class);
代码示例来源:origin: airlift/airlift
@Test
public void testWithoutFilters()
throws Exception
{
Injector injector = new Bootstrap(
binder -> httpClientBinder(binder).bindHttpClient("foo", FooClient.class))
.quiet()
.strictConfig()
.initialize();
assertNotNull(injector.getInstance(Key.get(HttpClient.class, FooClient.class)));
}
代码示例来源:origin: io.airlift/http-client
@Test
public void testWithoutFilters()
throws Exception
{
Injector injector = new Bootstrap(
binder -> httpClientBinder(binder).bindHttpClient("foo", FooClient.class))
.quiet()
.strictConfig()
.initialize();
assertNotNull(injector.getInstance(Key.get(HttpClient.class, FooClient.class)));
}
代码示例来源:origin: io.airlift/http-client
@Test
public void testAliases()
throws Exception
{
Injector injector = new Bootstrap(
binder -> httpClientBinder(binder).bindHttpClient("foo", FooClient.class)
.withAlias(FooAlias1.class)
.withAliases(ImmutableList.of(FooAlias2.class, FooAlias3.class)))
.quiet()
.strictConfig()
.initialize();
HttpClient client = injector.getInstance(Key.get(HttpClient.class, FooClient.class));
assertSame(injector.getInstance(Key.get(HttpClient.class, FooAlias1.class)), client);
assertSame(injector.getInstance(Key.get(HttpClient.class, FooAlias2.class)), client);
assertSame(injector.getInstance(Key.get(HttpClient.class, FooAlias3.class)), client);
}
代码示例来源:origin: airlift/airlift
@Test
public void testAliases()
throws Exception
{
Injector injector = new Bootstrap(
binder -> httpClientBinder(binder).bindHttpClient("foo", FooClient.class)
.withAlias(FooAlias1.class)
.withAliases(ImmutableList.of(FooAlias2.class, FooAlias3.class)))
.quiet()
.strictConfig()
.initialize();
HttpClient client = injector.getInstance(Key.get(HttpClient.class, FooClient.class));
assertSame(injector.getInstance(Key.get(HttpClient.class, FooAlias1.class)), client);
assertSame(injector.getInstance(Key.get(HttpClient.class, FooAlias2.class)), client);
assertSame(injector.getInstance(Key.get(HttpClient.class, FooAlias3.class)), client);
}
代码示例来源:origin: io.airlift/http-client
@Test
public void testBindClientWithAliases()
throws Exception
{
Injector injector = new Bootstrap(
binder -> httpClientBinder(binder).bindHttpClient("foo", FooClient.class)
.withAlias(FooAlias1.class)
.withAlias(FooAlias2.class))
.quiet()
.strictConfig()
.initialize();
HttpClient client = injector.getInstance(Key.get(HttpClient.class, FooClient.class));
assertSame(injector.getInstance(Key.get(HttpClient.class, FooAlias1.class)), client);
assertSame(injector.getInstance(Key.get(HttpClient.class, FooAlias2.class)), client);
}
代码示例来源:origin: airlift/airlift
@Test
public void testBindClientWithAliases()
throws Exception
{
Injector injector = new Bootstrap(
binder -> httpClientBinder(binder).bindHttpClient("foo", FooClient.class)
.withAlias(FooAlias1.class)
.withAlias(FooAlias2.class))
.quiet()
.strictConfig()
.initialize();
HttpClient client = injector.getInstance(Key.get(HttpClient.class, FooClient.class));
assertSame(injector.getInstance(Key.get(HttpClient.class, FooAlias1.class)), client);
assertSame(injector.getInstance(Key.get(HttpClient.class, FooAlias2.class)), client);
}
代码示例来源:origin: io.airlift/http-client
@Test
public void testMultipleClients()
throws Exception
{
Injector injector = new Bootstrap(
binder -> {
httpClientBinder(binder).bindHttpClient("foo", FooClient.class);
httpClientBinder(binder).bindHttpClient("bar", BarClient.class);
})
.quiet()
.strictConfig()
.initialize();
HttpClient fooClient = injector.getInstance(Key.get(HttpClient.class, FooClient.class));
HttpClient barClient = injector.getInstance(Key.get(HttpClient.class, BarClient.class));
assertNotSame(fooClient, barClient);
}
代码示例来源:origin: airlift/airlift
@Test
public void testMultipleClients()
throws Exception
{
Injector injector = new Bootstrap(
binder -> {
httpClientBinder(binder).bindHttpClient("foo", FooClient.class);
httpClientBinder(binder).bindHttpClient("bar", BarClient.class);
})
.quiet()
.strictConfig()
.initialize();
HttpClient fooClient = injector.getInstance(Key.get(HttpClient.class, FooClient.class));
HttpClient barClient = injector.getInstance(Key.get(HttpClient.class, BarClient.class));
assertNotSame(fooClient, barClient);
}
代码示例来源:origin: airlift/airlift
@Test
public void testClientShutdown()
throws Exception
{
Injector injector = new Bootstrap(
binder -> {
httpClientBinder(binder).bindHttpClient("foo", FooClient.class);
httpClientBinder(binder).bindHttpClient("bar", BarClient.class);
})
.quiet()
.strictConfig()
.initialize();
HttpClient fooClient = injector.getInstance(Key.get(HttpClient.class, FooClient.class));
HttpClient barClient = injector.getInstance(Key.get(HttpClient.class, BarClient.class));
assertFalse(fooClient.isClosed());
assertFalse(barClient.isClosed());
injector.getInstance(LifeCycleManager.class).stop();
assertTrue(fooClient.isClosed());
assertTrue(barClient.isClosed());
}
代码示例来源:origin: io.airlift/http-client
@Test
public void testConfigDefaults()
throws Exception
{
Injector injector = new Bootstrap(
binder -> httpClientBinder(binder)
.bindHttpClient("foo", FooClient.class)
.withConfigDefaults(config -> config.setRequestTimeout(new Duration(33, MINUTES))),
new TraceTokenModule())
.quiet()
.strictConfig()
.initialize();
JettyHttpClient httpClient = (JettyHttpClient) injector.getInstance(Key.get(HttpClient.class, FooClient.class));
assertEquals(httpClient.getRequestTimeoutMillis(), MINUTES.toMillis(33));
}
代码示例来源:origin: airlift/airlift
@Test
public void testConfigDefaults()
throws Exception
{
Injector injector = new Bootstrap(
binder -> httpClientBinder(binder)
.bindHttpClient("foo", FooClient.class)
.withConfigDefaults(config -> config.setRequestTimeout(new Duration(33, MINUTES))),
new TraceTokenModule())
.quiet()
.strictConfig()
.initialize();
JettyHttpClient httpClient = (JettyHttpClient) injector.getInstance(Key.get(HttpClient.class, FooClient.class));
assertEquals(httpClient.getRequestTimeoutMillis(), MINUTES.toMillis(33));
}
代码示例来源:origin: io.airlift/http-client
@Test
public void testBindClientWithFilter()
throws Exception
{
Injector injector = new Bootstrap(
binder -> httpClientBinder(binder).bindHttpClient("foo", FooClient.class)
.withFilter(TestingRequestFilter.class)
.withFilter(AnotherHttpRequestFilter.class)
.withTracing(),
new TraceTokenModule())
.quiet()
.strictConfig()
.initialize();
HttpClient httpClient = injector.getInstance(Key.get(HttpClient.class, FooClient.class));
assertFilterCount(httpClient, 3);
}
代码示例来源:origin: airlift/airlift
@Test
public void testBindClientWithFilter()
throws Exception
{
Injector injector = new Bootstrap(
binder -> httpClientBinder(binder).bindHttpClient("foo", FooClient.class)
.withFilter(TestingRequestFilter.class)
.withFilter(AnotherHttpRequestFilter.class)
.withTracing(),
new TraceTokenModule())
.quiet()
.strictConfig()
.initialize();
HttpClient httpClient = injector.getInstance(Key.get(HttpClient.class, FooClient.class));
assertFilterCount(httpClient, 3);
}
代码示例来源:origin: airlift/airlift
@BeforeClass
public void setup()
throws Exception
{
Bootstrap app = new Bootstrap(
new TestingNodeModule(),
new TestingHttpServerModule(),
new JsonModule(),
new JaxrsModule(true),
new JmxHttpModule(),
binder -> binder.bind(MBeanServer.class).toInstance(mbeanServer));
Injector injector = app
.quiet()
.strictConfig()
.initialize();
lifeCycleManager = injector.getInstance(LifeCycleManager.class);
server = injector.getInstance(TestingHttpServer.class);
client = new JettyHttpClient();
}
代码示例来源:origin: io.airlift/jmx-http
@BeforeClass
public void setup()
throws Exception
{
Bootstrap app = new Bootstrap(
new TestingNodeModule(),
new TestingHttpServerModule(),
new JsonModule(),
new JaxrsModule(true),
new JmxHttpModule(),
binder -> binder.bind(MBeanServer.class).toInstance(mbeanServer));
Injector injector = app
.quiet()
.strictConfig()
.initialize();
lifeCycleManager = injector.getInstance(LifeCycleManager.class);
server = injector.getInstance(TestingHttpServer.class);
client = new JettyHttpClient();
}
内容来源于网络,如有侵权,请联系作者删除!