You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ha...@apache.org on 2008/11/10 09:32:16 UTC
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...
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";