[jboss-svn-commits] JBL Code SVN: r8950 - labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/messagestore.

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

Author: mark.little at jboss.com
Date: 2007-01-21 04:52:43 -0500 (Sun, 21 Jan 2007)
New Revision: 8950

Modified:
   labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/messagestore/MessageStoreClient.java
Log:
Method signature changes for finer granularity exceptions.

Modified: labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/messagestore/MessageStoreClient.java
===================================================================
--- labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/messagestore/MessageStoreClient.java	2007-01-21 09:33:55 UTC (rev 8949)
+++ labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/messagestore/MessageStoreClient.java	2007-01-21 09:52:43 UTC (rev 8950)
@@ -33,61 +33,77 @@
 import org.jboss.soa.esb.services.persistence.MessageStoreFactory;
 import org.jboss.soa.esb.services.persistence.MessageStoreType;
 
-
-
 /**
  * @author dbrum
- *
+ * 
  */
-public class MessageStoreClient implements Runnable{
-	
+public class MessageStoreClient implements Runnable
+{
+
 	private static Logger logger = Logger.getLogger(MessageStoreTest.class);
 
-	
-	public void run() {
-		long startTime=System.currentTimeMillis();
-		
-		int requestors = 1000;	//number of persist calls to make
+	public void run ()
+	{
+		long startTime = System.currentTimeMillis();
+
+		int requestors = 1000; // number of persist calls to make
 		Vector<URI> writeList = new Vector<URI>();
-		
-//		get the database store
-		MessageStore store = MessageStoreFactory.getInstance().getMessageStore(MessageStoreType.DATABASE);
-		
-		//messages to persist
-		Message msg[] = { MessageFactory.getInstance().getMessage(MessageType.JBOSS_XML), 
-						 MessageFactory.getInstance().getMessage(MessageType.JAVA_SERIALIZED)};		
-		
-		//set some content inside the Messages
-		for (int x=0; x<msg.length; x++) {
+
+		// get the database store
+		MessageStore store = MessageStoreFactory.getInstance().getMessageStore(
+				MessageStoreType.DATABASE);
+
+		// messages to persist
+		Message msg[] = { MessageFactory.getInstance().getMessage(
+				MessageType.JBOSS_XML), MessageFactory.getInstance()
+				.getMessage(MessageType.JAVA_SERIALIZED) };
+
+		// set some content inside the Messages
+		for (int x = 0; x < msg.length; x++)
+		{
 			msg[x].getBody().setContents("TEST BODY".getBytes());
-			msg[x].getProperties().setProperty("prop"+x, "val"+x);
-			msg[x].getAttachment().addItem(new String("TEST ATTACHMENT"));						
+			msg[x].getProperties().setProperty("prop" + x, "val" + x);
+			msg[x].getAttachment().addItem(new String("TEST ATTACHMENT"));
 		}
-		
-		//loop through adding the messages
-		
+
+		// loop through adding the messages
+
 		Random rndMsg = new Random();
-		for (int x=0; x<=requestors; x++) {
-			URI uid = store.addMessage(msg[rndMsg.nextInt(2)]);
-			if (uid != null)
-				writeList.add(uid);
-			else
-				System.out.println("null was found... not adding uid to list...");
+		for (int x = 0; x <= requestors; x++)
+		{
+			try
+			{
+				URI uid = store.addMessage(msg[rndMsg.nextInt(2)]);
+				if (uid != null) writeList.add(uid);
+				else
+					System.err
+							.println("null was found... not adding uid to list...");
+			}
+			catch (Exception ex)
+			{
+				_logger.error("Adding message failed.", ex);
+			}
 		}
-		
-		logger.info("total messages persisted to db: " + (writeList.size()-1));
-		
-		//loop back reading the messages from the db
-		Vector<Message> readList = new Vector<Message> ();
-		for (int x=0; x<writeList.size(); x++) {
-			try {
-				readList.add(store.getMessage(writeList.get(x)));				
-			} catch (Exception e) {
+
+		logger
+				.info("total messages persisted to db: " + (writeList.size() - 1));
+
+		// loop back reading the messages from the db
+		Vector<Message> readList = new Vector<Message>();
+		for (int x = 0; x < writeList.size(); x++)
+		{
+			try
+			{
+				readList.add(store.getMessage(writeList.get(x)));
+			}
+			catch (Exception e)
+			{
 				logger.error(e);
 			}
 		}
-		logger.info("total messages read from db: " + (readList.size()-1));		
-		logger.info("time to finish write/read for this client: " + (System.currentTimeMillis()-startTime) + " milliseconds.");
+		logger.info("total messages read from db: " + (readList.size() - 1));
+		logger.info("time to finish write/read for this client: " + (System
+				.currentTimeMillis() - startTime) + " milliseconds.");
 
 	}
 }