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

GZIPInInterceptor介绍

[英]CXF interceptor that uncompresses those incoming messages that have "gzip" content-encoding. An instance of this class should be added as an in and inFault interceptor on clients that need to talk to a service that returns gzipped responses or on services that want to accept gzipped requests. For clients, you probably also want to use org.apache.cxf.transports.http.configuration.HTTPClientPolicy#setAcceptEncodingto let the server know you can handle compressed responses. To compress outgoing messages, see GZIPOutInterceptor. This class was originally based on one of the CXF samples (configuration_interceptor).
[中]

代码示例

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

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

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

public GZIPInInterceptor() {
  super(Phase.RECEIVE);
  addBefore(AttachmentInInterceptor.class.getName());
}

代码示例来源：origin: org.apache.cxf/cxf-core

public void handleMessage(Message message) throws Fault {
  if (isGET(message)) {
    return;
        if (isRequestor(message)) {

代码示例来源：origin: org.apache.cxf/cxf-rt-transports-common

if (isRequestor(message)) {

代码示例来源：origin: org.apache.cxf/cxf-rt-core

public void handleMessage(Message message) throws Fault {
  if (isGET(message)) {
    return;
        if (isRequestor(message)) {

代码示例来源：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.cxf/cxf-bundle-jaxrs

public void handleMessage(Message message) throws Fault {
  if (isGET(message)) {
    return;
        if (isRequestor(message)) {

代码示例来源：origin: org.apache.cxf/cxf-rt-transports-common

public GZIPInInterceptor() {
  super(Phase.RECEIVE);
  addBefore(AttachmentInInterceptor.class.getName());
}

代码示例来源：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: apache/cxf

public void handleMessage(Message message) throws Fault {
  if (isGET(message)) {
    return;
        if (isRequestor(message)) {

代码示例来源：origin: org.apache.cxf/cxf-core

public GZIPInInterceptor() {
  super(Phase.RECEIVE);
  addBefore(AttachmentInInterceptor.class.getName());
}

代码示例来源：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: org.apache.cxf/cxf-rt-core

public GZIPInInterceptor() {
  super(Phase.RECEIVE);
  addBefore(AttachmentInInterceptor.class.getName());
}

代码示例来源：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: org.apache.cxf/cxf-bundle-jaxrs

public GZIPInInterceptor() {
  super(Phase.RECEIVE);
  addBefore(AttachmentInInterceptor.class.getName());
}

代码示例来源：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);