io.airlift.bootstrap.Bootstrap.quiet()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(9.4k)|赞(0)|评价(0)|浏览(117)

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

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();
}

相关文章