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

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

Author: kurt.stam at jboss.com
Date: 2006-07-27 21:50:16 -0400 (Thu, 27 Jul 2006)
New Revision: 5332

Modified:
   labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks/src/org/jboss/soa/esb/samples/loanbroker/banks/BankPollManager.java
   labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks/src/org/jboss/soa/esb/samples/loanbroker/banks/FileUtil.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/BankPollManager.java
===================================================================
--- labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks/src/org/jboss/soa/esb/samples/loanbroker/banks/BankPollManager.java	2006-07-28 01:41:26 UTC (rev 5331)
+++ labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks/src/org/jboss/soa/esb/samples/loanbroker/banks/BankPollManager.java	2006-07-28 01:50:16 UTC (rev 5332)
@@ -42,6 +42,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";
 	
 	public void cycleStarted(CycleStartEvent evt) {
 		logger.log(Priority.DEBUG, "Poller awakened "
@@ -88,27 +91,38 @@
 				errorCode=4;
 				bankQuoteRequest.setLoanAmount(Integer.valueOf(messagePart[3]));
 				errorCode=5;
-				bankQuoteRequest.setLoanTerm(Integer.valueOf(messagePart[5]));
+				bankQuoteRequest.setLoanTerm(Integer.valueOf(messagePart[4]));
 				
 				Bank fileBasedBank = new Bank(BANK_NAME, RATE_PREMIUM, MAXLOANTERM);
 				bankQuoteReply = fileBasedBank.processMessage(bankQuoteRequest);
 				
-			} catch (Exception e) {
-				logger.log(Priority.ERROR, e.getMessage(), e);
+			} catch (Throwable e) {
+				logger.log(Priority.ERROR, e.getMessage());
 				bankQuoteReply.setErrorCode(errorCode);
 			}
 			
 			try {
-				File outgoingFile = new File(file.getAbsolutePath() + "/outgoing/reply_" + file.getName());
+				File outgoingDir  = new File(file.getParent() + "/" + OUTGOING_DIR);
+				if (!outgoingDir.exists()) {
+					outgoingDir.mkdir();
+				}
+				File outgoingFile = new File(outgoingDir + "/" + PREFIX + file.getName());
 				logger.log(Priority.INFO, "Creating outgoing file " + outgoingFile.getAbsolutePath());
 				outgoingFile.createNewFile();
 				String reply=bankQuoteReply.getInterestRate() + "," + bankQuoteReply.getQuoteId() + "," + bankQuoteReply.getErrorCode();
 				logger.log(Priority.INFO, "Writing reply " + reply);
 				FileUtil.writeTextFile(outgoingFile, reply);
 				
+				File processedDir  = new File(file.getParent() + "/" + PROCESSED_DIR);
+				if (!processedDir.exists()) {
+					processedDir.mkdir();
+				}
 				logger.log(Priority.INFO, "Moving file " + file.getName() + " to processed directory");
-				File processedFile = new File(file.getAbsolutePath() + "/processed/" + file.getName());
+				File processedFile = new File(processedDir.getAbsolutePath() + "/" + file.getName());
 				file.renameTo(processedFile);
+				if (file.exists()) {
+					file.delete();
+				}
 			} catch (Exception e) {
 				logger.log(Priority.ERROR, e.getMessage(), e);
 			}

Modified: labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks/src/org/jboss/soa/esb/samples/loanbroker/banks/FileUtil.java
===================================================================
--- labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks/src/org/jboss/soa/esb/samples/loanbroker/banks/FileUtil.java	2006-07-28 01:41:26 UTC (rev 5331)
+++ labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/banks/src/org/jboss/soa/esb/samples/loanbroker/banks/FileUtil.java	2006-07-28 01:50:16 UTC (rev 5332)
@@ -13,10 +13,10 @@
     {
         StringBuffer sb = new StringBuffer(1024);
         BufferedReader reader = new BufferedReader(new FileReader(file.getPath()));
-        char[] chars = new char[1024];
+        char[] chars = new char[1];
         while( (reader.read(chars)) > -1){
             sb.append(String.valueOf(chars)); 
-            chars = new char[1024];
+            chars = new char[1];
         }
         reader.close();
         return sb.toString();