serge 02/04/18 12:14:23
Modified: src/java/org/apache/james/mailrepository
MimeMessageJDBCSource.java
Log:
Removed stupid debug code, and also stopped looping 10 times each time I went to
receive a message.
Revision Changes Path
1.6 +19 -16
jakarta-james/src/java/org/apache/james/mailrepository/MimeMessageJDBCSource.java
Index: MimeMessageJDBCSource.java
===================================================================
RCS file:
/home/cvs/jakarta-james/src/java/org/apache/james/mailrepository/MimeMessageJDBCSource.java,v
retrieving revision 1.5
retrieving revision 1.6
diff -u -r1.5 -r1.6
--- MimeMessageJDBCSource.java 18 Apr 2002 14:49:15 -0000 1.5
+++ MimeMessageJDBCSource.java 18 Apr 2002 19:14:23 -0000 1.6
@@ -24,6 +24,7 @@
* InputStream to the JDBC field/record, possibly sequenced with the file stream.
*/
public class MimeMessageJDBCSource extends MimeMessageSource {
+ private static final boolean DEEP_DEBUG = false;
//Define how to get to the data
JDBCMailRepository repository = null;
@@ -67,26 +68,28 @@
*/
public synchronized InputStream getInputStream() throws IOException {
try {
- new Throwable().printStackTrace();
Connection conn = repository.getConnection();
byte[] headers = null;
- for (int i = 0; i < 10; i++) {
- long start = System.currentTimeMillis();
- System.err.println("starting");
- PreparedStatement retrieveMessageStream =
conn.prepareStatement(retrieveMessageBodySQL);
- retrieveMessageStream.setString(1, key);
- retrieveMessageStream.setString(2, repository.repositoryName);
- ResultSet rsRetrieveMessageStream =
retrieveMessageStream.executeQuery();
-
- if (!rsRetrieveMessageStream.next()) {
- throw new IOException("Could not find message");
- }
-
- headers = rsRetrieveMessageStream.getBytes(1);
- rsRetrieveMessageStream.close();
- retrieveMessageStream.close();
+ long start = 0;
+ if (DEEP_DEBUG) {
+ start = System.currentTimeMillis();
+ System.out.println("starting");
+ }
+ PreparedStatement retrieveMessageStream =
conn.prepareStatement(retrieveMessageBodySQL);
+ retrieveMessageStream.setString(1, key);
+ retrieveMessageStream.setString(2, repository.repositoryName);
+ ResultSet rsRetrieveMessageStream =
retrieveMessageStream.executeQuery();
+
+ if (!rsRetrieveMessageStream.next()) {
+ throw new IOException("Could not find message");
+ }
+
+ headers = rsRetrieveMessageStream.getBytes(1);
+ rsRetrieveMessageStream.close();
+ retrieveMessageStream.close();
+ if (DEEP_DEBUG) {
System.err.println("stopping");
System.err.println(System.currentTimeMillis() - start);
}
--
To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
