You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by js...@apache.org on 2007/10/01 17:23:01 UTC
svn commit: r580991 - in
/activemq/camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc:
JdbcEndpoint.java JdbcProducer.java
Author: jstrachan
Date: Mon Oct 1 08:23:01 2007
New Revision: 580991
URL: http://svn.apache.org/viewvc?rev=580991&view=rev
Log:
increased the default maximum readSize for CAMEL-128
Modified:
activemq/camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcEndpoint.java
activemq/camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java
Modified: activemq/camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcEndpoint.java?rev=580991&r1=580990&r2=580991&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcEndpoint.java (original)
+++ activemq/camel/trunk/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcEndpoint.java Mon Oct 1 08:23:01 2007
@@ -34,7 +34,8 @@
private URI uri;
private String remaining;
- private int readSize;
+ /** The maximum size for reading a result set <code>readSize</code> */
+ private int readSize = 20000;
protected JdbcEndpoint(String endpointUri, String remaining, JdbcComponent component) throws URISyntaxException {
super(endpointUri, component);
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=580991&r1=580990&r2=580991&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 Oct 1 08:23:01 2007
@@ -43,6 +43,7 @@
public JdbcProducer(JdbcEndpoint endpoint, String remaining, int readSize) throws Exception {
super(endpoint);
+ this.readSize = readSize;
source = (DataSource) getEndpoint().getContext().getRegistry().lookup(remaining);
}