[jboss-svn-commits] JBL Code SVN: r6954 - labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/persistence/format/db

[jboss-svn-commits at lists.jboss.org]

Author: daniel.brum at jboss.com
Date: 2006-10-20 09:52:25 -0400 (Fri, 20 Oct 2006)
New Revision: 6954

Modified:
   labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/persistence/format/db/MessageStoreImpl.java
Log:


Modified: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/persistence/format/db/MessageStoreImpl.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/persistence/format/db/MessageStoreImpl.java	2006-10-20 13:38:16 UTC (rev 6953)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/persistence/format/db/MessageStoreImpl.java	2006-10-20 13:52:25 UTC (rev 6954)
@@ -52,6 +52,11 @@
 
 public class MessageStoreImpl implements MessageStore {
 	
+//	private Connection conn = null;
+//	private PreparedStatement ps = null;
+//	private ResultSet rs = null;
+	
+	
 	private DBConnectionManager mgr = null;	
 	
 	public MessageStoreImpl() {		
@@ -94,12 +99,20 @@
 			ps.setString(3, messageString);
 			ps.execute();
 			
-			conn.close();
-			ps.close();
 			
 		} catch (Exception e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		} //finally { release(); }
+		finally {
+			if (conn != null) {				
+				try{
+					ps.close();
+				}catch (Exception e1){}
+				try{
+					conn.close();
+				}catch(Exception e2){}
+			}
 		}
 		
 		return uid;
@@ -141,22 +154,50 @@
 				Object message = Base64.decodeToObject(msg);
 				return (org.jboss.internal.soa.esb.message.format.serialized.MessageImpl)message;		
 				
-			}
+			}			
 			
-			rs.close();
-			ps.close();
-			conn.close();
-			
 		} catch (SQLException e) {
 			e.printStackTrace();
 			return null;
 		} catch (Exception e) {
 			e.printStackTrace();
 			return null;
-		}	
+		}//finally { release(); }
+		finally {
+			if (conn != null) {
+				if (rs != null) {
+					try{
+						rs.close();
+					}catch (Exception e) {}
+				}
+				try{
+					ps.close();
+				}catch (Exception e1){}
+				try{
+					conn.close();
+				}catch(Exception e2){}			
+			}
+		}
 		
 		return null;
 	}
+	
+//	private void release() {
+//		
+//		if (conn != null) {
+//			if (rs != null) {
+//				try{
+//					rs.close();
+//				}catch (Exception e) {}
+//			}
+//			try{
+//				ps.close();
+//			}catch (Exception e1){}
+//			try{
+//				conn.close();
+//			}catch(Exception e2){}			
+//		}
+//	}