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/11/12 20:26:29 UTC
svn commit: r713464 -
/activemq/camel/branches/camel-1.x/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlComponent.java
Author: janstey
Date: Wed Nov 12 11:26:28 2008
New Revision: 713464
URL: http://svn.apache.org/viewvc?rev=713464&view=rev
Log:
Fix compile error
Modified:
activemq/camel/branches/camel-1.x/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlComponent.java
Modified: activemq/camel/branches/camel-1.x/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlComponent.java
URL: http://svn.apache.org/viewvc/activemq/camel/branches/camel-1.x/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlComponent.java?rev=713464&r1=713463&r2=713464&view=diff
==============================================================================
--- activemq/camel/branches/camel-1.x/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlComponent.java (original)
+++ activemq/camel/branches/camel-1.x/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlComponent.java Wed Nov 12 11:26:28 2008
@@ -22,12 +22,13 @@
import org.apache.camel.CamelContext;
import org.apache.camel.Endpoint;
+import org.apache.camel.Exchange;
import org.apache.camel.impl.DefaultComponent;
/**
* @version $Revision:520964 $
*/
-public class SqlComponent extends DefaultComponent {
+public class SqlComponent extends DefaultComponent<Exchange> {
private DataSource dataSource;
public SqlComponent() {
@@ -38,7 +39,7 @@
}
@Override
- protected Endpoint createEndpoint(String uri, String remaining, Map parameters) throws Exception {
+ protected Endpoint<Exchange> createEndpoint(String uri, String remaining, Map parameters) throws Exception {
String dataSourceRef = getAndRemoveParameter(parameters, "dataSourceRef", String.class);
if (dataSourceRef != null) {
dataSource = getCamelContext().getRegistry().lookup(dataSourceRef, DataSource.class);