You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commons-dev@ws.apache.org by ve...@apache.org on 2009/06/07 22:20:38 UTC
svn commit: r782451 - in
/webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine:
GZIPCompressedEntity.java InterceptorTestBase.java TestHttpHandler.java
Author: veithen
Date: Sun Jun 7 20:20:37 2009
New Revision: 782451
URL: http://svn.apache.org/viewvc?rev=782451&view=rev
Log:
Added test case for gzip encoding.
Added:
webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/GZIPCompressedEntity.java (with props)
Modified:
webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/InterceptorTestBase.java
webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/TestHttpHandler.java
Added: webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/GZIPCompressedEntity.java
URL: http://svn.apache.org/viewvc/webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/GZIPCompressedEntity.java?rev=782451&view=auto
==============================================================================
--- webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/GZIPCompressedEntity.java (added)
+++ webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/GZIPCompressedEntity.java Sun Jun 7 20:20:37 2009
@@ -0,0 +1,56 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * 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.
+ */
+
+package org.apache.ws.commons.tcpmon.core.engine;
+
+import java.io.IOException;
+import java.io.OutputStream;
+import java.util.zip.GZIPOutputStream;
+
+import org.apache.commons.io.IOUtils;
+import org.apache.http.Header;
+import org.apache.http.HttpEntity;
+import org.apache.http.entity.HttpEntityWrapper;
+import org.apache.http.message.BasicHeader;
+import org.apache.http.protocol.HTTP;
+
+public class GZIPCompressedEntity extends HttpEntityWrapper {
+ public GZIPCompressedEntity(HttpEntity entity) {
+ super(entity);
+ }
+
+ @Override
+ public Header getContentEncoding() {
+ return new BasicHeader(HTTP.CONTENT_ENCODING, "gzip");
+ }
+
+ @Override
+ public long getContentLength() {
+ return -1;
+ }
+
+ @Override
+ public boolean isChunked() {
+ return true;
+ }
+
+ @Override
+ public void writeTo(OutputStream out) throws IOException {
+ OutputStream compressed = new GZIPOutputStream(out);
+ IOUtils.copy(wrappedEntity.getContent(), compressed);
+ compressed.close();
+ }
+}
Propchange: webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/GZIPCompressedEntity.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/InterceptorTestBase.java
URL: http://svn.apache.org/viewvc/webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/InterceptorTestBase.java?rev=782451&r1=782450&r2=782451&view=diff
==============================================================================
--- webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/InterceptorTestBase.java (original)
+++ webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/InterceptorTestBase.java Sun Jun 7 20:20:37 2009
@@ -78,6 +78,14 @@
assertEquals("test", TestUtil.getResponseAsString(response));
}
+ public void testPostWithGzip() throws Exception {
+ HttpPost request = new HttpPost(baseUri + "/echo");
+ request.setEntity(new GZIPCompressedEntity(new StringEntity("test")));
+ HttpResponse response = client.execute(request);
+ assertEquals(200, response.getStatusLine().getStatusCode());
+ assertEquals("test", TestUtil.getResponseAsString(response));
+ }
+
public void testGetWithKeepAlive() throws Exception {
HttpGet request = new HttpGet(baseUri + "/test");
HttpResponse response = client.execute(request);
Modified: webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/TestHttpHandler.java
URL: http://svn.apache.org/viewvc/webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/TestHttpHandler.java?rev=782451&r1=782450&r2=782451&view=diff
==============================================================================
--- webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/TestHttpHandler.java (original)
+++ webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/test/java/org/apache/ws/commons/tcpmon/core/engine/TestHttpHandler.java Sun Jun 7 20:20:37 2009
@@ -17,10 +17,12 @@
package org.apache.ws.commons.tcpmon.core.engine;
import java.io.IOException;
+import java.io.InputStream;
import java.io.OutputStreamWriter;
import java.io.Writer;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
+import java.util.zip.GZIPInputStream;
import org.apache.commons.io.IOUtils;
import org.mortbay.http.HttpException;
@@ -59,6 +61,10 @@
}
public void echo(HttpRequest request, HttpResponse response) throws IOException {
- IOUtils.copy(request.getInputStream(), response.getOutputStream());
+ InputStream in = request.getInputStream();
+ if ("gzip".equals(request.getField("Content-Encoding"))) {
+ in = new GZIPInputStream(in);
+ }
+ IOUtils.copy(in, response.getOutputStream());
}
}