svn commit: r1398972 - in /uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel: UimaAsComponent.java UimaAsEndpoint.java UimaAsProducer.java

[cw...@apache.org]

Author: cwiklik
Date: Tue Oct 16 20:09:39 2012
New Revision: 1398972

URL: http://svn.apache.org/viewvc?rev=1398972&view=rev
Log:
UIMA-2481 removed dubious use of generics

Modified:
    uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsComponent.java
    uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsEndpoint.java
    uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsProducer.java

Modified: uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsComponent.java
URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsComponent.java?rev=1398972&r1=1398971&r2=1398972&view=diff
==============================================================================
--- uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsComponent.java (original)
+++ uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsComponent.java Tue Oct 16 20:09:39 2012
@@ -23,17 +23,17 @@ import java.net.URI;
 import java.util.Map;
 
 import org.apache.camel.Endpoint;
-import org.apache.camel.Exchange;
 import org.apache.camel.RuntimeCamelException;
 import org.apache.camel.impl.DefaultComponent;
 
 /**
  * Defines the UIMA-AS camel driver component.
  */
-public class UimaAsComponent extends DefaultComponent<Exchange> {
+@SuppressWarnings("rawtypes")
+public class UimaAsComponent extends DefaultComponent {
 
 	@Override
-	protected Endpoint<Exchange> createEndpoint(String uri, String remaining,
+	protected Endpoint createEndpoint(String uri, String remaining,
     		Map parameters) throws Exception {
 		
     	URI hbaseURI = UriUtils.create(uri);

Modified: uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsEndpoint.java
URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsEndpoint.java?rev=1398972&r1=1398971&r2=1398972&view=diff
==============================================================================
--- uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsEndpoint.java (original)
+++ uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsEndpoint.java Tue Oct 16 20:09:39 2012
@@ -22,7 +22,6 @@ package org.apache.uima.camel;
 import java.util.Map;
 
 import org.apache.camel.Consumer;
-import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.apache.camel.Producer;
 import org.apache.camel.impl.DefaultEndpoint;
@@ -31,7 +30,8 @@ import org.apache.uima.aae.client.UimaAs
 /**
  * Represent the UIMA-AS camel driver endpoint.
  */
-public class UimaAsEndpoint extends DefaultEndpoint<Exchange> {
+@SuppressWarnings("rawtypes")
+public class UimaAsEndpoint extends DefaultEndpoint {
 
 	private String brokerAddress;
 	private String queue;
@@ -81,11 +81,12 @@ public class UimaAsEndpoint extends Defa
 		
     }
     
-	public Consumer<Exchange> createConsumer(Processor arg0) throws Exception {
+    
+	public Consumer createConsumer(Processor arg0) throws Exception {
 		return null;
 	}
 
-	public Producer<Exchange> createProducer() throws Exception {
+	public Producer createProducer() throws Exception {
 		return new UimaAsProducer(brokerAddress, queue, casPoolSize, timeout, this);
 	}
 

Modified: uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsProducer.java
URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsProducer.java?rev=1398972&r1=1398971&r2=1398972&view=diff
==============================================================================
--- uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsProducer.java (original)
+++ uima/uima-as/trunk/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsProducer.java Tue Oct 16 20:09:39 2012
@@ -48,7 +48,8 @@ import org.apache.uima.resource.Resource
  * For example:
  * uimadriver:tcp://localhost:61616?queue=TextAnalysisQueue
  */
-public class UimaAsProducer extends DefaultProducer<Exchange> implements AsyncProcessor {
+@SuppressWarnings("rawtypes")
+public class UimaAsProducer extends DefaultProducer implements AsyncProcessor {
 
   private static final Log LOG = LogFactory.getLog(UimaAsProducer.class);
 
@@ -141,7 +142,8 @@ public class UimaAsProducer extends Defa
    */
   private final Map<String, ExchangeAsyncCallbackPair> intermediateMap;
 
-  public UimaAsProducer(String brokerAddress, String queue, Integer casPoolSize, Integer timeout, Endpoint<Exchange> endpoint)
+  @SuppressWarnings("unchecked")
+public UimaAsProducer(String brokerAddress, String queue, Integer casPoolSize, Integer timeout, Endpoint endpoint)
           throws Exception {
     super(endpoint);