activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r520341 - in /activemq/camel/trunk/camel-core/src: main/java/org/apache/camel/queue/ test/java/org/apache/camel/pojo/ test/resources/ test/resources/META-INF/ test/resources/META-INF/services/ test/resources/META-INF/services/org/ test/reso...
Date Tue, 20 Mar 2007 09:11:48 GMT
Author: chirino
Date: Tue Mar 20 02:11:47 2007
New Revision: 520341

URL: http://svn.apache.org/viewvc?view=rev&rev=520341
Log:
Added a little Pojo play component in the test section.  This now gives another component
that we can test against.
It would be nice to see how exchange conversions will be implemented.

Added:
    activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/
    activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/ISay.java
    activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoComponent.java
    activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoEndpoint.java
    activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoEndpointResolver.java
    activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoExchange.java
    activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoInvocation.java
    activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoRouteTest.java
    activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/SayService.java
    activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/package.html
    activemq/camel/trunk/camel-core/src/test/resources/
    activemq/camel/trunk/camel-core/src/test/resources/META-INF/
    activemq/camel/trunk/camel-core/src/test/resources/META-INF/services/
    activemq/camel/trunk/camel-core/src/test/resources/META-INF/services/org/
    activemq/camel/trunk/camel-core/src/test/resources/META-INF/services/org/apache/
    activemq/camel/trunk/camel-core/src/test/resources/META-INF/services/org/apache/camel/
    activemq/camel/trunk/camel-core/src/test/resources/META-INF/services/org/apache/camel/EndpointResolver/
    activemq/camel/trunk/camel-core/src/test/resources/META-INF/services/org/apache/camel/EndpointResolver/pojo
Modified:
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/queue/QueueEndpointResolver.java

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/queue/QueueEndpointResolver.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/queue/QueueEndpointResolver.java?view=diff&rev=520341&r1=520340&r2=520341
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/queue/QueueEndpointResolver.java
(original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/queue/QueueEndpointResolver.java
Tue Mar 20 02:11:47 2007
@@ -73,7 +73,7 @@
 		String splitURI[] = ObjectHelper.splitOnCharacter(uri, ":", 3);        
     	if( splitURI[2] != null ) {
     		rc[0] =  splitURI[1];
-    		rc[0] =  splitURI[2];
+    		rc[1] =  splitURI[2];
     	} else {
     		rc[0] =  splitURI[1];
     	}

Added: activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/ISay.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/ISay.java?view=auto&rev=520341
==============================================================================
--- activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/ISay.java (added)
+++ activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/ISay.java Tue Mar
20 02:11:47 2007
@@ -0,0 +1,21 @@
+/*
+ * 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.pojo;
+
+public interface ISay {
+	public String say();
+}

Added: activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoComponent.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoComponent.java?view=auto&rev=520341
==============================================================================
--- activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoComponent.java
(added)
+++ activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoComponent.java
Tue Mar 20 02:11:47 2007
@@ -0,0 +1,62 @@
+/*
+ * 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.pojo;
+
+import java.util.HashMap;
+
+import org.apache.camel.CamelContainer;
+import org.apache.camel.Component;
+
+/**
+ * Represents the component that manages {@link PojoEndpoint}.  It holds the 
+ * list of named pojos that queue endpoints reference.
+ *
+ * @version $Revision: 519973 $
+ */
+public class PojoComponent implements Component<PojoExchange> {
+	
+    private final HashMap<String, Object> registry = new HashMap<String, Object>();
+    private final HashMap<String, PojoEndpoint> activatedEndpoints = new HashMap<String,
PojoEndpoint>();
+    
+	private CamelContainer container;
+
+	public void registerPojo(String uri, Object pojo) {
+		registry.put(uri, pojo);
+	}
+	public Object lookupRegisteredPojo(String uri) {
+		return registry.get(uri);
+	}
+	
+	public void registerActivation(String uri, PojoEndpoint endpoint) {
+		activatedEndpoints.put(uri, endpoint);
+	}
+	public void unregisterActivation(String uri) {
+		activatedEndpoints.remove(uri);
+	}
+	public PojoEndpoint lookupActivation(String uri) {
+		return activatedEndpoints.get(uri);
+	}
+	
+	
+	public void setContainer(CamelContainer container) {
+		this.container = container;
+	}
+	public CamelContainer getContainer() {
+		return container;
+	}
+    
+}

Added: activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoEndpoint.java?view=auto&rev=520341
==============================================================================
--- activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoEndpoint.java
(added)
+++ activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoEndpoint.java
Tue Mar 20 02:11:47 2007
@@ -0,0 +1,103 @@
+/*
+ * 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.pojo;
+
+import java.lang.reflect.InvocationHandler;
+import java.lang.reflect.InvocationTargetException;
+import java.lang.reflect.Method;
+import java.lang.reflect.Proxy;
+
+import org.apache.camel.CamelContainer;
+import org.apache.camel.impl.DefaultEndpoint;
+
+/**
+ * Represents a pojo endpoint that uses reflection
+ * to send messages around.
+ *
+ * @version $Revision: 519973 $
+ */
+public class PojoEndpoint extends DefaultEndpoint<PojoExchange> {
+
+    private final Object pojo;
+	private final PojoComponent component;
+    
+	public PojoEndpoint(String uri, CamelContainer container, PojoComponent component, Object
pojo) {
+        super(uri, container);
+		this.component = component;
+		this.pojo = pojo;
+    }
+
+	/**
+	 *  This causes us to invoke the endpoint Pojo using reflection.
+	 */
+    public void onExchange(PojoExchange exchange) {
+        PojoInvocation invocation = exchange.getRequest();
+        try {
+			Object response = invocation.getMethod().invoke(pojo, invocation.getArgs());
+			exchange.setResponse(response);
+		} catch (InvocationTargetException e) {
+			exchange.setFault(e.getCause());
+		} catch ( RuntimeException e ) {
+			throw e;
+		} catch ( Throwable e ) {
+			throw new RuntimeException(e);
+		}
+    }
+
+    public PojoExchange createExchange() {
+        return new PojoExchange();
+    }
+
+    @Override
+    protected void doActivate() {
+    	component.registerActivation(getEndpointUri(), this);
+    }
+    
+    @Override
+    protected void doDeactivate() {
+    	component.unregisterActivation(getEndpointUri());
+    }
+
+    /**
+     * Creates a Proxy object that can be used to deliver inbound PojoExchanges.
+     * 
+     * @param interfaces
+     * @return
+     */
+    public Object createInboundProxy(Class interfaces[]) {
+    	final PojoEndpoint endpoint = component.lookupActivation(getEndpointUri());
+    	if( endpoint == null ) 
+			throw new IllegalArgumentException("The endpoint has not been activated yet: "+getEndpointUri());
+    	
+    	return Proxy.newProxyInstance(pojo.getClass().getClassLoader(), interfaces, new InvocationHandler(){
+			public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
+				if( !activated.get() ) {
+					PojoInvocation invocation = new PojoInvocation(proxy, method, args);
+					PojoExchange exchange = new PojoExchange();
+					exchange.setRequest(invocation);
+					endpoint.getInboundProcessor().onExchange(exchange);
+					Throwable fault = exchange.getFault();
+					if ( fault != null ) {
+						throw new InvocationTargetException(fault);
+					}
+					return exchange.getResponse();
+				}
+				throw new IllegalStateException("The endpoint is not active: "+getEndpointUri());
+			}
+		});
+    }
+}

Added: activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoEndpointResolver.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoEndpointResolver.java?view=auto&rev=520341
==============================================================================
--- activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoEndpointResolver.java
(added)
+++ activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoEndpointResolver.java
Tue Mar 20 02:11:47 2007
@@ -0,0 +1,83 @@
+/*
+ * 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.pojo;
+
+import org.apache.camel.CamelContainer;
+import org.apache.camel.Component;
+import org.apache.camel.EndpointResolver;
+import org.apache.camel.util.ObjectHelper;
+
+/**
+ * An implementation of {@link EndpointResolver} that creates 
+ * {@link PojoEndpoint} objects.
+ *
+ * The synatax for a Pojo URI looks like:
+ * 
+ * <pre><code>pojo:component:queuename</code></pre>
+ * 
+ * @version $Revision: 519901 $
+ */
+public class PojoEndpointResolver implements EndpointResolver<PojoExchange> {
+		
+	/**
+	 * Finds the {@see QueueComponent} specified by the uri.  If the {@see QueueComponent} 
+	 * object do not exist, it will be created.
+	 * 
+	 * @see org.apache.camel.EndpointResolver#resolveComponent(org.apache.camel.CamelContainer,
java.lang.String)
+	 */
+	public Component resolveComponent(CamelContainer container, String uri) {
+		String id[] = getEndpointId(uri);        
+		return resolveQueueComponent(container, id[0]);
+	}
+
+	/**
+	 * Finds the {@see QueueEndpoint} specified by the uri.  If the {@see QueueEndpoint} or
it's associated
+	 * {@see QueueComponent} object do not exist, they will be created.
+	 * 
+	 * @see org.apache.camel.EndpointResolver#resolveEndpoint(org.apache.camel.CamelContainer,
java.lang.String)
+	 */
+	public PojoEndpoint resolveEndpoint(CamelContainer container, String uri) {
+		String id[] = getEndpointId(uri);        
+    	PojoComponent component = resolveQueueComponent(container, id[0]);        
+        Object pojo = component.lookupRegisteredPojo(id[1]);
+		return new PojoEndpoint(uri, container, component, pojo);
+    }
+
+	private PojoComponent resolveQueueComponent(CamelContainer container, String componentName)
{
+    	Component rc = container.getComponent(componentName);
+    	if( rc == null ) {
+    		throw new IllegalArgumentException("Invalid URI, pojo component does not exist: "+componentName);
+    	}
+    	return (PojoComponent) rc;
+	}
+
+	/**
+	 * @return an array that looks like: [componentName,endpointName] 
+	 */
+	private String[] getEndpointId(String uri) {
+		String rc [] = {null, null};
+		String splitURI[] = ObjectHelper.splitOnCharacter(uri, ":", 3);        
+    	if( splitURI[2] != null ) {
+    		rc[0] =  splitURI[1];
+    		rc[1] =  splitURI[2];
+    	} else {
+    		throw new IllegalArgumentException("Invalid URI, component not specified in URI: "+uri);
+    	}
+		return rc;
+	}
+
+}

Added: activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoExchange.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoExchange.java?view=auto&rev=520341
==============================================================================
--- activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoExchange.java
(added)
+++ activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoExchange.java
Tue Mar 20 02:11:47 2007
@@ -0,0 +1,48 @@
+/*
+ * 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.pojo;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.camel.impl.ExchangeSupport;
+
+
+/**
+ * @version $Revision: 519901 $
+ */
+public class PojoExchange extends ExchangeSupport<PojoInvocation, Object, Throwable>
{
+	
+	Map<String, Object> headers;
+	
+	public Object getHeader(String name) {
+		if( headers == null )
+			return null;
+		return headers.get(name);
+	}
+
+	public Map<String, Object> getHeaders() {
+		if( headers == null )
+			headers = new HashMap<String, Object>();
+		return headers;
+	}
+	
+	public void setHeader(String name, Object value) {
+		getHeaders().put(name, value);
+	}
+
+}

Added: activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoInvocation.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoInvocation.java?view=auto&rev=520341
==============================================================================
--- activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoInvocation.java
(added)
+++ activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoInvocation.java
Tue Mar 20 02:11:47 2007
@@ -0,0 +1,30 @@
+package org.apache.camel.pojo;
+
+import java.lang.reflect.Method;
+
+public class PojoInvocation {
+
+	private final Object proxy;
+	private final Method method;
+	private final Object[] args;
+
+	public PojoInvocation(Object proxy, Method method, Object[] args) {
+		this.proxy = proxy;
+		this.method = method;
+		this.args = args;
+	}
+
+	public Object[] getArgs() {
+		return args;
+	}
+
+	public Method getMethod() {
+		return method;
+	}
+
+	public Object getProxy() {
+		return proxy;
+	}
+
+
+}

Added: activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoRouteTest.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoRouteTest.java?view=auto&rev=520341
==============================================================================
--- activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoRouteTest.java
(added)
+++ activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/PojoRouteTest.java
Tue Mar 20 02:11:47 2007
@@ -0,0 +1,83 @@
+/**
+ *
+ * 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.pojo;
+
+import java.util.concurrent.atomic.AtomicInteger;
+
+import junit.framework.TestCase;
+
+import org.apache.camel.CamelContainer;
+import org.apache.camel.InterceptorProcessor;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.impl.DefaultExchange;
+
+/**
+ * @version $Revision: 520220 $
+ */
+public class PojoRouteTest extends TestCase {
+	
+	static class StringExchange extends DefaultExchange<String, String, String> {		
+	}
+	
+    public void testJmsRoute() throws Exception {
+
+        CamelContainer container = new CamelContainer();
+        PojoComponent component = new PojoComponent();
+        component.registerPojo("hello", new SayService("Hello!"));
+        component.registerPojo("bye", new SayService("Good Bye!"));
+        container.addComponent("default", component);
+        
+        final AtomicInteger hitCount = new AtomicInteger();
+        final InterceptorProcessor<PojoExchange> tracingInterceptor = new InterceptorProcessor<PojoExchange>()
{
+        	@Override
+        	public void onExchange(PojoExchange exchange) {
+        		super.onExchange(exchange);
+        		hitCount.incrementAndGet();
+        	}
+        };
+        // lets add some routes
+        container.routes(new RouteBuilder() {
+            public void configure() {
+                from("pojo:default:hello").intercept(tracingInterceptor).target().to("pojo:default:bye");
+                
+//                from("pojo:default:bye").intercept(tracingInterceptor).target().to("pojo:default:hello");
+            }
+        });
+
+        
+        container.activateEndpoints();
+        
+        // now lets fire in a message
+        PojoEndpoint endpoint = (PojoEndpoint) container.endpoint("pojo:default:hello");
+        ISay proxy = (ISay) endpoint.createInboundProxy(new Class[]{ISay.class});
+        String rc = proxy.say();
+        assertEquals("Good Bye!", rc);
+
+        try {
+			endpoint = (PojoEndpoint) container.endpoint("pojo:default:bye");
+			proxy = (ISay) endpoint.createInboundProxy(new Class[]{ISay.class});
+			rc = proxy.say();
+			assertEquals("Hello!", rc);
+			
+		} catch (IllegalArgumentException expected) {
+			// since bye is not active.
+		}
+
+        container.deactivateEndpoints();
+    }
+}

Added: activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/SayService.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/SayService.java?view=auto&rev=520341
==============================================================================
--- activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/SayService.java (added)
+++ activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/SayService.java Tue
Mar 20 02:11:47 2007
@@ -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.pojo;
+
+public class SayService implements ISay {
+	String message = "Hello";
+	
+	public SayService() {
+	}
+	public SayService(String message) {
+		this.message = message;
+	}
+
+	public String say() {
+		return message;
+	}
+
+	public String getMessage() {
+		return message;
+	}
+
+	public void setMessage(String message) {
+		this.message = message;
+	}
+
+}

Added: activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/package.html
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/package.html?view=auto&rev=520341
==============================================================================
--- activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/package.html (added)
+++ activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/pojo/package.html Tue Mar
20 02:11:47 2007
@@ -0,0 +1,25 @@
+<!--
+    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.
+-->
+<html>
+<head>
+</head>
+<body>
+
+Experimenation/Testing component that defines pojo endpoints for camel.  The exchanges are
based on Java reflection.
+
+</body>
+</html>

Added: activemq/camel/trunk/camel-core/src/test/resources/META-INF/services/org/apache/camel/EndpointResolver/pojo
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/resources/META-INF/services/org/apache/camel/EndpointResolver/pojo?view=auto&rev=520341
==============================================================================
--- activemq/camel/trunk/camel-core/src/test/resources/META-INF/services/org/apache/camel/EndpointResolver/pojo
(added)
+++ activemq/camel/trunk/camel-core/src/test/resources/META-INF/services/org/apache/camel/EndpointResolver/pojo
Tue Mar 20 02:11:47 2007
@@ -0,0 +1 @@
+class=org.apache.camel.pojo.PojoEndpointResolver



Mime
View raw message