5 files changed, 0 insertions, 694 deletions
diff --git a/openstack-client-connectors/jersey-connector/src/main/java/com/woorea/openstack/connector/JerseyConnector.java b/openstack-client-connectors/jersey-connector/src/main/java/com/woorea/openstack/connector/JerseyConnector.java
deleted file mode 100644
index 770b4d8..0000000
--- a/openstack-client-connectors/jersey-connector/src/main/java/com/woorea/openstack/connector/JerseyConnector.java
+++ /dev/null
@@ -1,119 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package com.woorea.openstack.connector;
-
-import java.util.List;
-import java.util.Map;
-import java.util.logging.Logger;
-
-import javax.ws.rs.core.MultivaluedMap;
-import javax.ws.rs.ext.ContextResolver;
-import javax.ws.rs.ext.Provider;
-
-import com.fasterxml.jackson.annotation.JsonRootName;
-import com.fasterxml.jackson.annotation.JsonInclude.Include;
-import com.fasterxml.jackson.databind.DeserializationFeature;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.fasterxml.jackson.databind.SerializationFeature;
-import com.fasterxml.jackson.jaxrs.json.JacksonJaxbJsonProvider;
-import com.sun.jersey.api.client.Client;
-import com.sun.jersey.api.client.ClientResponse;
-import com.sun.jersey.api.client.UniformInterfaceException;
-import com.sun.jersey.api.client.WebResource;
-import com.sun.jersey.api.client.config.ClientConfig;
-import com.sun.jersey.api.client.config.DefaultClientConfig;
-import com.sun.jersey.client.impl.ClientRequestImpl;
-import com.sun.jersey.core.header.OutBoundHeaders;
-import com.woorea.openstack.base.client.OpenStackClientConnector;
-import com.woorea.openstack.base.client.OpenStackRequest;
-import com.woorea.openstack.base.client.OpenStackResponse;
-import com.woorea.openstack.base.client.OpenStackResponseException;
-
-public class JerseyConnector implements OpenStackClientConnector {
-    
-    protected Client client = null;
-    protected boolean logPassword;
-    private JerseyLoggingFilter logger = new JerseyLoggingFilter(Logger.getLogger("os"));
-
-    public JerseyConnector() {
-        ClientConfig clientConfig = new DefaultClientConfig();
-        clientConfig.getClasses().add(JacksonJaxbJsonProvider.class);
-        clientConfig.getClasses().add(OpenStackObjectMapper.class);
-        client = Client.create(clientConfig);
-    }
-
-    @Override
-    public <T> OpenStackResponse request(OpenStackRequest<T> request) {
-        WebResource target = client.resource(request.endpoint()).path(request.path());
-        for(Map.Entry<String, List<Object> > entry : request.queryParams().entrySet()) {
-            for (Object o : entry.getValue()) {
-                target = target.queryParam(entry.getKey(), String.valueOf(o));
-            }
-        }
-        target.addFilter(logger);
-        MultivaluedMap<String, Object> headers = new OutBoundHeaders();
-        for(Map.Entry<String, List<Object>> h : request.headers().entrySet()) {
-            for(Object v : h.getValue()) {
-                headers.add(h.getKey(), v);
-            }
-        }
-        if(request.entity() != null && request.entity().getContentType() != null) {
-            headers.add("Content-Type", request.entity().getContentType());
-        } else {
-            headers.add("Content-Type", "application/json");
-        }
-        try {
-            ClientResponse response;
-            if (request.entity() != null && request.entity().getEntity() != null) {
-                response = target.getHeadHandler().handle(new ClientRequestImpl(target.getURI(), request.method().name(), request.entity().getEntity(), headers));
-            } else {
-                response = target.getHeadHandler().handle(new ClientRequestImpl(target.getURI(), request.method().name(), null, headers));
-            }
-            return new JerseyResponse(response);
-        } catch (UniformInterfaceException e) {
-            throw new OpenStackResponseException(e.getResponse().getClientResponseStatus().getReasonPhrase(), e.getResponse().getStatus());
-        }
-    }
-
-    @Provider
-    public static class OpenStackObjectMapper implements ContextResolver<ObjectMapper> {
-        static ObjectMapper DEFAULT_MAPPER;
-        static ObjectMapper WRAPPED_MAPPER;
-        static {
-            DEFAULT_MAPPER = new ObjectMapper();
-            DEFAULT_MAPPER.setSerializationInclusion(Include.NON_NULL);
-            DEFAULT_MAPPER.enable(SerializationFeature.INDENT_OUTPUT);
-            DEFAULT_MAPPER.enable(DeserializationFeature.ACCEPT_SINGLE_VALUE_AS_ARRAY);
-            DEFAULT_MAPPER.disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES);
-            DEFAULT_MAPPER.enable(DeserializationFeature.ACCEPT_EMPTY_STRING_AS_NULL_OBJECT);
-
-            WRAPPED_MAPPER = new ObjectMapper();
-            WRAPPED_MAPPER.setSerializationInclusion(Include.NON_NULL);
-            WRAPPED_MAPPER.enable(SerializationFeature.INDENT_OUTPUT);
-            WRAPPED_MAPPER.enable(SerializationFeature.WRAP_ROOT_VALUE);
-            WRAPPED_MAPPER.enable(DeserializationFeature.UNWRAP_ROOT_VALUE);
-            WRAPPED_MAPPER.enable(DeserializationFeature.ACCEPT_SINGLE_VALUE_AS_ARRAY);
-            WRAPPED_MAPPER.disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES);
-            WRAPPED_MAPPER.enable(DeserializationFeature.ACCEPT_EMPTY_STRING_AS_NULL_OBJECT);
-        }
-        
-        @Override
-        public ObjectMapper getContext(Class<?> type) {
-            return type.getAnnotation(JsonRootName.class) == null ? DEFAULT_MAPPER : WRAPPED_MAPPER;
-        }
-    }
-}
diff --git a/openstack-client-connectors/jersey-connector/src/main/java/com/woorea/openstack/connector/JerseyLoggingFilter.java b/openstack-client-connectors/jersey-connector/src/main/java/com/woorea/openstack/connector/JerseyLoggingFilter.java
deleted file mode 100644
index ffdeb83..0000000
--- a/openstack-client-connectors/jersey-connector/src/main/java/com/woorea/openstack/connector/JerseyLoggingFilter.java
+++ /dev/null
@@ -1,225 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * ONAP - SO
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-package com.woorea.openstack.connector;
-
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
-import java.util.List;
-import java.util.Map;
-import java.util.concurrent.atomic.AtomicLong;
-import java.util.logging.Logger;
-
-import com.sun.jersey.api.client.AbstractClientRequestAdapter;
-import com.sun.jersey.api.client.ClientHandlerException;
-import com.sun.jersey.api.client.ClientRequest;
-import com.sun.jersey.api.client.ClientRequestAdapter;
-import com.sun.jersey.api.client.ClientResponse;
-import com.sun.jersey.api.client.filter.ClientFilter;
-import com.sun.jersey.core.util.ReaderWriter;
-
-/**
- * A Jersey client filter that writes the request and response to a specified logger.
- */
-public class JerseyLoggingFilter extends ClientFilter {
-
-    private final AtomicLong counter = new AtomicLong(0);
-    private final Logger logger;
-
-    /**
-     * Constructor
-     * @param logger the logger to which the request and response are written.
-     */
-    public JerseyLoggingFilter(Logger logger) {
-        this.logger = logger;
-    }
-
-    @Override
-    public ClientResponse handle(ClientRequest request) throws ClientHandlerException {
-        long id = counter.incrementAndGet();
-        logRequest(id, request);
-        ClientResponse response = getNext().handle(request);
-        logResponse(id, response);
-        return response;
-    }
-
-    /**
-     * Logs a request.
-     * @param id the request id (counter)
-     * @param request the request
-     */
-    private void logRequest(long id, ClientRequest request) {
-        StringBuilder builder = new StringBuilder();
-
-        builder.append(String.valueOf(id));
-        builder.append(" * Client out-bound request\n");
-
-        builder.append(String.valueOf(id));
-        builder.append(" > ");
-        builder.append(request.getMethod());
-        builder.append(" ");
-        builder.append(request.getURI().toASCIIString());
-        builder.append("\n");
-
-        // Request headers
-
-        for (Map.Entry<String, List<Object>> entry : request.getHeaders().entrySet()) {
-            String header = entry.getKey();
-            List<Object> values = entry.getValue();
-
-            if (values.size() == 1) {
-                builder.append(String.valueOf(id));
-                builder.append(" > ");
-                builder.append(header);
-                builder.append(": ");
-                builder.append(ClientRequest.getHeaderValue(values.get(0)));
-                builder.append("\n");
-            } else {
-                StringBuilder buf = new StringBuilder();
-                boolean first = true;
-
-                for(Object value : values) {
-                    if (first) {
-                        first = false;
-                    } else {
-                        buf.append(",");
-                    }
-
-                    buf.append(ClientRequest.getHeaderValue(value));
-                }
-
-                builder.append(String.valueOf(id));
-                builder.append(" > ");
-                builder.append(header);
-                builder.append(": ");
-                builder.append(buf.toString());
-                builder.append("\n");
-            }
-        }
-
-        // Request body
-
-        if (request.getEntity() != null) {
-            request.setAdapter(new JerseyLoggingAdapter(request.getAdapter(), builder));
-        } else {
-            logger.info(builder.toString());
-        }
-    }
-
-    /**
-     * Logs a response.
-     * @param id the request id (counter)
-     * @param response the response
-     */
-    private void logResponse(long id, ClientResponse response) {
-        StringBuilder builder = new StringBuilder();
-
-        builder.append(String.valueOf(id));
-        builder.append(" * Client in-bound response\n");
-
-        builder.append(String.valueOf(id));
-        builder.append(" < ");
-        builder.append(String.valueOf(response.getStatus()));
-        builder.append("\n");
-
-        // Response headers
-
-        for (Map.Entry<String, List<String>> entry : response.getHeaders().entrySet()) {
-            String header = entry.getKey();
-            for (String value : entry.getValue()) {
-                builder.append(String.valueOf(id));
-                builder.append(" < ");
-                builder.append(header);
-                builder.append(": ");
-                builder.append(value).append("\n");
-            }
-        }
-
-        // Response body
-
-        ByteArrayOutputStream out = new ByteArrayOutputStream();
-        InputStream in = response.getEntityInputStream();
-        try {
-            ReaderWriter.writeTo(in, out);
-
-            byte[] requestEntity = out.toByteArray();
-            appendToBuffer(builder, requestEntity);
-            response.setEntityInputStream(new ByteArrayInputStream(requestEntity));
-        } catch (IOException ex) {
-            throw new ClientHandlerException(ex);
-        }
-
-        logger.info(builder.toString());
-    }
-
-    /**
-     * Appends bytes to the builder. If the bytes contain the password pattern,
-     * the password is obliterated.
-     * @param builder the builder
-     * @param bytes the bytes to append
-     */
-    private void appendToBuffer(StringBuilder builder, byte[] bytes) {
-        if (bytes.length != 0) {
-            String s = new String(bytes);
-            builder.append(s.replaceAll("\"password\".*:.*\"(.*)\"", "\"password\" : \"******\""));
-            builder.append("\n");
-        }
-    }
-
-    private class JerseyLoggingAdapter extends AbstractClientRequestAdapter {
-        private final StringBuilder builder;
-
-        JerseyLoggingAdapter(ClientRequestAdapter adapter, StringBuilder builder) {
-            super(adapter);
-            this.builder = builder;
-        }
-
-        @Override
-        public OutputStream adapt(ClientRequest request, OutputStream out) throws IOException {
-            return new JerseyLoggingOutputStream(getAdapter().adapt(request, out), builder);
-        }
-    }
-
-    private class JerseyLoggingOutputStream extends OutputStream {
-        private final OutputStream stream;
-        private final StringBuilder builder;
-        private final ByteArrayOutputStream logStream = new ByteArrayOutputStream();
-
-        JerseyLoggingOutputStream(OutputStream stream, StringBuilder builder) {
-            this.stream = stream;
-            this.builder = builder;
-        }
-
-        @Override
-        public void write(int value) throws IOException {
-            logStream.write(value);
-            stream.write(value);
-        }
-
-        @Override
-        public void close() throws IOException {
-            appendToBuffer(builder, logStream.toByteArray());
-            logger.info(builder.toString());
-            stream.close();
-        }
-    }
-}
-\ No newline at end of file
diff --git a/openstack-client-connectors/jersey-connector/src/main/java/com/woorea/openstack/connector/JerseyResponse.java b/openstack-client-connectors/jersey-connector/src/main/java/com/woorea/openstack/connector/JerseyResponse.java
deleted file mode 100644
index 5b01660..0000000
--- a/openstack-client-connectors/jersey-connector/src/main/java/com/woorea/openstack/connector/JerseyResponse.java
+++ /dev/null
@@ -1,82 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package com.woorea.openstack.connector;
-
-/*
- * Modifications copyright (c) 2017 AT&T Intellectual Property
- */
-
-import java.io.InputStream;
-import java.util.HashMap;
-import java.util.Map;
-
-import com.sun.jersey.api.client.ClientResponse;
-import com.woorea.openstack.base.client.OpenStackResponse;
-import com.woorea.openstack.base.client.OpenStackResponseException;
-
-public class JerseyResponse implements OpenStackResponse {
-
-    private ClientResponse response;
-
-    public JerseyResponse(ClientResponse response) {
-        this.response = response;
-    }
-
-    @Override
-    public <T> T getEntity(Class<T> returnType) {
-        if(response.getStatus() >= 400) {
-            throw new OpenStackResponseException(response.getClientResponseStatus().getReasonPhrase(), 
-                    response.getStatus(), this);
-        }
-        if(response.hasEntity() && returnType != null && Void.class != returnType) {
-            return response.getEntity(returnType);
-        } else {
-            return null;
-        }
-    }
-
-    @Override
-    public <T> T getErrorEntity(Class<T> returnType) {
-        if(response.getStatus() >= 400 && response.hasEntity()) {
-            return response.getEntity(returnType);
-        }
-        return null;
-    }
-
-    @Override
-    public InputStream getInputStream() {
-        if(response.hasEntity()) {
-            return response.getEntityInputStream();
-        } else {
-            return null;
-        }
-    }
-
-    @Override
-    public String header(String name) {
-        return response.getHeaders().getFirst(name);
-    }
-
-    @Override
-    public Map<String, String> headers() {
-        Map<String, String> headers = new HashMap<>();
-        for(String k : response.getHeaders().keySet()) {
-            headers.put(k, response.getHeaders().getFirst(k));
-        }
-        return headers;
-    }
-}
diff --git a/openstack-client-connectors/jersey-connector/src/main/resources/META-INF/services/com.woorea.openstack.base.client.OpenStackClientConnector b/openstack-client-connectors/jersey-connector/src/main/resources/META-INF/services/com.woorea.openstack.base.client.OpenStackClientConnector
deleted file mode 100644
index 5b9a158..0000000
--- a/openstack-client-connectors/jersey-connector/src/main/resources/META-INF/services/com.woorea.openstack.base.client.OpenStackClientConnector
+++ /dev/null
@@ -1 +0,0 @@
-com.woorea.openstack.connector.JerseyConnector
-\ No newline at end of file
diff --git a/openstack-client-connectors/jersey-connector/src/test/java/com/woorea/openstack/connector/JerseyLoggingFilterTest.java b/openstack-client-connectors/jersey-connector/src/test/java/com/woorea/openstack/connector/JerseyLoggingFilterTest.java
deleted file mode 100644
index 3ebad7c..0000000
--- a/openstack-client-connectors/jersey-connector/src/test/java/com/woorea/openstack/connector/JerseyLoggingFilterTest.java
+++ /dev/null
@@ -1,267 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * ONAP - SO
- * ================================================================================
- * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
- * ================================================================================ 
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package com.woorea.openstack.connector;
-
-import static org.junit.Assert.assertTrue;
-import static org.mockito.Matchers.any;
-import static org.mockito.Mockito.doCallRealMethod;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.when;
-
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.io.OutputStream;
-import java.lang.reflect.Method;
-import java.net.URI;
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.List;
-import java.util.logging.ConsoleHandler;
-import java.util.logging.Level;
-import java.util.logging.LogRecord;
-import java.util.logging.Logger;
-import java.util.logging.SimpleFormatter;
-
-import javax.ws.rs.core.MultivaluedMap;
-
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.mockito.invocation.InvocationOnMock;
-import org.mockito.stubbing.Answer;
-
-import com.sun.jersey.api.client.ClientHandler;
-import com.sun.jersey.api.client.ClientRequest;
-import com.sun.jersey.api.client.ClientRequestAdapter;
-import com.sun.jersey.api.client.ClientResponse;
-import com.sun.jersey.api.client.filter.ClientFilter;
-
-public class JerseyLoggingFilterTest {
-
-    private static Logger logger;
-    private static LogFormatter logFormatter;
-    
-    @BeforeClass
-    public static void setUpClass() throws Exception {
-        logger = Logger.getLogger(JerseyLoggingFilterTest.class.getSimpleName());
-        logger.setLevel(Level.ALL);
-        logger.setUseParentHandlers(false);
-
-        ConsoleHandler handler = new ConsoleHandler();
-        logFormatter = new LogFormatter();
-        handler.setFormatter(logFormatter);
-        handler.setLevel(Level.ALL);
-        logger.addHandler(handler);
-    }
-
-    @Before
-    public void setUpTest() {
-        logFormatter.clearLog();
-    }
-    
-    /**
-     * Tests a scenario with no request content (GET).
-     * @throws Exception for unexpected errors
-     */
-    @Test
-    public void testGET() throws Exception {
-        String responseContent = "<response>Hello, I am Eliza.</response>";
-        execute("GET", "http://www.onap.org/eliza", null, responseContent);
-    }
-    
-    /**
-     * Tests a scenario with request content (POST).
-     * @throws Exception for unexpected errors
-     */
-    @Test
-    public void testPOST() throws Exception {
-        String requestContent = "<request>I feel sad.</request>";
-        String responseContent = "<response>Do you often feel sad?</response>";
-        execute("POST", "http://www.onap.org/eliza", requestContent, responseContent);
-    }
-
-    /**
-     * Runs a single test.
-     * @param httpMethod any HTTP method (POST, GET, ...)
-     * @param url any URL
-     * @param requestContent mock request content, possibly null
-     * @param responseContent mock response content, never null
-     * @throws Exception for unexpected errors
-     */
-    private void execute(String httpMethod, String url, String requestContent, String responseContent)
-            throws Exception {
-        JerseyLoggingFilter loggingFilter = new JerseyLoggingFilter(logger);
-
-        // Mock multi-valued and single valued request headers
-
-        HashMap<String, List<Object>> requestHeaderMap = new HashMap<>();
-        requestHeaderMap.put("Accept", Arrays.asList(new Object[]{"application/xml","application/json"}));
-
-        if (requestContent != null) {
-            requestHeaderMap.put("Content-Type", Arrays.asList(new Object[]{"application/xml"}));
-            requestHeaderMap.put("Content-Length", Arrays.asList(new Object[]{String.valueOf(requestContent.length())}));
-        }
-
-        @SuppressWarnings("unchecked")
-        MultivaluedMap<String, Object> requestHeaders = mock(MultivaluedMap.class);
-        when(requestHeaders.entrySet()).thenReturn(requestHeaderMap.entrySet());
-
-        // Mock the request object
-
-        ClientRequest request = mock(TestClientRequest.class);
-        when(request.getURI()).thenReturn(new URI(url));
-        when(request.getMethod()).thenReturn(httpMethod);
-        when(request.getHeaders()).thenReturn(requestHeaders);
-
-        if (requestContent != null) {
-            when(request.getEntity()).thenReturn(requestContent.getBytes("UTF-8"));
-        }
-
-        doCallRealMethod().when(request).setAdapter(any(ClientRequestAdapter.class));
-        when(request.getAdapter()).thenCallRealMethod();
-        request.setAdapter(new DefaultClientRequestAdapter());
-
-        // Mock multi-valued and single valued response headers
-
-        HashMap<String, List<String>> responseHeaderMap = new HashMap<>();
-        responseHeaderMap.put("Cache-Control", Arrays.asList(new String[]{"no-cache","no-store"}));
-        responseHeaderMap.put("Content-Type", Arrays.asList(new String[]{"application/xml"}));
-        responseHeaderMap.put("Content-Length", Arrays.asList(new String[]{String.valueOf(responseContent.length())}));
-        @SuppressWarnings("unchecked")
-        MultivaluedMap<String, String> responseHeaders = mock(MultivaluedMap.class);
-        when(responseHeaders.entrySet()).thenReturn(responseHeaderMap.entrySet());
-
-        // Mock the response object
-
-        ClientResponse response = mock(ClientResponse.class);
-        when(response.getStatus()).thenReturn(200);
-        when(response.getHeaders()).thenReturn(responseHeaders);
-        when(response.getEntityInputStream()).thenReturn(
-                new ByteArrayInputStream(responseContent.getBytes("UTF-8")));
-
-        // Mock a handler that returns the response object and set
-        // it to be the next filter after the logging filter.
-
-        ClientFilter handler = mock(ClientFilter.class);
-        when(handler.handle(request)).then(produceResponse(response));
-        Method setNext = ClientFilter.class.getDeclaredMethod("setNext", new Class<?>[]{ClientHandler.class});
-        setNext.setAccessible(true);
-        setNext.invoke(loggingFilter, new Object[]{handler});
-
-        // Run the request into the logging filter
-
-        loggingFilter.handle(request);
-
-        // Validate resulting the log content
-
-        String log = logFormatter.getLog();
-
-        assertContains(log, "* Client out-bound request");
-        assertContains(log, "> " + httpMethod + " " + url);
-
-        for (String header : requestHeaderMap.keySet()) {
-            assertContains(log, "> " + header + ": ");
-        }
-
-        if (requestContent != null) {
-            assertContains(log, requestContent);
-        }
-
-        assertContains(log, "* Client in-bound response");
-        assertContains(log, "< 200");
-
-        for (String header : responseHeaderMap.keySet()) {
-            assertContains(log, "< " + header + ": ");
-        }
-
-        assertContains(log, responseContent);
-    }
-    
-    private void assertContains(String log, String expect) {
-        assertTrue("Log does not contain '" + expect + "'", log.contains(expect));
-    }
-
-    private class DefaultClientRequestAdapter implements ClientRequestAdapter {
-        @Override
-        public OutputStream adapt(ClientRequest request, OutputStream out) throws IOException {
-            return out;
-        }
-    }
-
-    private abstract class TestClientRequest extends ClientRequest {
-        private ClientRequestAdapter adapter;
-
-        @Override
-        public ClientRequestAdapter getAdapter() {
-            return adapter;
-        }
-
-        @Override
-        public void setAdapter(ClientRequestAdapter adapter) {
-            this.adapter = adapter;
-        }
-    }
-    
-    private Answer<ClientResponse> produceResponse(final ClientResponse response) { 
-        return new Answer<ClientResponse>() {
-            public ClientResponse answer(InvocationOnMock invocation) throws IOException {
-                ClientRequest request = (ClientRequest) invocation.getArguments()[0];
-                byte[] entity = (byte[]) request.getEntity();
-
-                if (entity != null) {
-                    ClientRequestAdapter adapter = request.getAdapter();
-    
-                    OutputStream nullOutputStream = new OutputStream() {
-                        @Override
-                        public void write(int b) {
-                            // Discard
-                        }
-                    };
-
-                    OutputStream outputStream = adapter.adapt(request, nullOutputStream);
-                    outputStream.write(entity);
-                    outputStream.close();
-                }
-
-                return response;
-            }
-        };
-    }
-
-    private static class LogFormatter extends SimpleFormatter {
-        StringBuilder buffer = new StringBuilder();
-
-        public synchronized String getLog() {
-            return buffer.toString();
-        }
-
-        public synchronized void clearLog() {
-            buffer.setLength(0);
-        }
-
-        @Override
-        public synchronized String format(LogRecord record) {
-            String logData = super.format(record);
-            buffer.append(logData);
-            return logData;
-        }
-    }
-}
-\ No newline at end of file