[jboss-svn-commits] JBL Code SVN: r6860 - 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-17 11:31:10 -0400 (Tue, 17 Oct 2006)
New Revision: 6860

Modified:
   labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/persistence/format/db/MessageStoreImpl.java
Log:
changed to use URI instead of String on method calls

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-17 15:30:40 UTC (rev 6859)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/persistence/format/db/MessageStoreImpl.java	2006-10-17 15:31:10 UTC (rev 6860)
@@ -52,26 +52,24 @@
 
 public class MessageStoreImpl implements MessageStore {
 	
-	private DBConnectionManager mgr = null;
+	private DBConnectionManager mgr = null;	
 	
 	public MessageStoreImpl() {		
 		mgr = DBConnectionManager.getInstance();
 	}
 	
-	public String addMessage(Message message){
+	public URI addMessage(Message message){
 		
 		Connection conn = null;
 		PreparedStatement ps = null;
 		String messageString = null;
-		String uid = null;
+		URI uid = null;		
 		
-		//get a UID
-		String uuid = UUID.randomUUID().toString();
-		uid = "urn:jboss:esb:message:UID:" + uuid;
-		
 		try {			
-			conn = mgr.getConnection();				
+			conn = mgr.getConnection();
 			
+			uid = new URI("urn:jboss:esb:message:UID:" + UUID.randomUUID().toString());
+			
 			if (message.getType().equals(MessageType.JBOSS_XML) ) {
 				Document doc = DocumentBuilderFactory.newInstance().newDocumentBuilder().newDocument();
 				((org.jboss.internal.soa.esb.message.format.xml.MessageImpl)message).toXML(doc);					
@@ -91,7 +89,7 @@
 			//insert into the database
 			String sql = "insert into message(uid, type, message) values(?,?,?)";
 			ps = conn.prepareStatement(sql);
-			ps.setString(1, uid);
+			ps.setString(1, uid.toString());
 			ps.setString(2, message.getType().toString());
 			ps.setString(3, messageString);
 			ps.execute();
@@ -107,7 +105,7 @@
 		return uid;
 	}
 
-	public Message getMessage(String uid) throws Exception{
+	public Message getMessage(URI uid) throws Exception{
 		
 		Connection conn = null;
 		PreparedStatement ps = null;
@@ -118,7 +116,7 @@
 		try {
 			conn = mgr.getConnection();
 			ps = conn.prepareStatement(sql);
-			ps.setString(1, uid);
+			ps.setString(1, uid.toString());
 			
 			rs = ps.executeQuery();
 			if (! rs.next()) throw new Exception("Non existing Message for UID: " + uid);