camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hadr...@apache.org
Subject svn commit: r712626 - in /activemq/camel/trunk: camel-core/src/main/java/org/apache/camel/component/list/ camel-core/src/main/java/org/apache/camel/component/mock/ camel-core/src/main/java/org/apache/camel/impl/ components/camel-cxf/src/main/java/org/a...
Date Mon, 10 Nov 2008 08:32:16 GMT
Author: hadrian
Date: Mon Nov 10 00:32:15 2008
New Revision: 712626

URL: http://svn.apache.org/viewvc?rev=712626&view=rev
Log:
CAMEL-872.  Removed generics on DefaultProducer.  Part 7 of 8.

Modified:
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/list/ListEndpoint.java
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducer.java
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProcessorEndpoint.java
    activemq/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfProducer.java
    activemq/camel/trunk/components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/FlatpackProducer.java
    activemq/camel/trunk/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/RemoteFileProducer.java
    activemq/camel/trunk/components/camel-http/src/main/java/org/apache/camel/component/http/HttpProducer.java
    activemq/camel/trunk/components/camel-ibatis/src/main/java/org/apache/camel/component/ibatis/IBatisProducer.java
    activemq/camel/trunk/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcProducer.java
    activemq/camel/trunk/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrProducer.java
    activemq/camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java
    activemq/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpProducer.java
    activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java
    activemq/camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java
    activemq/camel/trunk/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueProducer.java
    activemq/camel/trunk/components/camel-ldap/src/main/java/org/apache/camel/component/ldap/LdapProducer.java
    activemq/camel/trunk/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailProducer.java
    activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiProducer.java
    activemq/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationProducer.java
    activemq/camel/trunk/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java
    activemq/camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/list/ListEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/list/ListEndpoint.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/list/ListEndpoint.java
(original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/list/ListEndpoint.java
Mon Nov 10 00:32:15 2008
@@ -79,7 +79,7 @@
     }
 
     public Producer createProducer() throws Exception {
-        return new DefaultProducer<Exchange>(this) {
+        return new DefaultProducer(this) {
             public void process(Exchange exchange) throws Exception {
                 onExchange(exchange);
             }

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
(original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
Mon Nov 10 00:32:15 2008
@@ -167,7 +167,7 @@
     }
 
     public Producer createProducer() throws Exception {
-        return new DefaultProducer<Exchange>(this) {
+        return new DefaultProducer(this) {
             public void process(Exchange exchange) {
                 onExchange(exchange);
             }

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducer.java
(original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducer.java
Mon Nov 10 00:32:15 2008
@@ -26,10 +26,10 @@
  *
  * @version $Revision$
  */
-public abstract class DefaultProducer<E extends Exchange> extends ServiceSupport implements
Producer {
-    private Endpoint<E> endpoint;
+public abstract class DefaultProducer extends ServiceSupport implements Producer {
+    private Endpoint endpoint;
 
-    public DefaultProducer(Endpoint<E> endpoint) {
+    public DefaultProducer(Endpoint endpoint) {
         this.endpoint = endpoint;
     }
 

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProcessorEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProcessorEndpoint.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProcessorEndpoint.java
(original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProcessorEndpoint.java
Mon Nov 10 00:32:15 2008
@@ -61,7 +61,7 @@
     }
 
     public Producer createProducer() throws Exception {
-        return new DefaultProducer<Exchange>(this) {
+        return new DefaultProducer(this) {
             public void process(Exchange exchange) throws Exception {
                 onExchange(exchange);
             }

Modified: activemq/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfProducer.java
(original)
+++ activemq/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfProducer.java
Mon Nov 10 00:32:15 2008
@@ -55,7 +55,7 @@
  *
  * @version $Revision$
  */
-public class CxfProducer extends DefaultProducer<CxfExchange> {
+public class CxfProducer extends DefaultProducer {
     private CxfEndpoint endpoint;
     private Client client;
     private DataFormat dataFormat;

Modified: activemq/camel/trunk/components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/FlatpackProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/FlatpackProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/FlatpackProducer.java
(original)
+++ activemq/camel/trunk/components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/FlatpackProducer.java
Mon Nov 10 00:32:15 2008
@@ -24,7 +24,7 @@
 /**
  * @version $Revision$
  */
-class FlatpackProducer extends DefaultProducer<Exchange> {
+class FlatpackProducer extends DefaultProducer {
     private FixedLengthEndpoint endpoint;
 
     public FlatpackProducer(FixedLengthEndpoint endpoint) {

Modified: activemq/camel/trunk/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/RemoteFileProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/RemoteFileProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/RemoteFileProducer.java
(original)
+++ activemq/camel/trunk/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/RemoteFileProducer.java
Mon Nov 10 00:32:15 2008
@@ -24,7 +24,7 @@
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-public abstract class RemoteFileProducer<T extends RemoteFileExchange> extends DefaultProducer<T>
{
+public abstract class RemoteFileProducer<T extends RemoteFileExchange> extends DefaultProducer
{
     protected final transient Log log = LogFactory.getLog(getClass());
     protected RemoteFileEndpoint<T> endpoint;
 

Modified: activemq/camel/trunk/components/camel-http/src/main/java/org/apache/camel/component/http/HttpProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-http/src/main/java/org/apache/camel/component/http/HttpProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-http/src/main/java/org/apache/camel/component/http/HttpProducer.java
(original)
+++ activemq/camel/trunk/components/camel-http/src/main/java/org/apache/camel/component/http/HttpProducer.java
Mon Nov 10 00:32:15 2008
@@ -46,7 +46,7 @@
 /**
  * @version $Revision$
  */
-public class HttpProducer extends DefaultProducer<HttpExchange> {
+public class HttpProducer extends DefaultProducer {
     public static final String HTTP_URI = "http.uri";
     public static final String HTTP_RESPONSE_CODE = "http.responseCode";
     public static final String QUERY = "org.apache.camel.component.http.query";    

Modified: activemq/camel/trunk/components/camel-ibatis/src/main/java/org/apache/camel/component/ibatis/IBatisProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-ibatis/src/main/java/org/apache/camel/component/ibatis/IBatisProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-ibatis/src/main/java/org/apache/camel/component/ibatis/IBatisProducer.java
(original)
+++ activemq/camel/trunk/components/camel-ibatis/src/main/java/org/apache/camel/component/ibatis/IBatisProducer.java
Mon Nov 10 00:32:15 2008
@@ -30,7 +30,7 @@
 /**
  * @version $Revision$
  */
-public class IBatisProducer extends DefaultProducer<Exchange> {
+public class IBatisProducer extends DefaultProducer {
     private String statement;
     private IBatisEndpoint endpoint;
 

Modified: activemq/camel/trunk/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcProducer.java
(original)
+++ activemq/camel/trunk/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcProducer.java
Mon Nov 10 00:32:15 2008
@@ -24,7 +24,7 @@
 import org.schwering.irc.lib.IRCConnection;
 import org.schwering.irc.lib.IRCEventListener;
 
-public class IrcProducer extends DefaultProducer<IrcExchange> {
+public class IrcProducer extends DefaultProducer {
 
     public static final String[] COMMANDS = new String[] {"AWAY", "INVITE", "ISON", "JOIN",
"KICK", "LIST", "NAMES", "PRIVMSG", "MODE", "NICK", "NOTICE", "PART", "PONG", "QUIT", "TOPIC",
"WHO",
                                                           "WHOIS", "WHOWAS", "USERHOST"};

Modified: activemq/camel/trunk/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrProducer.java
(original)
+++ activemq/camel/trunk/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrProducer.java
Mon Nov 10 00:32:15 2008
@@ -24,10 +24,9 @@
 
 import org.apache.camel.Exchange;
 import org.apache.camel.TypeConverter;
-import org.apache.camel.impl.DefaultExchange;
 import org.apache.camel.impl.DefaultProducer;
 
-public class JcrProducer extends DefaultProducer<DefaultExchange> {
+public class JcrProducer extends DefaultProducer {
 
     public JcrProducer(JcrEndpoint jcrEndpoint) throws LoginException,
             RepositoryException {

Modified: activemq/camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java
(original)
+++ activemq/camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java
Mon Nov 10 00:32:15 2008
@@ -28,7 +28,6 @@
 import javax.sql.DataSource;
 
 import org.apache.camel.Exchange;
-import org.apache.camel.impl.DefaultExchange;
 import org.apache.camel.impl.DefaultProducer;
 import org.apache.camel.util.IntrospectionSupport;
 import org.apache.commons.logging.Log;
@@ -37,7 +36,7 @@
 /**
  * @version $Revision$
  */
-public class JdbcProducer extends DefaultProducer<DefaultExchange> {
+public class JdbcProducer extends DefaultProducer {
 
     private static final transient Log LOG = LogFactory.getLog(JdbcProducer.class);
     private DataSource source;

Modified: activemq/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpProducer.java
(original)
+++ activemq/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpProducer.java
Mon Nov 10 00:32:15 2008
@@ -42,7 +42,7 @@
 /**
  * @deprecated use org.apache.camel.component.http.HttpProducer instead. Will be removed
in Camel 2.0.
  */
-public class JettyHttpProducer extends DefaultProducer<HttpExchange> implements Producer,
AsyncProcessor {
+public class JettyHttpProducer extends DefaultProducer implements AsyncProcessor {
 
     private final class CamelContentExchange extends ContentExchange {
 

Modified: activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java
(original)
+++ activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java
Mon Nov 10 00:32:15 2008
@@ -28,7 +28,6 @@
 
 import org.apache.camel.AsyncCallback;
 import org.apache.camel.AsyncProcessor;
-import org.apache.camel.Endpoint;
 import org.apache.camel.Exchange;
 import org.apache.camel.Message;
 import org.apache.camel.impl.DefaultProducer;
@@ -64,7 +63,7 @@
 import org.apache.http.protocol.RequestTargetHost;
 import org.apache.http.protocol.RequestUserAgent;
 
-public class JhcProducer extends DefaultProducer<JhcExchange> implements AsyncProcessor
{
+public class JhcProducer extends DefaultProducer implements AsyncProcessor {
 
     public static final String HTTP_RESPONSE_CODE = "http.responseCode";
 

Modified: activemq/camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java
(original)
+++ activemq/camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java
Mon Nov 10 00:32:15 2008
@@ -31,7 +31,7 @@
 /**
  * @version $Revision$
  */
-public class JpaProducer extends DefaultProducer<Exchange> {
+public class JpaProducer extends DefaultProducer {
     private final TransactionStrategy template;
     private final JpaEndpoint endpoint;
     private final Expression expression;

Modified: activemq/camel/trunk/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueProducer.java
(original)
+++ activemq/camel/trunk/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueProducer.java
Mon Nov 10 00:32:15 2008
@@ -27,7 +27,7 @@
 /**
  * {@link Producer} to send data to an AS/400 data queue.
  */
-public class Jt400DataQueueProducer extends DefaultProducer<Exchange> {
+public class Jt400DataQueueProducer extends DefaultProducer {
 
     private final Jt400DataQueueEndpoint endpoint;
 

Modified: activemq/camel/trunk/components/camel-ldap/src/main/java/org/apache/camel/component/ldap/LdapProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-ldap/src/main/java/org/apache/camel/component/ldap/LdapProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-ldap/src/main/java/org/apache/camel/component/ldap/LdapProducer.java
(original)
+++ activemq/camel/trunk/components/camel-ldap/src/main/java/org/apache/camel/component/ldap/LdapProducer.java
Mon Nov 10 00:32:15 2008
@@ -25,7 +25,6 @@
 import javax.naming.directory.SearchResult;
 
 import org.apache.camel.Exchange;
-import org.apache.camel.impl.DefaultExchange;
 import org.apache.camel.impl.DefaultProducer;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -33,7 +32,7 @@
 /**
  * @version $
  */
-public class LdapProducer<E extends Exchange> extends DefaultProducer<DefaultExchange>
{
+public class LdapProducer<E extends Exchange> extends DefaultProducer {
     private static final transient Log LOG = LogFactory.getLog(LdapProducer.class);
     private DirContext ldapContext;
     private SearchControls controls;

Modified: activemq/camel/trunk/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailProducer.java
(original)
+++ activemq/camel/trunk/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailProducer.java
Mon Nov 10 00:32:15 2008
@@ -31,7 +31,7 @@
  *  
  * @version $Revision$
  */
-public class MailProducer extends DefaultProducer<MailExchange> {
+public class MailProducer extends DefaultProducer {
     private static final transient Log LOG = LogFactory.getLog(MailProducer.class);
     private final MailEndpoint endpoint;
     private final JavaMailSender sender;

Modified: activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiProducer.java
(original)
+++ activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiProducer.java
Mon Nov 10 00:32:15 2008
@@ -20,7 +20,6 @@
 import java.rmi.RemoteException;
 
 import org.apache.camel.Exchange;
-import org.apache.camel.component.bean.BeanExchange;
 import org.apache.camel.component.bean.BeanHolder;
 import org.apache.camel.component.bean.BeanProcessor;
 import org.apache.camel.impl.DefaultProducer;
@@ -28,7 +27,7 @@
 /**
  * @version $Revision$
  */
-public class RmiProducer extends DefaultProducer<BeanExchange> {
+public class RmiProducer extends DefaultProducer {
 
     private BeanProcessor beanProcessor;
 

Modified: activemq/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationProducer.java
(original)
+++ activemq/camel/trunk/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationProducer.java
Mon Nov 10 00:32:15 2008
@@ -45,7 +45,7 @@
  * should be set for receiving the response message.
  * @version $Revision$
  */
-public class SpringIntegrationProducer extends DefaultProducer<SpringIntegrationExchange>
implements AsyncProcessor {
+public class SpringIntegrationProducer extends DefaultProducer implements AsyncProcessor
{
     private static final transient Log LOG = LogFactory.getLog(SpringIntegrationProducer.class);
     private SpringCamelContext context;
     private DirectChannel inputChannel;

Modified: activemq/camel/trunk/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java
(original)
+++ activemq/camel/trunk/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java
Mon Nov 10 00:32:15 2008
@@ -66,7 +66,7 @@
 
     public Producer createProducer() throws Exception {
         ObjectHelper.notNull(getApplicationContext(), "applicationContext");
-        return new DefaultProducer<Exchange>(this) {
+        return new DefaultProducer(this) {
             public void process(Exchange exchange) throws Exception {
                 ApplicationEvent event = toApplicationEvent(exchange);
                 getApplicationContext().publishEvent(event);

Modified: activemq/camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java?rev=712626&r1=712625&r2=712626&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java
(original)
+++ activemq/camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java
Mon Nov 10 00:32:15 2008
@@ -38,7 +38,7 @@
 /**
  * Producer that can write to streams
  */
-public class StreamProducer extends DefaultProducer<Exchange> {
+public class StreamProducer extends DefaultProducer {
 
     private static final transient Log LOG = LogFactory.getLog(StreamProducer.class);
     private static final String TYPES = "out,err,file,header,url";



Mime
View raw message