[jboss-svn-commits] JBL Code SVN: r5341 - in labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks: src/org/jboss/soa/esb/samples/loanbroker/banks test/org/jboss/soa/esb/samples/loanbroker/banks

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

Author: kurt.stam at jboss.com
Date: 2006-07-28 09:31:23 -0400 (Fri, 28 Jul 2006)
New Revision: 5341

Modified:
   labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks/src/org/jboss/soa/esb/samples/loanbroker/banks/FlatFilePollManager.java
   labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks/test/org/jboss/soa/esb/samples/loanbroker/banks/FlatFileProcessorTest.java
Log:
adding bank code for the loan broker example

Modified: labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks/src/org/jboss/soa/esb/samples/loanbroker/banks/FlatFilePollManager.java
===================================================================
--- labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks/src/org/jboss/soa/esb/samples/loanbroker/banks/FlatFilePollManager.java	2006-07-28 12:55:35 UTC (rev 5340)
+++ labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks/src/org/jboss/soa/esb/samples/loanbroker/banks/FlatFilePollManager.java	2006-07-28 13:31:23 UTC (rev 5341)
@@ -54,9 +54,9 @@
 	private static final String BANK_NAME        = "FileBasedBank";
 	private static final BigDecimal RATE_PREMIUM = BigDecimal.valueOf(0.25);
 	private static final int MAXLOANTERM         = 120;
-	private static final String OUTGOING_DIR     = "outgoing";
-	private static final String PREFIX           = "reply_to_";
-	private static final String PROCESSED_DIR    = "processed";
+	protected static final String OUTGOING_DIR   = "outgoing";
+	protected static final String PREFIX         = "reply_to_";
+	protected static final String PROCESSED_DIR  = "processed";
 	/**
 	 * Handle to the cycle start event.
 	 */
@@ -119,7 +119,7 @@
 	 * 
 	 * @param file - incoming flat file with loan quote request info.
 	 */
-	private void processFile(File file) 
+	protected void processFile(File file) 
 	{
 		BankQuoteReply bankQuoteReply=new BankQuoteReply();
 		bankQuoteReply.setQuoteId(BANK_NAME);

Modified: labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks/test/org/jboss/soa/esb/samples/loanbroker/banks/FlatFileProcessorTest.java
===================================================================
--- labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks/test/org/jboss/soa/esb/samples/loanbroker/banks/FlatFileProcessorTest.java	2006-07-28 12:55:35 UTC (rev 5340)
+++ labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks/test/org/jboss/soa/esb/samples/loanbroker/banks/FlatFileProcessorTest.java	2006-07-28 13:31:23 UTC (rev 5341)
@@ -24,7 +24,6 @@
 import static org.junit.Assert.*;
 
 import java.io.File;
-import java.math.BigDecimal;
 
 import junit.framework.JUnit4TestAdapter;
 
@@ -35,10 +34,11 @@
 public class FlatFileProcessorTest {
 
 	private Logger logger = Logger.getLogger(this.getClass());
-	
+	private static String FLAT_FILE = "FlatFileProcessorTest.txt";
 	/**
 	 * Tests the processing of flat file containing a loan quote request. First
-	 * we try to find a temporary directory
+	 * we try to find a temporary directory. When this succeeds we drop a
+	 * load request file in there and try to process it.
 	 *
 	 */
 	@Test public void processRequest()
@@ -58,7 +58,51 @@
 			    assertTrue(false);
 			}
 		}
-
+//		We found a temp space so now we can drop in a load request file.
+		try {
+			logger.log(Priority.INFO, "Creating " + FLAT_FILE + " file in " + writableDir.getAbsolutePath());
+			File loanRequestFile = new File(writableDir.getAbsolutePath() + "/"+ FLAT_FILE);
+			if (loanRequestFile.exists()) {
+				loanRequestFile.delete();
+			}
+			loanRequestFile.createNewFile();
+			String str="23456890,3,4,20000,5";
+			FileUtil.writeTextFile(loanRequestFile, str);
+			
+			logger.log(Priority.INFO, "Processing FlatFileProcessorTest.txt");
+			FlatFilePollManager pollManager = new FlatFilePollManager();
+			pollManager.processFile(loanRequestFile);
+			
+			//Check to see if the file is now moved.
+			assertFalse(loanRequestFile.exists());
+			
+			File processedFile = new File(writableDir.getAbsolutePath() + "/" 
+				+ FlatFilePollManager.PROCESSED_DIR + "/" + FLAT_FILE);
+			logger.log(Priority.INFO, "Check to see if " + processedFile.getAbsolutePath()
+					+ " exists");
+			assertTrue(processedFile.exists());
+			logger.log(Priority.INFO, "OK");
+			
+			File replyToFile = new File(writableDir.getAbsolutePath() + "/" 
+				+ FlatFilePollManager.OUTGOING_DIR + "/" + FlatFilePollManager.PREFIX
+				+ FLAT_FILE);
+			logger.log(Priority.INFO, "Check to see if " + replyToFile.getAbsolutePath()
+					+ " exists");
+			assertTrue(replyToFile.exists());
+			logger.log(Priority.INFO, "OK");
+			
+			//Checking the content of the reply
+			logger.log(Priority.INFO, "Check the reply, should be ('8.29,FileBasedBank-0,0'");
+			assertTrue("8.29,FileBasedBank-0,0".equals(FileUtil.readTextFile(replyToFile)));
+			logger.log(Priority.INFO, "OK");
+			//Cleaning up
+			processedFile.delete();
+			replyToFile.delete();
+			
+		} catch (Throwable e) {
+			logger.log(Priority.ERROR,e.getMessage(),e);
+			assertTrue(false);
+		}
 	}
 	
 	public static junit.framework.Test suite() {