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);
}
