camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ioca...@apache.org
Subject svn commit: r1240351 [1/2] - in /camel/trunk: camel-core/src/main/java/org/apache/camel/builder/ camel-core/src/main/java/org/apache/camel/model/ camel-core/src/main/java/org/apache/camel/model/dataformat/ camel-core/src/main/resources/org/apache/camel...
Date Fri, 03 Feb 2012 21:41:16 GMT
Author: iocanel
Date: Fri Feb  3 21:41:13 2012
New Revision: 1240351

URL: http://svn.apache.org/viewvc?rev=1240351&view=rev
Log:
Merge branch 'trunk' of git://git.apache.org/camel into trunk-avro

Conflicts:
	components/pom.xml

Added:
    camel/trunk/camel-core/src/main/java/org/apache/camel/model/dataformat/AvroDataFormat.java
    camel/trunk/components/camel-avro/
    camel/trunk/components/camel-avro/pom.xml
    camel/trunk/components/camel-avro/src/
    camel/trunk/components/camel-avro/src/main/
    camel/trunk/components/camel-avro/src/main/java/
    camel/trunk/components/camel-avro/src/main/java/org/
    camel/trunk/components/camel-avro/src/main/java/org/apache/
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroComponent.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroConfiguration.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroConstants.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroConsumer.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroEndpoint.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpConsumer.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpEndpoint.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpProducer.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyConsumer.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyEndpoint.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyProducer.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroProducer.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroRequestor.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroResponder.java
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/dataformat/
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/dataformat/avro/
    camel/trunk/components/camel-avro/src/main/java/org/apache/camel/dataformat/avro/AvroDataFormat.java
    camel/trunk/components/camel-avro/src/main/resources/
    camel/trunk/components/camel-avro/src/main/resources/META-INF/
    camel/trunk/components/camel-avro/src/main/resources/META-INF/services/
    camel/trunk/components/camel-avro/src/main/resources/META-INF/services/org/
    camel/trunk/components/camel-avro/src/main/resources/META-INF/services/org/apache/
    camel/trunk/components/camel-avro/src/main/resources/META-INF/services/org/apache/camel/
    camel/trunk/components/camel-avro/src/main/resources/META-INF/services/org/apache/camel/component/
    camel/trunk/components/camel-avro/src/main/resources/META-INF/services/org/apache/camel/component/avro
    camel/trunk/components/camel-avro/src/main/resources/META-INF/services/org/apache/camel/dataformat/
    camel/trunk/components/camel-avro/src/main/resources/META-INF/services/org/apache/camel/dataformat/avro
    camel/trunk/components/camel-avro/src/test/
    camel/trunk/components/camel-avro/src/test/avro/
    camel/trunk/components/camel-avro/src/test/avro/test.avpr
    camel/trunk/components/camel-avro/src/test/java/
    camel/trunk/components/camel-avro/src/test/java/org/
    camel/trunk/components/camel-avro/src/test/java/org/apache/
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/Key.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/KeyValueProtocol.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/Value.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/impl/
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/impl/KeyValueProtocolImpl.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroConsumerTestSupport.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroHttpConsumerTest.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroHttpProducerTest.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroHttpSpringProducerTest.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroNettyConsumerTest.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroNettyProducerTest.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroNettySpringConsumerTest.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroNettySpringProducerTest.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroProducerTestSupport.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroTestSupport.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/processors/
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/processors/GetProcessor.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/processors/PutProcessor.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/dataformat/
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/dataformat/avro/
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/dataformat/avro/AvroMarshalAndUnmarshalSpringTest.java
    camel/trunk/components/camel-avro/src/test/java/org/apache/camel/dataformat/avro/AvroMarshalAndUnmarshallTest.java
    camel/trunk/components/camel-avro/src/test/resources/
    camel/trunk/components/camel-avro/src/test/resources/org/
    camel/trunk/components/camel-avro/src/test/resources/org/apache/
    camel/trunk/components/camel-avro/src/test/resources/org/apache/camel/
    camel/trunk/components/camel-avro/src/test/resources/org/apache/camel/component/
    camel/trunk/components/camel-avro/src/test/resources/org/apache/camel/component/avro/
    camel/trunk/components/camel-avro/src/test/resources/org/apache/camel/component/avro/avro-http-consumer.xml
    camel/trunk/components/camel-avro/src/test/resources/org/apache/camel/component/avro/avro-http-producer.xml
    camel/trunk/components/camel-avro/src/test/resources/org/apache/camel/component/avro/avro-netty-consumer.xml
    camel/trunk/components/camel-avro/src/test/resources/org/apache/camel/component/avro/avro-netty-producer.xml
    camel/trunk/components/camel-avro/src/test/resources/org/apache/camel/dataformat/
    camel/trunk/components/camel-avro/src/test/resources/org/apache/camel/dataformat/avro/
    camel/trunk/components/camel-avro/src/test/resources/org/apache/camel/dataformat/avro/springDataFormat.xml
Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/builder/DataFormatClause.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/model/MarshalDefinition.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/model/UnmarshalDefinition.java
    camel/trunk/camel-core/src/main/resources/org/apache/camel/model/dataformat/jaxb.index
    camel/trunk/components/pom.xml
    camel/trunk/parent/pom.xml
    camel/trunk/platforms/karaf/features/src/main/resources/features.xml

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/builder/DataFormatClause.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/builder/DataFormatClause.java?rev=1240351&r1=1240350&r2=1240351&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/builder/DataFormatClause.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/builder/DataFormatClause.java Fri Feb  3 21:41:13 2012
@@ -23,6 +23,7 @@ import org.w3c.dom.Node;
 
 import org.apache.camel.model.DataFormatDefinition;
 import org.apache.camel.model.ProcessorDefinition;
+import org.apache.camel.model.dataformat.AvroDataFormat;
 import org.apache.camel.model.dataformat.BindyDataFormat;
 import org.apache.camel.model.dataformat.BindyType;
 import org.apache.camel.model.dataformat.CastorDataFormat;
@@ -71,6 +72,24 @@ public class DataFormatClause<T extends 
         this.operation = operation;
     }
 
+
+    /**
+     * Uses the Avro data format
+     */
+    public T avro() {
+        return dataFormat(new AvroDataFormat());
+    }
+
+    public T avro(Object schema) {
+        AvroDataFormat dataFormat = new AvroDataFormat();
+        dataFormat.setSchema(schema);
+        return dataFormat(dataFormat);
+    }
+
+    public T avro(String instanceClassName) {
+        return dataFormat(new AvroDataFormat(instanceClassName));
+    }
+
     /**
      * Uses the Bindy data format
      *

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/model/MarshalDefinition.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/model/MarshalDefinition.java?rev=1240351&r1=1240350&r2=1240351&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/model/MarshalDefinition.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/model/MarshalDefinition.java Fri Feb  3 21:41:13 2012
@@ -24,6 +24,7 @@ import javax.xml.bind.annotation.XmlElem
 import javax.xml.bind.annotation.XmlRootElement;
 
 import org.apache.camel.Processor;
+import org.apache.camel.model.dataformat.AvroDataFormat;
 import org.apache.camel.model.dataformat.BindyDataFormat;
 import org.apache.camel.model.dataformat.CastorDataFormat;
 import org.apache.camel.model.dataformat.CryptoDataFormat;
@@ -67,6 +68,7 @@ public class MarshalDefinition extends N
     private String ref;
     // cannot use @XmlElementRef as it doesn't allow optional properties
     @XmlElements({
+    @XmlElement(required = false, name = "avro", type = AvroDataFormat.class),
     @XmlElement(required = false, name = "bindy", type = BindyDataFormat.class),
     @XmlElement(required = false, name = "castor", type = CastorDataFormat.class),
     @XmlElement(required = false, name = "crypto", type = CryptoDataFormat.class),

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/model/UnmarshalDefinition.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/model/UnmarshalDefinition.java?rev=1240351&r1=1240350&r2=1240351&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/model/UnmarshalDefinition.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/model/UnmarshalDefinition.java Fri Feb  3 21:41:13 2012
@@ -24,6 +24,7 @@ import javax.xml.bind.annotation.XmlElem
 import javax.xml.bind.annotation.XmlRootElement;
 
 import org.apache.camel.Processor;
+import org.apache.camel.model.dataformat.AvroDataFormat;
 import org.apache.camel.model.dataformat.BindyDataFormat;
 import org.apache.camel.model.dataformat.CastorDataFormat;
 import org.apache.camel.model.dataformat.CryptoDataFormat;
@@ -67,6 +68,7 @@ public class UnmarshalDefinition extends
     private String ref;
     // cannot use @XmlElementRef as it doesn't allow optional properties
     @XmlElements({
+    @XmlElement(required = false, name = "avro", type = AvroDataFormat.class),
     @XmlElement(required = false, name = "bindy", type = BindyDataFormat.class),
     @XmlElement(required = false, name = "castor", type = CastorDataFormat.class),
     @XmlElement(required = false, name = "crypto", type = CryptoDataFormat.class),

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/model/dataformat/AvroDataFormat.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/model/dataformat/AvroDataFormat.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/model/dataformat/AvroDataFormat.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/model/dataformat/AvroDataFormat.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,74 @@
+/**
+ * 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.model.dataformat;
+
+import javax.xml.bind.annotation.XmlAccessType;
+import javax.xml.bind.annotation.XmlAccessorType;
+import javax.xml.bind.annotation.XmlAttribute;
+import javax.xml.bind.annotation.XmlRootElement;
+import javax.xml.bind.annotation.XmlTransient;
+import org.apache.camel.model.DataFormatDefinition;
+import org.apache.camel.spi.DataFormat;
+
+/**
+ * Represents a avro DataFormat {@link org.apache.camel.spi.DataFormat}
+ *
+ * @version 
+ */
+@XmlRootElement(name = "avro")
+@XmlAccessorType(XmlAccessType.FIELD)
+public class AvroDataFormat extends DataFormatDefinition {
+    @XmlAttribute
+    private String instanceClassName;
+    @XmlTransient
+    private Object schema;
+
+    public AvroDataFormat() {
+        super("avro");
+    }
+
+    public AvroDataFormat(String instanceClassName) {
+        this();
+        setInstanceClassName(instanceClassName);
+    }
+
+    public String getInstanceClassName() {
+        return instanceClassName;
+    }
+
+    public void setInstanceClassName(String instanceClassName) {
+        this.instanceClassName = instanceClassName;
+    }
+
+    public Object getSchema() {
+        return schema;
+    }
+
+    public void setSchema(Object schema) {
+        this.schema = schema;
+    }
+
+    @Override
+    protected void configureDataFormat(DataFormat dataFormat) {
+        if (this.instanceClassName != null) {
+            setProperty(dataFormat, "instanceClass", instanceClassName);
+        }
+        if (this.schema != null) {
+            setProperty(dataFormat, "schema", schema);
+        }
+    }
+}

Modified: camel/trunk/camel-core/src/main/resources/org/apache/camel/model/dataformat/jaxb.index
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/resources/org/apache/camel/model/dataformat/jaxb.index?rev=1240351&r1=1240350&r2=1240351&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/resources/org/apache/camel/model/dataformat/jaxb.index (original)
+++ camel/trunk/camel-core/src/main/resources/org/apache/camel/model/dataformat/jaxb.index Fri Feb  3 21:41:13 2012
@@ -14,6 +14,7 @@
 ## See the License for the specific language governing permissions and
 ## limitations under the License.
 ## ------------------------------------------------------------------------
+AvroDataFormat
 BindyDataFormat
 BindyType
 CastorDataFormat

Added: camel/trunk/components/camel-avro/pom.xml
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/pom.xml?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/pom.xml (added)
+++ camel/trunk/components/camel-avro/pom.xml Fri Feb  3 21:41:13 2012
@@ -0,0 +1,91 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <groupId>org.apache.camel</groupId>
+        <artifactId>camel-parent</artifactId>
+        <version>2.10-SNAPSHOT</version>
+        <relativePath>../../parent</relativePath>
+    </parent>
+
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>org.apache.camel</groupId>
+    <artifactId>camel-avro</artifactId>
+    <packaging>bundle</packaging>
+    <name>Camel :: Avro</name>
+
+    <properties>
+        <camel.osgi.export.pkg>org.apache.camel.dataformat.avro*,org.apache.camel.component.avro*</camel.osgi.export.pkg>
+    </properties>
+
+    <build>
+        <plugins>
+            <!--plugin>
+                <groupId>org.apache.avro</groupId>
+                <artifactId>avro-maven-plugin</artifactId>
+                <version>${avro-version}</version>
+                <executions>
+                    <execution>
+                        <id>schemas</id>
+                        <phase>generate-sources</phase>
+                        <goals>
+                            <goal>schema</goal>
+                            <goal>protocol</goal>
+                            <goal>idl-protocol</goal>
+                        </goals>
+                        <configuration>
+                            <sourceDirectory>${project.basedir}/src/test/avro/</sourceDirectory>
+                            <outputDirectory>${project.basedir}/src/test/java/</outputDirectory>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin-->
+        </plugins>
+    </build>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.avro</groupId>
+            <artifactId>avro</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.avro</groupId>
+            <artifactId>avro-ipc</artifactId>
+        </dependency>
+
+        <!-- testing -->
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-juel</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-spring</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-log4j12</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+
+</project>
\ No newline at end of file

Added: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroComponent.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroComponent.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroComponent.java (added)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroComponent.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,88 @@
+/**
+ * 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.avro;
+
+import java.lang.reflect.Field;
+import java.net.URI;
+import java.util.Map;
+import org.apache.avro.Protocol;
+import org.apache.camel.CamelContext;
+import org.apache.camel.Endpoint;
+import org.apache.camel.impl.DefaultComponent;
+import org.apache.camel.util.URISupport;
+
+public class AvroComponent extends DefaultComponent {
+
+    private AvroConfiguration configuration;
+
+    public AvroComponent() {
+    }
+
+    public AvroComponent(CamelContext context) {
+        super(context);
+    }
+
+
+    /**
+     * A factory method allowing derived components to create a new endpoint
+     * from the given URI, remaining path and optional parameters
+     *
+     * @param uri        the full URI of the endpoint
+     * @param remaining  the remaining part of the URI without the query
+     *                   parameters or component prefix
+     * @param parameters the optional parameters passed in
+     * @return a newly created endpoint or null if the endpoint cannot be
+     *         created based on the inputs
+     */
+    @Override
+    protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
+        AvroConfiguration config;
+        if (configuration != null) {
+            config = configuration.copy();
+        } else {
+            config = new AvroConfiguration();
+        }
+        URI enpointUri = new URI(URISupport.normalizeUri(remaining));
+        config.parseURI(enpointUri, parameters, this);
+        setProperties(config, parameters);
+
+        if (config.getProtocol() == null && config.getProtocolClassName() != null) {
+            Class<?> protocolClass = getCamelContext().getClassResolver().resolveClass(config.getProtocolClassName());
+            Field f = protocolClass.getField("PROTOCOL");
+            Protocol protocol = (Protocol) f.get(null);
+            config.setProtocol(protocol);
+        }
+
+        if (AvroConstants.AVRO_NETTY_TRANSPORT.equals(enpointUri.getScheme())) {
+            return new AvroNettyEndpoint(remaining, this, config);
+        } else if (AvroConstants.AVRO_HTTP_TRANSPORT.equals(enpointUri.getScheme())) {
+            return new AvroHttpEndpoint(remaining, this, config);
+        } else {
+            throw new IllegalArgumentException("Unknown avro scheme. Should use either netty or http.");
+        }
+    }
+
+
+    public AvroConfiguration getConfiguration() {
+        return configuration;
+    }
+
+    public void setConfiguration(AvroConfiguration configuration) {
+        this.configuration = configuration;
+    }
+}

Added: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroConfiguration.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroConfiguration.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroConfiguration.java (added)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroConfiguration.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,102 @@
+/**
+ * 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.avro;
+
+import java.net.URI;
+import java.util.Map;
+import org.apache.avro.Protocol;
+import org.apache.camel.RuntimeCamelException;
+
+public class AvroConfiguration implements Cloneable {
+
+    private String host;
+    private int port;
+    private Protocol protocol;
+    private String protocolLocation;
+    private String protocolClassName;
+    private String transport;
+
+
+    public AvroConfiguration copy() {
+        try {
+            AvroConfiguration answer = (AvroConfiguration) clone();
+            return answer;
+        } catch (CloneNotSupportedException e) {
+            throw new RuntimeCamelException(e);
+        }
+    }
+
+    public void parseURI(URI uri, Map<String, Object> parameters, AvroComponent component) throws Exception {
+        transport = uri.getScheme();
+
+        if ((!transport.equalsIgnoreCase("http")) && (!transport.equalsIgnoreCase("netty"))) {
+            throw new IllegalArgumentException("Unrecognized Avro IPC transport: " + protocol + " for uri: " + uri);
+        }
+
+        setHost(uri.getHost());
+        setPort(uri.getPort());
+    }
+
+    public String getHost() {
+        return host;
+    }
+
+    public void setHost(String host) {
+        this.host = host;
+    }
+
+    public int getPort() {
+        return port;
+    }
+
+    public void setPort(int port) {
+        this.port = port;
+    }
+
+    public Protocol getProtocol() {
+        return protocol;
+    }
+
+    public void setProtocol(Protocol protocol) {
+        this.protocol = protocol;
+    }
+
+    public String getTransport() {
+        return transport;
+    }
+
+    public void setTransport(String transport) {
+        this.transport = transport;
+    }
+
+    public String getProtocolLocation() {
+        return protocolLocation;
+    }
+
+    public void setProtocolLocation(String protocolLocation) {
+        this.protocolLocation = protocolLocation;
+    }
+
+    public String getProtocolClassName() {
+        return protocolClassName;
+    }
+
+    public void setProtocolClassName(String protocolClassName) {
+        this.protocolClassName = protocolClassName;
+    }
+}

Added: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroConstants.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroConstants.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroConstants.java (added)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroConstants.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,31 @@
+/**
+ * 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.avro;
+
+public final class AvroConstants {
+
+
+    public static final transient String AVRO_NETTY_TRANSPORT = "netty";
+    public static final transient String AVRO_HTTP_TRANSPORT = "http";
+
+    public static final transient String AVRO_MESSAGE_NAME = "CamelAvroMessageName";
+
+    private AvroConstants() {
+        // Utility class
+    }
+}

Added: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroConsumer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroConsumer.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroConsumer.java (added)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroConsumer.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,38 @@
+/**
+ * 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.avro;
+
+import org.apache.camel.Endpoint;
+import org.apache.camel.Processor;
+import org.apache.camel.impl.DefaultConsumer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public abstract class AvroConsumer extends DefaultConsumer {
+
+    private static final Logger LOG = LoggerFactory.getLogger(AvroConsumer.class);
+
+    public AvroConsumer(Endpoint endpoint, Processor processor) {
+        super(endpoint, processor);
+    }
+
+    @Override
+    public AvroEndpoint getEndpoint() {
+        return (AvroEndpoint) super.getEndpoint();
+    }
+}

Added: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroEndpoint.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroEndpoint.java (added)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroEndpoint.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,75 @@
+/**
+ * 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.avro;
+
+import org.apache.avro.Protocol;
+import org.apache.avro.Schema;
+import org.apache.camel.Component;
+import org.apache.camel.Exchange;
+import org.apache.camel.ExchangePattern;
+import org.apache.camel.impl.DefaultEndpoint;
+
+public abstract class AvroEndpoint extends DefaultEndpoint {
+
+    private AvroConfiguration configuration;
+    private boolean sync;
+
+
+    /**
+     * Constructs a fully-initialized DefaultEndpoint instance. This is the
+     * preferred method of constructing an object from Java code (as opposed to
+     * Spring beans, etc.).
+     *
+     * @param endpointUri the full URI used to create this endpoint
+     * @param component   the component that created this endpoint
+     */
+    public AvroEndpoint(String endpointUri, Component component, AvroConfiguration configuration) {
+        super(endpointUri, component);
+        this.configuration = configuration;
+    }
+
+
+    public Exchange createExchange(Protocol.Message message, Object request) {
+        ExchangePattern pattern = ExchangePattern.InOut;
+        if (message.getResponse().equals(Schema.Type.NULL)) {
+            pattern = ExchangePattern.InOnly;
+        }
+        Exchange exchange = createExchange(pattern);
+        exchange.getIn().setBody(request);
+        exchange.getIn().setHeader(AvroConstants.AVRO_MESSAGE_NAME, message.getName());
+        return exchange;
+    }
+
+    /**
+     * Whether this class supports being singleton or not.
+     *
+     * @return <tt>true</tt> to be a single shared instance, <tt>false</tt> to create new instances.
+     */
+    @Override
+    public boolean isSingleton() {
+        return false;
+    }
+
+    public AvroConfiguration getConfiguration() {
+        return configuration;
+    }
+
+    public Protocol getProtocol() {
+        return configuration.getProtocol();
+    }
+}

Added: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpConsumer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpConsumer.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpConsumer.java (added)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpConsumer.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,56 @@
+/**
+ * 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.avro;
+
+import org.apache.avro.ipc.HttpServer;
+import org.apache.camel.Endpoint;
+import org.apache.camel.Processor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class AvroHttpConsumer extends AvroConsumer {
+
+    private static final Logger LOG = LoggerFactory.getLogger(AvroHttpConsumer.class);
+    HttpServer server;
+
+
+    public AvroHttpConsumer(Endpoint endpoint, Processor processor) {
+        super(endpoint, processor);
+        String uri = endpoint.getEndpointUri();
+    }
+
+    @Override
+    protected void doStart() throws Exception {
+        AvroConfiguration configuration = getEndpoint().getConfiguration();
+        server = new HttpServer(new AvroResponder(this), configuration.getPort());
+        server.start();
+    }
+
+    @Override
+    protected void doStop() throws Exception {
+        super.doStop();
+        if (server != null) {
+            server.close();
+        }
+    }
+
+    @Override
+    public AvroEndpoint getEndpoint() {
+        return (AvroEndpoint) super.getEndpoint();
+    }
+}

Added: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpEndpoint.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpEndpoint.java (added)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpEndpoint.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,64 @@
+/**
+ * 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.avro;
+
+import org.apache.camel.Component;
+import org.apache.camel.Consumer;
+import org.apache.camel.Processor;
+import org.apache.camel.Producer;
+
+public class AvroHttpEndpoint extends AvroEndpoint {
+
+    /**
+     * Constructs a fully-initialized DefaultEndpoint instance. This is the
+     * preferred method of constructing an object from Java code (as opposed to
+     * Spring beans, etc.).
+     *
+     * @param endpointUri the full URI used to create this endpoint
+     * @param component   the component that created this endpoint
+     */
+    public AvroHttpEndpoint(String endpointUri, Component component, AvroConfiguration configuration) {
+        super(endpointUri, component, configuration);
+    }
+
+    /**
+     * Creates a new producer which is used send messages into the endpoint
+     *
+     * @return a newly created producer
+     * @throws Exception can be thrown
+     */
+    @Override
+    public Producer createProducer() throws Exception {
+        return new AvroHttpProducer(this);
+    }
+
+    /**
+     * Creates a new <a
+     * href="http://camel.apache.org/event-driven-consumer.html">Event
+     * Driven Consumer</a> which consumes messages from the endpoint using the
+     * given processor
+     *
+     * @param processor the given processor
+     * @return a newly created consumer
+     * @throws Exception can be thrown
+     */
+    @Override
+    public Consumer createConsumer(Processor processor) throws Exception {
+        return new AvroHttpConsumer(this, processor);
+    }
+}

Added: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpProducer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpProducer.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpProducer.java (added)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroHttpProducer.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,36 @@
+/**
+ * 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.avro;
+
+import java.net.URL;
+import org.apache.avro.ipc.HttpTransceiver;
+import org.apache.avro.ipc.Transceiver;
+import org.apache.camel.Endpoint;
+import org.apache.camel.util.URISupport;
+
+public class AvroHttpProducer extends AvroProducer {
+
+    public AvroHttpProducer(Endpoint endpoint) {
+        super(endpoint);
+    }
+
+    @Override
+    public Transceiver createTranceiver() throws Exception {
+        return new HttpTransceiver(new URL(URISupport.normalizeUri(getEndpoint().getEndpointUri())));
+    }
+}

Added: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyConsumer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyConsumer.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyConsumer.java (added)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyConsumer.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,57 @@
+/**
+ * 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.avro;
+
+import java.net.InetSocketAddress;
+import org.apache.avro.ipc.NettyServer;
+import org.apache.camel.Endpoint;
+import org.apache.camel.Processor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class AvroNettyConsumer extends AvroConsumer {
+
+    private static final Logger LOG = LoggerFactory.getLogger(AvroNettyConsumer.class);
+    NettyServer server;
+
+
+    public AvroNettyConsumer(Endpoint endpoint, Processor processor) {
+        super(endpoint, processor);
+        String uri = endpoint.getEndpointUri();
+    }
+
+    @Override
+    protected void doStart() throws Exception {
+        AvroConfiguration configuration = getEndpoint().getConfiguration();
+        server = new NettyServer(new AvroResponder(this), new InetSocketAddress(configuration.getHost(), configuration.getPort()));
+        server.start();
+    }
+
+    @Override
+    protected void doStop() throws Exception {
+        super.doStop();
+        if (server != null) {
+            server.close();
+        }
+    }
+
+    @Override
+    public AvroEndpoint getEndpoint() {
+        return (AvroEndpoint) super.getEndpoint();
+    }
+}

Added: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyEndpoint.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyEndpoint.java (added)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyEndpoint.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,64 @@
+/**
+ * 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.avro;
+
+import org.apache.camel.Component;
+import org.apache.camel.Consumer;
+import org.apache.camel.Processor;
+import org.apache.camel.Producer;
+
+public class AvroNettyEndpoint extends AvroEndpoint {
+
+    /**
+     * Constructs a fully-initialized DefaultEndpoint instance. This is the
+     * preferred method of constructing an object from Java code (as opposed to
+     * Spring beans, etc.).
+     *
+     * @param endpointUri the full URI used to create this endpoint
+     * @param component   the component that created this endpoint
+     */
+    public AvroNettyEndpoint(String endpointUri, Component component, AvroConfiguration configuration) {
+        super(endpointUri, component, configuration);
+    }
+
+    /**
+     * Creates a new producer which is used send messages into the endpoint
+     *
+     * @return a newly created producer
+     * @throws Exception can be thrown
+     */
+    @Override
+    public Producer createProducer() throws Exception {
+        return new AvroNettyProducer(this);
+    }
+
+    /**
+     * Creates a new <a
+     * href="http://camel.apache.org/event-driven-consumer.html">Event
+     * Driven Consumer</a> which consumes messages from the endpoint using the
+     * given processor
+     *
+     * @param processor the given processor
+     * @return a newly created consumer
+     * @throws Exception can be thrown
+     */
+    @Override
+    public Consumer createConsumer(Processor processor) throws Exception {
+        return new AvroNettyConsumer(this, processor);
+    }
+}

Added: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyProducer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyProducer.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyProducer.java (added)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroNettyProducer.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,38 @@
+/**
+ * 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.avro;
+
+import java.net.InetSocketAddress;
+import org.apache.avro.ipc.NettyTransceiver;
+import org.apache.avro.ipc.Transceiver;
+import org.apache.camel.Endpoint;
+
+public class AvroNettyProducer extends AvroProducer {
+
+
+    public AvroNettyProducer(Endpoint endpoint) {
+        super(endpoint);
+    }
+
+    @Override
+    public Transceiver createTranceiver() throws Exception {
+        AvroConfiguration configuration = getEndpoint().getConfiguration();
+        return transceiver = new NettyTransceiver(new InetSocketAddress(configuration.getHost(), configuration.getPort()));
+    }
+
+}

Added: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroProducer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroProducer.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroProducer.java (added)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroProducer.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,95 @@
+/**
+ * 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.avro;
+
+import org.apache.avro.ipc.Callback;
+import org.apache.avro.ipc.Requestor;
+import org.apache.avro.ipc.Transceiver;
+import org.apache.camel.Endpoint;
+import org.apache.camel.Exchange;
+import org.apache.camel.ServicePoolAware;
+import org.apache.camel.impl.DefaultProducer;
+
+public abstract class AvroProducer extends DefaultProducer implements ServicePoolAware {
+
+    Transceiver transceiver;
+    Requestor requestor;
+
+    public AvroProducer(Endpoint endpoint) {
+        super(endpoint);
+    }
+
+    public abstract Transceiver createTranceiver() throws Exception;
+
+    /**
+     * Processes the message exchange
+     *
+     * @param exchange the message exchange
+     * @throws Exception if an internal processing error has occurred.
+     */
+    @Override
+    public void process(final Exchange exchange) throws Exception {
+        Object request = exchange.getIn().getBody();
+
+        if (transceiver == null) {
+            transceiver = createTranceiver();
+            requestor = new AvroRequestor(getEndpoint().getProtocol(), transceiver);
+        }
+
+        requestor.request(exchange.getIn().getHeader(AvroConstants.AVRO_MESSAGE_NAME, String.class), wrapObjectToArray(request), new Callback<Object>() {
+
+            @Override
+            public void handleResult(Object result) {
+                exchange.getOut().setBody(result);
+            }
+
+            @Override
+            public void handleError(Throwable error) {
+                exchange.setException(error);
+            }
+        });
+    }
+
+    public Object[] wrapObjectToArray(Object object) {
+        if (object instanceof Object[]) {
+            return (Object[]) object;
+        } else {
+            Object[] wrapper = new Object[1];
+            wrapper[0] = object;
+            return wrapper;
+        }
+    }
+
+    @Override
+    protected void doStart() throws Exception {
+        super.doStart();
+    }
+
+    @Override
+    protected void doStop() throws Exception {
+        super.doStop();
+        if (transceiver != null) {
+            transceiver.close();
+        }
+    }
+
+    @Override
+    public AvroEndpoint getEndpoint() {
+        return (AvroEndpoint) super.getEndpoint();
+    }
+}

Added: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroRequestor.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroRequestor.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroRequestor.java (added)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroRequestor.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,30 @@
+/**
+ * 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.avro;
+
+import java.io.IOException;
+import org.apache.avro.Protocol;
+import org.apache.avro.ipc.Transceiver;
+import org.apache.avro.ipc.specific.SpecificRequestor;
+
+public class AvroRequestor extends SpecificRequestor {
+
+    public AvroRequestor(Protocol protocol, Transceiver transceiver) throws IOException {
+        super(protocol, transceiver);
+    }
+}

Added: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroResponder.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroResponder.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroResponder.java (added)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/component/avro/AvroResponder.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,80 @@
+/**
+ * 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.avro;
+
+import org.apache.avro.Protocol;
+import org.apache.avro.Schema;
+import org.apache.avro.generic.GenericRecord;
+import org.apache.avro.ipc.specific.SpecificResponder;
+import org.apache.avro.specific.SpecificData;
+import org.apache.camel.Exchange;
+import org.apache.camel.util.ExchangeHelper;
+
+public class AvroResponder extends SpecificResponder {
+
+    private AvroConsumer consumer;
+
+    /**
+     * Constructor
+     *
+     * @param consumer
+     */
+    public AvroResponder(AvroConsumer consumer) {
+        super(consumer.getEndpoint().getProtocol(), null);
+        this.consumer = consumer;
+    }
+
+    @Override
+    public Object respond(Protocol.Message message, Object request) throws Exception {
+        Object response = null;
+        int numParams = message.getRequest().getFields().size();
+        Object[] params = new Object[numParams];
+        Class[] paramTypes = new Class[numParams];
+        int i = 0;
+        for (Schema.Field param : message.getRequest().getFields()) {
+            params[i] = ((GenericRecord) request).get(param.name());
+            paramTypes[i] = SpecificData.get().getClass(param.schema());
+            i++;
+        }
+        Exchange exchange = consumer.getEndpoint().createExchange(message, params);
+
+        try {
+            consumer.getProcessor().process(exchange);
+        } catch (Throwable e) {
+            consumer.getExceptionHandler().handleException(e);
+        }
+
+        if (ExchangeHelper.isOutCapable(exchange)) {
+            response = exchange.getOut().getBody();
+        } else {
+            response = null;
+        }
+
+        boolean failed = exchange.isFailed();
+        if (failed) {
+            if (exchange.getException() != null) {
+                response = exchange.getException();
+            } else {
+                // failed and no exception, must be a fault
+                response = exchange.getOut().getBody();
+            }
+        }
+        return response;
+
+    }
+}

Added: camel/trunk/components/camel-avro/src/main/java/org/apache/camel/dataformat/avro/AvroDataFormat.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/java/org/apache/camel/dataformat/avro/AvroDataFormat.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/java/org/apache/camel/dataformat/avro/AvroDataFormat.java (added)
+++ camel/trunk/components/camel-avro/src/main/java/org/apache/camel/dataformat/avro/AvroDataFormat.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,123 @@
+/**
+ * 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.dataformat.avro;
+
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.lang.reflect.Method;
+import org.apache.avro.Schema;
+import org.apache.avro.generic.GenericContainer;
+import org.apache.avro.generic.GenericRecord;
+import org.apache.avro.io.DatumReader;
+import org.apache.avro.io.DatumWriter;
+import org.apache.avro.io.Decoder;
+import org.apache.avro.io.DecoderFactory;
+import org.apache.avro.io.Encoder;
+import org.apache.avro.io.EncoderFactory;
+import org.apache.avro.specific.SpecificDatumReader;
+import org.apache.avro.specific.SpecificDatumWriter;
+import org.apache.camel.CamelContext;
+import org.apache.camel.CamelException;
+import org.apache.camel.Exchange;
+import org.apache.camel.spi.DataFormat;
+import org.apache.camel.util.ObjectHelper;
+
+public class AvroDataFormat implements DataFormat {
+
+    private Schema schema;
+    private String instanceClassName;
+
+
+    /**
+     * @param schema
+     */
+    public AvroDataFormat(Schema schema) {
+        this.schema = schema;
+    }
+
+    public AvroDataFormat() {
+    }
+
+    public synchronized Schema getSchema(Exchange exchange, Object graph) throws Exception {
+        if (schema == null) {
+            if (instanceClassName != null) {
+                return loadDefaultSchema(instanceClassName, exchange.getContext());
+            }
+            if (graph != null && graph instanceof GenericContainer) {
+                return loadDefaultSchema(graph.getClass().getName(), exchange.getContext());
+            } else {
+                throw new CamelException("There is not schema for avro marshaling / unmarshaling");
+            }
+        }
+        return schema;
+    }
+
+    public void setSchema(Object schema) {
+        if (schema instanceof Schema) {
+            this.schema = (Schema) schema;
+        } else {
+            throw new IllegalArgumentException("The argument for setDefaultInstance should be subClass of " + Schema.class.getName());
+        }
+    }
+
+    public void setInstanceClass(String className) throws Exception {
+        ObjectHelper.notNull(className, "AvroDataFormat messageClass");
+        instanceClassName = className;
+    }
+
+    protected Schema loadDefaultSchema(String className, CamelContext context) throws CamelException, ClassNotFoundException {
+        Class<?> instanceClass = context.getClassResolver().resolveMandatoryClass(className);
+        if (GenericContainer.class.isAssignableFrom(instanceClass)) {
+            try {
+                Method method = instanceClass.getMethod("getSchema", new Class[0]);
+                return (Schema) method.invoke(instanceClass.newInstance(), new Object[0]);
+            } catch (Exception ex) {
+                throw new CamelException("Can't set the defaultInstance of AvroDataFormat with "
+                        + className + ", caused by " + ex);
+            }
+        } else {
+            throw new CamelException("Can't set the shcema of AvroDataFormat with "
+                    + className + ", as the class is not a subClass of SpecificData");
+        }
+    }
+
+    /*
+     * (non-Javadoc)
+     * @see org.apache.camel.spi.DataFormat#marshal(org.apache.camel.Exchange,
+     * java.lang.Object, java.io.OutputStream)
+     */
+    public void marshal(Exchange exchange, Object graph, OutputStream outputStream) throws Exception {
+        DatumWriter datum = new SpecificDatumWriter(getSchema(exchange, graph));
+        Encoder encoder = EncoderFactory.get().binaryEncoder(outputStream, null);
+        datum.write(graph, encoder);
+        encoder.flush();
+    }
+
+    /*
+     * (non-Javadoc)
+     * @see org.apache.camel.spi.DataFormat#unmarshal(org.apache.camel.Exchange,
+     * java.io.InputStream)
+     */
+    public Object unmarshal(Exchange exchange, InputStream inputStream) throws Exception {
+        DatumReader<GenericRecord> reader = new SpecificDatumReader(getSchema(exchange, null));
+        Decoder decoder = DecoderFactory.get().binaryDecoder(inputStream, null);
+        Object result = reader.read(null, decoder);
+        return result;
+    }
+
+}

Added: camel/trunk/components/camel-avro/src/main/resources/META-INF/services/org/apache/camel/component/avro
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/resources/META-INF/services/org/apache/camel/component/avro?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/resources/META-INF/services/org/apache/camel/component/avro (added)
+++ camel/trunk/components/camel-avro/src/main/resources/META-INF/services/org/apache/camel/component/avro Fri Feb  3 21:41:13 2012
@@ -0,0 +1,17 @@
+#
+# 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.
+#
+class=org.apache.camel.component.avro.AvroComponent

Added: camel/trunk/components/camel-avro/src/main/resources/META-INF/services/org/apache/camel/dataformat/avro
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/main/resources/META-INF/services/org/apache/camel/dataformat/avro?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/main/resources/META-INF/services/org/apache/camel/dataformat/avro (added)
+++ camel/trunk/components/camel-avro/src/main/resources/META-INF/services/org/apache/camel/dataformat/avro Fri Feb  3 21:41:13 2012
@@ -0,0 +1,18 @@
+#
+# 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.
+#
+
+class=org.apache.camel.dataformat.avro.AvroDataFormat

Added: camel/trunk/components/camel-avro/src/test/avro/test.avpr
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/test/avro/test.avpr?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/test/avro/test.avpr (added)
+++ camel/trunk/components/camel-avro/src/test/avro/test.avpr Fri Feb  3 21:41:13 2012
@@ -0,0 +1,27 @@
+{"namespace": "org.apache.camel.avro.generated",
+ "protocol": "KeyValueProtocol",
+
+ "types": [
+     {"name": "Key", "type": "record",
+      "fields": [
+          {"name": "key",   "type": "string"}
+      ]
+     },
+     {"name": "Value", "type": "record",
+      "fields": [
+          {"name": "value",   "type": "string"}
+      ]
+     }
+ ],
+
+ "messages": {
+     "put": {
+         "request": [{"name": "key", "type": "Key"}, {"name": "value", "type": "Value"} ],
+         "response": "null"
+     },
+     "get": {
+         "request": [{"name": "key", "type": "Key"}],
+         "response": "Value"
+     }
+ }
+}
\ No newline at end of file

Added: camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/Key.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/Key.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/Key.java (added)
+++ camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/Key.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,121 @@
+/**
+ * Autogenerated by Avro
+ * 
+ * DO NOT EDIT DIRECTLY
+ */
+package org.apache.camel.avro.generated;  
+@SuppressWarnings("all")
+public class Key extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
+  public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"Key\",\"namespace\":\"org.apache.camel.avro.generated\",\"fields\":[{\"name\":\"key\",\"type\":\"string\"}]}");
+  @Deprecated public java.lang.CharSequence key;
+  public org.apache.avro.Schema getSchema() { return SCHEMA$; }
+  // Used by DatumWriter.  Applications should not call. 
+  public java.lang.Object get(int field$) {
+    switch (field$) {
+    case 0: return key;
+    default: throw new org.apache.avro.AvroRuntimeException("Bad index");
+    }
+  }
+  // Used by DatumReader.  Applications should not call. 
+  @SuppressWarnings(value="unchecked")
+  public void put(int field$, java.lang.Object value$) {
+    switch (field$) {
+    case 0: key = (java.lang.CharSequence)value$; break;
+    default: throw new org.apache.avro.AvroRuntimeException("Bad index");
+    }
+  }
+
+  /**
+   * Gets the value of the 'key' field.
+   */
+  public java.lang.CharSequence getKey() {
+    return key;
+  }
+
+  /**
+   * Sets the value of the 'key' field.
+   * @param value the value to set.
+   */
+  public void setKey(java.lang.CharSequence value) {
+    this.key = value;
+  }
+
+  /** Creates a new Key RecordBuilder */
+  public static org.apache.camel.avro.generated.Key.Builder newBuilder() {
+    return new org.apache.camel.avro.generated.Key.Builder();
+  }
+  
+  /** Creates a new Key RecordBuilder by copying an existing Builder */
+  public static org.apache.camel.avro.generated.Key.Builder newBuilder(org.apache.camel.avro.generated.Key.Builder other) {
+    return new org.apache.camel.avro.generated.Key.Builder(other);
+  }
+  
+  /** Creates a new Key RecordBuilder by copying an existing Key instance */
+  public static org.apache.camel.avro.generated.Key.Builder newBuilder(org.apache.camel.avro.generated.Key other) {
+    return new org.apache.camel.avro.generated.Key.Builder(other);
+  }
+  
+  /**
+   * RecordBuilder for Key instances.
+   */
+  public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase<Key>
+    implements org.apache.avro.data.RecordBuilder<Key> {
+
+    private java.lang.CharSequence key;
+
+    /** Creates a new Builder */
+    private Builder() {
+      super(org.apache.camel.avro.generated.Key.SCHEMA$);
+    }
+    
+    /** Creates a Builder by copying an existing Builder */
+    private Builder(org.apache.camel.avro.generated.Key.Builder other) {
+      super(other);
+    }
+    
+    /** Creates a Builder by copying an existing Key instance */
+    private Builder(org.apache.camel.avro.generated.Key other) {
+            super(org.apache.camel.avro.generated.Key.SCHEMA$);
+      if (isValidValue(fields()[0], other.key)) {
+        this.key = (java.lang.CharSequence) data().deepCopy(fields()[0].schema(), other.key);
+        fieldSetFlags()[0] = true;
+      }
+    }
+
+    /** Gets the value of the 'key' field */
+    public java.lang.CharSequence getKey() {
+      return key;
+    }
+    
+    /** Sets the value of the 'key' field */
+    public org.apache.camel.avro.generated.Key.Builder setKey(java.lang.CharSequence value) {
+      validate(fields()[0], value);
+      this.key = value;
+      fieldSetFlags()[0] = true;
+      return this; 
+    }
+    
+    /** Checks whether the 'key' field has been set */
+    public boolean hasKey() {
+      return fieldSetFlags()[0];
+    }
+    
+    /** Clears the value of the 'key' field */
+    public org.apache.camel.avro.generated.Key.Builder clearKey() {
+      key = null;
+      fieldSetFlags()[0] = false;
+      return this;
+    }
+
+    @Override
+    public Key build() {
+      try {
+        Key record = new Key();
+        record.key = fieldSetFlags()[0] ? this.key : (java.lang.CharSequence) defaultValue(fields()[0]);
+        return record;
+      } catch (Exception e) {
+        throw new org.apache.avro.AvroRuntimeException(e);
+      }
+    }
+  }
+}

Added: camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/KeyValueProtocol.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/KeyValueProtocol.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/KeyValueProtocol.java (added)
+++ camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/KeyValueProtocol.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,20 @@
+/**
+ * Autogenerated by Avro
+ * 
+ * DO NOT EDIT DIRECTLY
+ */
+package org.apache.camel.avro.generated;
+
+@SuppressWarnings("all")
+public interface KeyValueProtocol {
+  public static final org.apache.avro.Protocol PROTOCOL = org.apache.avro.Protocol.parse("{\"protocol\":\"KeyValueProtocol\",\"namespace\":\"org.apache.camel.avro.generated\",\"types\":[{\"type\":\"record\",\"name\":\"Key\",\"fields\":[{\"name\":\"key\",\"type\":\"string\"}]},{\"type\":\"record\",\"name\":\"Value\",\"fields\":[{\"name\":\"value\",\"type\":\"string\"}]}],\"messages\":{\"put\":{\"request\":[{\"name\":\"key\",\"type\":\"Key\"},{\"name\":\"value\",\"type\":\"Value\"}],\"response\":\"null\"},\"get\":{\"request\":[{\"name\":\"key\",\"type\":\"Key\"}],\"response\":\"Value\"}}}");
+  java.lang.Void put(org.apache.camel.avro.generated.Key key, org.apache.camel.avro.generated.Value value) throws org.apache.avro.AvroRemoteException;
+  org.apache.camel.avro.generated.Value get(org.apache.camel.avro.generated.Key key) throws org.apache.avro.AvroRemoteException;
+
+  @SuppressWarnings("all")
+  public interface Callback extends KeyValueProtocol {
+    public static final org.apache.avro.Protocol PROTOCOL = org.apache.camel.avro.generated.KeyValueProtocol.PROTOCOL;
+    void put(org.apache.camel.avro.generated.Key key, org.apache.camel.avro.generated.Value value, org.apache.avro.ipc.Callback<java.lang.Void> callback) throws java.io.IOException;
+    void get(org.apache.camel.avro.generated.Key key, org.apache.avro.ipc.Callback<org.apache.camel.avro.generated.Value> callback) throws java.io.IOException;
+  }
+}
\ No newline at end of file

Added: camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/Value.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/Value.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/Value.java (added)
+++ camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/generated/Value.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,121 @@
+/**
+ * Autogenerated by Avro
+ * 
+ * DO NOT EDIT DIRECTLY
+ */
+package org.apache.camel.avro.generated;  
+@SuppressWarnings("all")
+public class Value extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
+  public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"Value\",\"namespace\":\"org.apache.camel.avro.generated\",\"fields\":[{\"name\":\"value\",\"type\":\"string\"}]}");
+  @Deprecated public java.lang.CharSequence value;
+  public org.apache.avro.Schema getSchema() { return SCHEMA$; }
+  // Used by DatumWriter.  Applications should not call. 
+  public java.lang.Object get(int field$) {
+    switch (field$) {
+    case 0: return value;
+    default: throw new org.apache.avro.AvroRuntimeException("Bad index");
+    }
+  }
+  // Used by DatumReader.  Applications should not call. 
+  @SuppressWarnings(value="unchecked")
+  public void put(int field$, java.lang.Object value$) {
+    switch (field$) {
+    case 0: value = (java.lang.CharSequence)value$; break;
+    default: throw new org.apache.avro.AvroRuntimeException("Bad index");
+    }
+  }
+
+  /**
+   * Gets the value of the 'value' field.
+   */
+  public java.lang.CharSequence getValue() {
+    return value;
+  }
+
+  /**
+   * Sets the value of the 'value' field.
+   * @param value the value to set.
+   */
+  public void setValue(java.lang.CharSequence value) {
+    this.value = value;
+  }
+
+  /** Creates a new Value RecordBuilder */
+  public static org.apache.camel.avro.generated.Value.Builder newBuilder() {
+    return new org.apache.camel.avro.generated.Value.Builder();
+  }
+  
+  /** Creates a new Value RecordBuilder by copying an existing Builder */
+  public static org.apache.camel.avro.generated.Value.Builder newBuilder(org.apache.camel.avro.generated.Value.Builder other) {
+    return new org.apache.camel.avro.generated.Value.Builder(other);
+  }
+  
+  /** Creates a new Value RecordBuilder by copying an existing Value instance */
+  public static org.apache.camel.avro.generated.Value.Builder newBuilder(org.apache.camel.avro.generated.Value other) {
+    return new org.apache.camel.avro.generated.Value.Builder(other);
+  }
+  
+  /**
+   * RecordBuilder for Value instances.
+   */
+  public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase<Value>
+    implements org.apache.avro.data.RecordBuilder<Value> {
+
+    private java.lang.CharSequence value;
+
+    /** Creates a new Builder */
+    private Builder() {
+      super(org.apache.camel.avro.generated.Value.SCHEMA$);
+    }
+    
+    /** Creates a Builder by copying an existing Builder */
+    private Builder(org.apache.camel.avro.generated.Value.Builder other) {
+      super(other);
+    }
+    
+    /** Creates a Builder by copying an existing Value instance */
+    private Builder(org.apache.camel.avro.generated.Value other) {
+            super(org.apache.camel.avro.generated.Value.SCHEMA$);
+      if (isValidValue(fields()[0], other.value)) {
+        this.value = (java.lang.CharSequence) data().deepCopy(fields()[0].schema(), other.value);
+        fieldSetFlags()[0] = true;
+      }
+    }
+
+    /** Gets the value of the 'value' field */
+    public java.lang.CharSequence getValue() {
+      return value;
+    }
+    
+    /** Sets the value of the 'value' field */
+    public org.apache.camel.avro.generated.Value.Builder setValue(java.lang.CharSequence value) {
+      validate(fields()[0], value);
+      this.value = value;
+      fieldSetFlags()[0] = true;
+      return this; 
+    }
+    
+    /** Checks whether the 'value' field has been set */
+    public boolean hasValue() {
+      return fieldSetFlags()[0];
+    }
+    
+    /** Clears the value of the 'value' field */
+    public org.apache.camel.avro.generated.Value.Builder clearValue() {
+      value = null;
+      fieldSetFlags()[0] = false;
+      return this;
+    }
+
+    @Override
+    public Value build() {
+      try {
+        Value record = new Value();
+        record.value = fieldSetFlags()[0] ? this.value : (java.lang.CharSequence) defaultValue(fields()[0]);
+        return record;
+      } catch (Exception e) {
+        throw new org.apache.avro.AvroRuntimeException(e);
+      }
+    }
+  }
+}

Added: camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/impl/KeyValueProtocolImpl.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/impl/KeyValueProtocolImpl.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/impl/KeyValueProtocolImpl.java (added)
+++ camel/trunk/components/camel-avro/src/test/java/org/apache/camel/avro/impl/KeyValueProtocolImpl.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,49 @@
+/**
+ * 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.avro.impl;
+
+import java.util.HashMap;
+import java.util.Map;
+import org.apache.avro.AvroRemoteException;
+import org.apache.camel.avro.generated.Key;
+import org.apache.camel.avro.generated.KeyValueProtocol;
+import org.apache.camel.avro.generated.Value;
+
+public class KeyValueProtocolImpl implements KeyValueProtocol {
+
+    private Map<Key, Value> store = new HashMap<Key, Value>();
+
+    @Override
+    public Void put(Key key, Value value) throws AvroRemoteException {
+        store.put(key, value);
+        return null;
+    }
+
+    @Override
+    public Value get(Key key) throws AvroRemoteException {
+        return store.get(key);
+    }
+
+    public Map<Key, Value> getStore() {
+        return store;
+    }
+
+    public void setStore(Map<Key, Value> store) {
+        this.store = store;
+    }
+}

Added: camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroConsumerTestSupport.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroConsumerTestSupport.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroConsumerTestSupport.java (added)
+++ camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroConsumerTestSupport.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,91 @@
+/**
+ * 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.avro;
+
+import java.io.IOException;
+import junit.framework.Assert;
+import org.apache.avro.Protocol;
+import org.apache.avro.ipc.Requestor;
+import org.apache.avro.ipc.Transceiver;
+import org.apache.camel.CamelContext;
+import org.apache.camel.avro.generated.Key;
+import org.apache.camel.avro.generated.KeyValueProtocol;
+import org.apache.camel.avro.generated.Value;
+import org.apache.camel.avro.impl.KeyValueProtocolImpl;
+import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.test.CamelTestSupport;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+public abstract class AvroConsumerTestSupport extends AvroTestSupport {
+
+    Transceiver transceiver;
+    Requestor requestor;
+    KeyValueProtocolImpl keyValue = new KeyValueProtocolImpl();
+
+    protected abstract void initializeTranceiver() throws IOException;
+
+    @Before
+    protected void setUp() throws Exception {
+        super.setUp();
+    }
+
+    @After
+    protected void tearDown() throws Exception {
+        super.tearDown();
+        if (transceiver != null) {
+            transceiver.close();
+        }
+    }
+
+
+    @Test
+    public void testInOnly() throws Exception {
+        initializeTranceiver();
+        Key key = Key.newBuilder().setKey("1").build();
+        Value value = Value.newBuilder().setValue("test value").build();
+        Object[] request = {key, value};
+        requestor.request("put", request);
+    }
+
+
+    @Test
+    public void testInOut() throws Exception {
+        initializeTranceiver();
+        keyValue.getStore().clear();
+        Key key = Key.newBuilder().setKey("2").build();
+        Value value = Value.newBuilder().setValue("test value").build();
+        keyValue.getStore().put(key, value);
+        Object[] request = {key};
+        Object response = requestor.request("get", request);
+        Assert.assertEquals(value, response);
+    }
+
+    @Override
+    protected CamelContext createCamelContext() throws Exception {
+        CamelContext context = super.createCamelContext();
+        Protocol protocol = KeyValueProtocol.PROTOCOL;
+        AvroConfiguration configuration = new AvroConfiguration();
+        configuration.setProtocol(protocol);
+        AvroComponent component = new AvroComponent(context);
+        component.setConfiguration(configuration);
+        context.addComponent("avro", component);
+        return context;
+    }
+}
\ No newline at end of file

Added: camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroHttpConsumerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroHttpConsumerTest.java?rev=1240351&view=auto
==============================================================================
--- camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroHttpConsumerTest.java (added)
+++ camel/trunk/components/camel-avro/src/test/java/org/apache/camel/component/avro/AvroHttpConsumerTest.java Fri Feb  3 21:41:13 2012
@@ -0,0 +1,50 @@
+/**
+ * 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.avro;
+
+import java.io.IOException;
+import java.net.URL;
+import org.apache.avro.ipc.HttpTransceiver;
+import org.apache.avro.ipc.specific.SpecificRequestor;
+import org.apache.camel.avro.generated.KeyValueProtocol;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.avro.processors.GetProcessor;
+import org.apache.camel.component.avro.processors.PutProcessor;
+
+public class AvroHttpConsumerTest extends AvroConsumerTestSupport {
+
+    static int avroPort = setupFreePort("avroport");
+
+    @Override
+    protected void initializeTranceiver() throws IOException {
+        transceiver = new HttpTransceiver(new URL("http://localhost:" + avroPort));
+        requestor = new SpecificRequestor(KeyValueProtocol.class, transceiver);
+    }
+
+    protected RouteBuilder createRouteBuilder() throws Exception {
+        return new RouteBuilder() {
+            @Override
+            public void configure() throws Exception {
+                //In Only
+                from("avro:http:localhost:" + avroPort).choice()
+                        .when().el("${in.headers." + AvroConstants.AVRO_MESSAGE_NAME + " == 'put'}").process(new PutProcessor(keyValue))
+                        .when().el("${in.headers." + AvroConstants.AVRO_MESSAGE_NAME + " == 'get'}").process(new GetProcessor(keyValue));
+            }
+        };
+    }
+}



Mime
View raw message