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);
     }