[jboss-svn-commits] JBL Code SVN: r7217 - in labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer: . actions mockup

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

Author: daniel.brum at jboss.com
Date: 2006-10-29 22:11:53 -0500 (Sun, 29 Oct 2006)
New Revision: 7217

Added:
   labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/mockup/
   labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/mockup/MockLauncher.java
Removed:
   labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/MockLauncher.java
Modified:
   labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/LoanBrokerAction.java
Log:


Modified: labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/LoanBrokerAction.java
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/LoanBrokerAction.java	2006-10-30 03:03:54 UTC (rev 7216)
+++ labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/LoanBrokerAction.java	2006-10-30 03:11:53 UTC (rev 7217)
@@ -4,6 +4,9 @@
 import org.jboss.soa.esb.actions.templates.MockMessageAction;
 import org.jboss.soa.esb.helpers.ConfigTree;
 import org.jboss.soa.esb.message.Message;
+import org.jboss.soa.esb.services.persistence.MessageStore;
+import org.jboss.soa.esb.services.persistence.MessageStoreFactory;
+import org.jboss.soa.esb.services.persistence.MessageStoreType;
 import org.jboss.soa.esb.util.Util;
 
 public class LoanBrokerAction {
@@ -25,6 +28,15 @@
 		return message;
 	}
 	
+	public Message persistMessage(Message message) throws Exception {
+		System.out.println(this.getClass().getSimpleName() + " calling persistMessage()");
+		
+		MessageStore store = MessageStoreFactory.getInstance().getMessageStore(MessageStoreType.DATABASE);
+		store.addMessage(message);
+		
+		return message;
+	}
+	
 	Object getMessagePayload() 
 	{ 
 		return new String(_message.getBody().getContents()); 

Deleted: labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/MockLauncher.java
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/MockLauncher.java	2006-10-30 03:03:54 UTC (rev 7216)
+++ labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/MockLauncher.java	2006-10-30 03:11:53 UTC (rev 7217)
@@ -1,52 +0,0 @@
-package org.jboss.soa.esb.samples.trailblazer.actions;
-
-import org.apache.log4j.Logger;
-import org.jboss.soa.esb.addressing.EPR;
-import org.jboss.soa.esb.couriers.Courier;
-import org.jboss.soa.esb.couriers.CourierFactory;
-import org.jboss.soa.esb.listeners.message.EsbListenerController;
-import org.jboss.soa.esb.message.Message;
-import org.jboss.soa.esb.message.format.MessageFactory;
-
-public class MockLauncher {
-	
-	private static EsbListenerController _proc = null;
-	private static EPR _epr = null;
-	
-	private static final String SERVICE_NAME = "LoanRequestService";
-	@SuppressWarnings("unused")
-	private static Logger _logger = Logger.getLogger(MockLauncher.class);
-	
-	public static void main (String args[]) throws Exception {
-		triggerListener("/home/dbrum/dev/jbossesb/product/samples/trailblazer2/esb/conf/loanbroker-esb.xml");
-		// give the listener time to register
-		Thread.sleep(2000);
-		sendOneMessage();
-		_proc.requestEnd();
-		//give the action class time to finish
-		Thread.sleep(2000);
-
-		EsbListenerController.State oS = _proc.getState();
-		System.out.println("Exit state = "+oS.toString());
-	}
-	
-	private static void triggerListener(String paramFile) throws Exception {
-		_proc = new EsbListenerController(paramFile);
-		new Thread(_proc).start();
-	}
-		
-	private static void sendOneMessage() throws Exception{		
-		Message msg = MessageFactory.getInstance().getMessage();
-		msg.getBody().setContents("Foooooooooooooo".getBytes());		
-		try {
-			_epr = EsbListenerController.getEprManager().loadEPR(SERVICE_NAME); //TODO: replace with a real registry lookup
-		}catch(Exception e) {	
-			System.out.println("nobody servicing service " + SERVICE_NAME);
-			return;
-		}
-		Courier courier = CourierFactory.getCourier(_epr);
-		courier.deliver(msg);
-		
-	}
-
-}

Copied: labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/mockup/MockLauncher.java (from rev 7211, labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/MockLauncher.java)
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/MockLauncher.java	2006-10-30 02:58:49 UTC (rev 7211)
+++ labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/mockup/MockLauncher.java	2006-10-30 03:11:53 UTC (rev 7217)
@@ -0,0 +1,52 @@
+package org.jboss.soa.esb.samples.trailblazer.mockup;
+
+import org.apache.log4j.Logger;
+import org.jboss.soa.esb.addressing.EPR;
+import org.jboss.soa.esb.couriers.Courier;
+import org.jboss.soa.esb.couriers.CourierFactory;
+import org.jboss.soa.esb.listeners.message.EsbListenerController;
+import org.jboss.soa.esb.message.Message;
+import org.jboss.soa.esb.message.format.MessageFactory;
+
+public class MockLauncher {
+	
+	private static EsbListenerController _proc = null;
+	private static EPR _epr = null;
+	
+	private static final String SERVICE_NAME = "LoanRequestService";
+	@SuppressWarnings("unused")
+	private static Logger _logger = Logger.getLogger(MockLauncher.class);
+	
+	public static void main (String args[]) throws Exception {
+		triggerListener("/home/dbrum/dev/jbossesb/product/samples/trailblazer2/esb/conf/loanbroker-esb.xml");
+		// give the listener time to register
+		Thread.sleep(2000);
+		sendOneMessage();
+		_proc.requestEnd();
+		//give the action class time to finish
+		Thread.sleep(2000);
+
+		EsbListenerController.State oS = _proc.getState();
+		System.out.println("Exit state = "+oS.toString());
+	}
+	
+	private static void triggerListener(String paramFile) throws Exception {
+		_proc = new EsbListenerController(paramFile);
+		new Thread(_proc).start();
+	}
+		
+	private static void sendOneMessage() throws Exception{		
+		Message msg = MessageFactory.getInstance().getMessage();
+		msg.getBody().setContents("Foooooooooooooo".getBytes());		
+		try {
+			_epr = EsbListenerController.getEprManager().loadEPR(SERVICE_NAME); //TODO: replace with a real registry lookup
+		}catch(Exception e) {	
+			System.out.println("nobody servicing service " + SERVICE_NAME);
+			return;
+		}
+		Courier courier = CourierFactory.getCourier(_epr);
+		courier.deliver(msg);
+		
+	}
+
+}