camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jans...@apache.org
Subject svn commit: r722149 - in /activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java: DirectComponent.java DirectEndpoint.java DirectProducer.java
Date Mon, 01 Dec 2008 17:56:25 GMT
Author: janstey
Date: Mon Dec  1 09:56:25 2008
New Revision: 722149

URL: http://svn.apache.org/viewvc?rev=722149&view=rev
Log:
Remove generics from compoenent archetype

Modified:
    activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/DirectComponent.java
    activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/DirectEndpoint.java
    activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/DirectProducer.java

Modified: activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/DirectComponent.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/DirectComponent.java?rev=722149&r1=722148&r2=722149&view=diff
==============================================================================
--- activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/DirectComponent.java
(original)
+++ activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/DirectComponent.java
Mon Dec  1 09:56:25 2008
@@ -28,10 +28,10 @@
  *
  * @version
  */
-public class DirectComponent<E extends Exchange> extends DefaultComponent<E>
{
+public class DirectComponent extends DefaultComponent {
 
-    protected Endpoint<E> createEndpoint(String uri, String remaining, Map parameters)
throws Exception {
-        Endpoint<E> endpoint = new DirectEndpoint<E>(uri, this);
+    protected Endpoint createEndpoint(String uri, String remaining, Map parameters) throws
Exception {
+        Endpoint endpoint = new DirectEndpoint(uri, this);
         setProperties(endpoint, parameters);
         return endpoint;
     }

Modified: activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/DirectEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/DirectEndpoint.java?rev=722149&r1=722148&r2=722149&view=diff
==============================================================================
--- activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/DirectEndpoint.java
(original)
+++ activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/DirectEndpoint.java
Mon Dec  1 09:56:25 2008
@@ -34,22 +34,22 @@
  * 
  * @version 
  */
-public class DirectEndpoint<E extends Exchange> extends DefaultEndpoint<E> {
+public class DirectEndpoint extends DefaultEndpoint {
     private static final Log LOG = LogFactory.getLog(DirectEndpoint.class);
 
-    private final CopyOnWriteArrayList<DefaultConsumer<E>> consumers = new CopyOnWriteArrayList<DefaultConsumer<E>>();
+    private final CopyOnWriteArrayList<DefaultConsumer> consumers = new CopyOnWriteArrayList<DefaultConsumer>();
     boolean allowMultipleConsumers = true;
 
-    public DirectEndpoint(String uri, DirectComponent<E> component) {
+    public DirectEndpoint(String uri, DirectComponent component) {
         super(uri, component);
     }
 
     public Producer createProducer() throws Exception {
-        return new DirectProducer<E>(this);
+        return new DirectProducer(this);
     }
 
-    public Consumer<E> createConsumer(Processor processor) throws Exception {
-        return new DefaultConsumer<E>(this, processor) {
+    public Consumer createConsumer(Processor processor) throws Exception {
+        return new DefaultConsumer(this, processor) {
             @Override
             public void start() throws Exception {
                 if (!allowMultipleConsumers && !consumers.isEmpty()) {
@@ -80,7 +80,7 @@
         return true;
     }
 
-    public List<DefaultConsumer<E>> getConsumers() {
+    public List<DefaultConsumer> getConsumers() {
         return consumers;
     }
 }

Modified: activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/DirectProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/DirectProducer.java?rev=722149&r1=722148&r2=722149&view=diff
==============================================================================
--- activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/DirectProducer.java
(original)
+++ activemq/camel/trunk/tooling/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/DirectProducer.java
Mon Dec  1 09:56:25 2008
@@ -29,11 +29,11 @@
 /**
  * @version $
  */
-public class DirectProducer<E extends Exchange> extends DefaultProducer implements
AsyncProcessor {
+public class DirectProducer extends DefaultProducer implements AsyncProcessor {
     private static final transient Log LOG = LogFactory.getLog(DirectProducer.class);
-    private DirectEndpoint<E> endpoint;
+    private DirectEndpoint endpoint;
 
-    public DirectProducer(DirectEndpoint<E> endpoint) {
+    public DirectProducer(DirectEndpoint endpoint) {
         super(endpoint);
         this.endpoint = endpoint;
     }
@@ -43,7 +43,7 @@
             LOG.warn("No getConsumers() available on " + this + " for " + exchange);
         }
         else {
-            for (DefaultConsumer<E> consumer : endpoint.getConsumers()) {
+            for (DefaultConsumer consumer : endpoint.getConsumers()) {
                 consumer.getProcessor().process(exchange);
             }
         }
@@ -58,7 +58,7 @@
             if (size > 1) {
                 // Too hard to do multiple async.. do it sync
                 try {
-                    for (DefaultConsumer<E> consumer : endpoint.getConsumers()) {
+                    for (DefaultConsumer consumer : endpoint.getConsumers()) {
                         consumer.getProcessor().process(exchange);
                     }
                 }
@@ -67,7 +67,7 @@
                 }
             }
             else {
-                for (DefaultConsumer<E> consumer : endpoint.getConsumers()) {
+                for (DefaultConsumer consumer : endpoint.getConsumers()) {
                     AsyncProcessor processor = AsyncProcessorTypeConverter.convert(consumer.getProcessor());
                     return processor.process(exchange, callback);
                 }



Mime
View raw message