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

GZIPInInterceptor.<init>介绍

暂无

代码示例

代码示例来源：origin: stackoverflow.com

Client client = ClientProxy.getClient(port);
client.getInInterceptors().add(new GZIPInInterceptor());
client.getOutInterceptors().add(new GZIPOutInterceptor());

代码示例来源：origin: stackoverflow.com

// add accept-encoding header
Map<String, Object> requestHeaders = new HashMap<>();
requestHeaders.put("Accept-Encoding", new ArrayList<>(Arrays.asList("gzip")));
((BindingProvider)service).getRequestContext().put(MessageContext.HTTP_REQUEST_HEADERS, requestHeaders);

// encode response from server
client.getInInterceptors().add(new GZIPInInterceptor());

代码示例来源：origin: org.apache.brooklyn/brooklyn-rest-server

public static void installRest(ServletContextHandler context, Object... providers) {
  initSwagger();
  BrooklynRestApp app = new BrooklynRestApp();
  for (Object o : providers) {
    app.singleton(o);
  }
  CXFNonSpringJaxrsServlet servlet = new CXFNonSpringJaxrsServlet(app);
  servlet.setBus(BusFactory.newInstance().createBus());
  servlet.getBus().getInInterceptors().add(new GZIPInInterceptor());
  servlet.getBus().getInFaultInterceptors().add(new GZIPInInterceptor());
  servlet.getBus().getOutInterceptors().add(new GZIPOutInterceptor());
  final ServletHolder servletHolder = new ServletHolder(servlet);
  context.addServlet(servletHolder, "/v1/*");
}

代码示例来源：origin: org.apache.syncope.client/syncope-client-lib

/**
 * Creates an instance of the given service class, with configured content type and authentication.
 *
 * @param <T> any service class
 * @param serviceClass service class reference
 * @return service instance of the given reference class
 */
public <T> T getService(final Class<T> serviceClass) {
  synchronized (restClientFactory) {
    restClientFactory.setServiceClass(serviceClass);
    T serviceInstance = restClientFactory.create(serviceClass);
    Client client = WebClient.client(serviceInstance);
    client.type(mediaType).accept(mediaType);
    if (serviceInstance instanceof AnyService || serviceInstance instanceof ExecutableService) {
      client.accept(RESTHeaders.MULTIPART_MIXED);
    }
    ClientConfiguration config = WebClient.getConfig(client);
    config.getRequestContext().put(HEADER_SPLIT_PROPERTY, true);
    config.getRequestContext().put(URLConnectionHTTPConduit.HTTPURL_CONNECTION_METHOD_REFLECTION, true);
    if (useCompression) {
      config.getInInterceptors().add(new GZIPInInterceptor());
      config.getOutInterceptors().add(new GZIPOutInterceptor());
    }
    if (tlsClientParameters != null) {
      HTTPConduit httpConduit = (HTTPConduit) config.getConduit();
      httpConduit.setTlsClientParameters(tlsClientParameters);
    }
    return serviceInstance;
  }
}

代码示例来源：origin: apache/syncope

/**
 * Creates an instance of the given service class, with configured content type and authentication.
 *
 * @param <T> any service class
 * @param serviceClass service class reference
 * @return service instance of the given reference class
 */
public <T> T getService(final Class<T> serviceClass) {
  synchronized (restClientFactory) {
    restClientFactory.setServiceClass(serviceClass);
    T serviceInstance = restClientFactory.create(serviceClass);
    Client client = WebClient.client(serviceInstance);
    client.type(mediaType).accept(mediaType);
    if (serviceInstance instanceof AnyService || serviceInstance instanceof ExecutableService) {
      client.accept(RESTHeaders.MULTIPART_MIXED);
    }
    ClientConfiguration config = WebClient.getConfig(client);
    config.getRequestContext().put(HEADER_SPLIT_PROPERTY, true);
    config.getRequestContext().put(URLConnectionHTTPConduit.HTTPURL_CONNECTION_METHOD_REFLECTION, true);
    if (useCompression) {
      config.getInInterceptors().add(new GZIPInInterceptor());
      config.getOutInterceptors().add(new GZIPOutInterceptor());
    }
    if (tlsClientParameters != null) {
      HTTPConduit httpConduit = (HTTPConduit) config.getConduit();
      httpConduit.setTlsClientParameters(tlsClientParameters);
    }
    return serviceInstance;
  }
}

代码示例来源：origin: apache/cxf

private void invokeService(boolean isDirectDispatch) {
  BusFactory.setThreadDefaultBus(staticBus);
  Service service = Service.create(serviceName);
  service.addPort(localPortName, "http://schemas.xmlsoap.org/soap/",
          "local://Greeter");
  Greeter greeter = service.getPort(localPortName, Greeter.class);
  if (isDirectDispatch) {
    Client client = ClientProxy.getClient(greeter);
    client.getOutInterceptors().add(new GZIPOutInterceptor(50));
    client.getInInterceptors().add(new GZIPInInterceptor());
    InvocationHandler handler = Proxy.getInvocationHandler(greeter);
    BindingProvider bp = null;
    if (handler instanceof BindingProvider) {
      bp = (BindingProvider)handler;
      Map<String, Object> requestContext = bp.getRequestContext();
      requestContext.put(LocalConduit.DIRECT_DISPATCH, true);
    }
  }
  String reply = greeter.greetMe("test");
  assertEquals("Hello test", reply);
  reply = greeter.sayHi();
  assertNotNull("no response received from service", reply);
  assertEquals("Bonjour", reply);
}

代码示例来源：origin: apache/cxf

address = "http://localhost:" + PORT + "/SoapContext/SoapPortWithGzip";
Endpoint ep2 = Endpoint.publish(address, implementor);
((EndpointImpl)ep2).getService().getInInterceptors().add(new GZIPInInterceptor());
((EndpointImpl)ep2).getService().getOutInterceptors().add(new GZIPOutInterceptor());
eps.add(ep2);