Initial checkin of Camel routing library

git-svn-id: https://svn.apache.org/repos/asf/activemq/camel/trunk@519901 13f79535-47bb-0310-9956-ffa450edef68

Author: jstrachan

camel/camel-core/pom.xml

@@ -0,0 +1,50 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<!--
+  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.
+-->
+
+<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"
+  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://maven.apache.org/POM/4.0.0">
+
+  <modelVersion>4.0.0</modelVersion>
+
+  <parent>
+    <groupId>org.apache.camel</groupId>
+    <artifactId>camel-parent</artifactId>
+    <version>1.0-SNAPSHOT</version>
+  </parent>
+
+  <artifactId>camel-core</artifactId>
+  <name>Camel :: Core</name>
+  <description>The Core Camel POJO based router</description>
+
+  <dependencies>
+
+    <dependency>
+      <groupId>commons-logging</groupId>
+      <artifactId>commons-logging</artifactId>
+      <optional>false</optional>
+    </dependency>
+
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+
+</project>

camel/camel-core/src/main/java/org/apache/camel/Endpoint.java

@@ -0,0 +1,40 @@
+/*
+ * 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;
+
+/**
+ * Represents an endpoint on which messages can be exchanged
+ *
+ * @version $Revision$
+ */
+public interface Endpoint<E>  {
+
+    /**
+     * Returns the string representation of the URI
+     */
+    public String getEndpointUri();
+
+    /**
+     * Sends the mesage exchange to this endpoint
+     */
+    void send(E exchange);
+
+    /**
+     * Create a new exchange for communicating with this endpoint
+     */
+    E createExchange();
+}

camel/camel-core/src/main/java/org/apache/camel/EndpointResolver.java

@@ -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;
+
+/**
+ * A resolver of endpoints from a String URI
+ *
+ * @version $Revision$
+ */
+public interface EndpointResolver<E> {
+
+    /**
+     * Resolves the given uri or returns null if no endpoint could be found
+     */
+    public Endpoint<E> resolve(String uri);
+}

camel/camel-core/src/main/java/org/apache/camel/Exchange.java

@@ -0,0 +1,68 @@
+/*
+ * 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;
+
+import java.util.Map;
+
+/**
+ * Represents the base interface of an exchange
+ *
+ * @version $Revision$
+ */
+public interface Exchange<M> {
+
+    /**
+     * Accesses a specific header
+     */
+    <T> T getHeader(String name);
+
+    /**
+     * Sets a header on the exchange
+     */
+    void setHeader(String name, Object value);
+
+    /**
+     * Returns all of the headers associated with the request
+     */
+    Map<String,Object> getHeaders();
+
+    /**
+     * Returns the request message
+     */
+    M getRequest();
+
+    /**
+     * Returns the response message
+     */
+    M getResponse();
+
+    /**
+     * Returns the fault message
+     */
+    M getFault();
+
+    /**
+     * Returns the exception associated with this exchange
+     */
+    Exception getException();
+
+    /**
+     * Sets the exception associated with this exchange
+     */
+    void setException(Exception e);
+
+}

camel/camel-core/src/main/java/org/apache/camel/ExchangeConverter.java

@@ -0,0 +1,27 @@
+/*
+ * 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;
+
+/**
+ * This converter is capable of converting from an exchange to another type
+ *
+ * @version $Revision$
+ */
+public interface ExchangeConverter {
+
+     <T> T  convertTo(Class<T> type, Exchange exchange);
+}

camel/camel-core/src/main/java/org/apache/camel/FilterProcessor.java

@@ -0,0 +1,42 @@
+/**
+ *
+ * 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;
+
+/**
+ * @version $Revision$
+ */
+public class FilterProcessor<E> implements Processor<E> {
+    private Predicate<E> predicate;
+    private Processor<E> processor;
+
+    public FilterProcessor(Predicate<E> predicate, Processor<E> processor) {
+        this.predicate = predicate;
+        this.processor = processor;
+    }
+
+    public void onExchange(E exchange) {
+        if (predicate.evaluate(exchange)) {
+            processor.onExchange(exchange);
+        }
+    }
+
+    @Override
+    public String toString() {
+        return "if (" + predicate + ") " + processor;
+    }
+}

camel/camel-core/src/main/java/org/apache/camel/InvalidHeaderTypeException.java

@@ -0,0 +1,47 @@
+/*
+ * 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;
+
+/**
+ * @version $Revision$
+ */
+public class InvalidHeaderTypeException extends RuntimeCamelException {
+    private Object headerValue;
+
+    public InvalidHeaderTypeException(Throwable cause, Object headerValue) {
+        super(cause.getMessage() + " headerValue is: " + headerValue + " of type: "
+                + typeName(headerValue), cause);
+        this.headerValue = headerValue;
+    }
+
+    public InvalidHeaderTypeException(String message, Object headerValue) {
+        super(message);
+        this.headerValue = headerValue;
+    }
+
+
+    /**
+     * Returns the actual header value
+     */
+    public Object getHeaderValue() {
+        return headerValue;
+    }
+
+    protected static String typeName(Object headerValue) {
+        return (headerValue != null) ? headerValue.getClass().getName() : "null";
+    }
+}

camel/camel-core/src/main/java/org/apache/camel/Predicate.java

@@ -0,0 +1,33 @@
+/*
+ * 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;
+
+/**
+ * Evaluates a binary predicate on the message exchange
+ *
+ * @version $Revision$
+ */
+public interface Predicate<E> {
+
+    /**
+     * Evaluates the predicate on the message exchange
+     *
+     * @param exchange the message exchange
+     * @return true if the predicate matches
+     */
+    boolean evaluate(E exchange);
+}