You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2014/10/24 09:52:19 UTC
git commit: CAMEL-7848 Added the test file which I forgot to commit
Repository: camel
Updated Branches:
refs/heads/master 5f23cb4d2 -> 393ad7598
CAMEL-7848 Added the test file which I forgot to commit
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/393ad759
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/393ad759
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/393ad759
Branch: refs/heads/master
Commit: 393ad759843b5b7595e91fc0c2500d1082bb35f1
Parents: 5f23cb4
Author: Willem Jiang <wi...@gmail.com>
Authored: Fri Oct 24 15:52:04 2014 +0800
Committer: Willem Jiang <wi...@gmail.com>
Committed: Fri Oct 24 15:52:04 2014 +0800
----------------------------------------------------------------------
.../netty4/http/NettyHttpCompressTest.java | 71 ++++++++++++++++++++
1 file changed, 71 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/393ad759/components/camel-netty4-http/src/test/java/org/apache/camel/component/netty4/http/NettyHttpCompressTest.java
----------------------------------------------------------------------
diff --git a/components/camel-netty4-http/src/test/java/org/apache/camel/component/netty4/http/NettyHttpCompressTest.java b/components/camel-netty4-http/src/test/java/org/apache/camel/component/netty4/http/NettyHttpCompressTest.java
new file mode 100644
index 0000000..1697c75
--- /dev/null
+++ b/components/camel-netty4-http/src/test/java/org/apache/camel/component/netty4/http/NettyHttpCompressTest.java
@@ -0,0 +1,71 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.camel.component.netty4.http;
+
+import java.nio.charset.Charset;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import io.netty.channel.ChannelHandler;
+import io.netty.handler.codec.http.HttpContentDecompressor;
+
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.impl.JndiRegistry;
+import org.junit.Test;
+
+public class NettyHttpCompressTest extends BaseNettyTest {
+
+ // setup the decompress decoder here
+ @Override
+ protected JndiRegistry createRegistry() throws Exception {
+ JndiRegistry registry = super.createRegistry();
+ List<ChannelHandler> decoders = new ArrayList<ChannelHandler>();
+ decoders.add(new HttpContentDecompressor());
+ registry.bind("myDecoders", decoders);
+ return registry;
+ }
+
+
+ @Test
+ public void testContentType() throws Exception {
+
+ byte[] data = "Hello World".getBytes(Charset.forName("UTF-8"));
+ Map<String, Object> headers = new HashMap<String, Object>();
+ headers.put("content-type", "text/plain; charset=\"UTF-8\"");
+ headers.put("Accept-Encoding", "compress, gzip");
+ String out = template.requestBodyAndHeaders("netty4-http:http://0.0.0.0:9001/foo?decoders=#myDecoders", data,
+ headers, String.class);
+ // The decoded out has some space to clean up.
+ assertEquals("Bye World", out.trim());
+
+
+
+ }
+
+ @Override
+ protected RouteBuilder createRouteBuilder() throws Exception {
+ return new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("netty4-http:http://0.0.0.0:9001/foo?compression=true")
+ .transform().constant("Bye World").setHeader("content-type").constant("text/plain; charset=\"UTF-8\"");
+ }
+ };
+ }
+}