You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2008/12/01 18:56:25 UTC
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
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);
}