5:39 a.m.
Author: jeff.yuchang
Date: 2009-05-05 06:39:08 -0400 (Tue, 05 May 2009)
New Revision: 637
Added:
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/ResetMemoryStoreAction.java
Modified:
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/MemoryStore.java
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/SetOrderConfirmRequestAction.java
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/SetRequestQuoteMessageAction.java
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/resources/META-INF/jboss-esb.xml
Log:
Fix the stateless broker example. (so that it can be running mulitple times)
Modified:
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/MemoryStore.java
===================================================================
---
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/MemoryStore.java 2009-05-05
08:22:26 UTC (rev 636)
+++
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/MemoryStore.java 2009-05-05
10:39:08 UTC (rev 637)
@@ -38,5 +38,9 @@
public static int getCounter() {
return counter;
}
+
+ public static void reset() {
+ counter = 0;
+ }
}
Added:
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/ResetMemoryStoreAction.java
===================================================================
---
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/ResetMemoryStoreAction.java
(rev 0)
+++
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/ResetMemoryStoreAction.java 2009-05-05
10:39:08 UTC (rev 637)
@@ -0,0 +1,43 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2008, JBoss Inc., and others contributors as indicated
+ * by the @authors tag. All rights reserved.
+ * See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ * This copyrighted material is made available to anyone wishing to use,
+ * modify, copy, or redistribute it subject to the terms and conditions
+ * of the GNU Lesser General Public License, v. 2.1.
+ * This program is distributed in the hope that it will be useful, but WITHOUT A
+ * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
+ * PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
+ * You should have received a copy of the GNU Lesser General Public License,
+ * v.2.1 along with this distribution; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
+ * MA 02110-1301, USA.
+ *
+ * (C) 2008,
+ */
+package org.jboss.soa.overlord.samples.jbossesb.loan.broker;
+
+import org.apache.log4j.Logger;
+import org.jboss.soa.esb.actions.AbstractActionLifecycle;
+import org.jboss.soa.esb.helpers.ConfigTree;
+import org.jboss.soa.esb.message.Message;
+
+public class ResetMemoryStoreAction extends AbstractActionLifecycle {
+
+ private static Logger logger = Logger.getLogger(ResetMemoryStoreAction.class);
+
+ private ConfigTree config;
+
+ public ResetMemoryStoreAction(ConfigTree config) {
+ this.config = config;
+ }
+
+ public Message process(Message message) throws Exception{
+ MemoryStore.reset();
+ logger.info("Reseting the memory store counter to 0");
+ return(message);
+ }
+
+}
\ No newline at end of file
Modified:
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/SetOrderConfirmRequestAction.java
===================================================================
---
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/SetOrderConfirmRequestAction.java 2009-05-05
08:22:26 UTC (rev 636)
+++
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/SetOrderConfirmRequestAction.java 2009-05-05
10:39:08 UTC (rev 637)
@@ -43,11 +43,9 @@
public Message process(Message message) throws Exception {
Node node = XMLUtils.getNode((String)message.getBody().get());
String idValue = node.getAttributes().getNamedItem("id").getNodeValue();
- String supplier = (String)
message.getProperties().getProperty("supplierDesc");
- String quoteValue =
(String)message.getProperties().getProperty("quoteValue");
- message.getBody().add("<orderConfirmed id=\"" + idValue
+"\" supplierDesc=\""
- + supplier+"\" quoteValue=\"" + quoteValue +
"\"></orderConfirmed>");
+ message.getBody().add("<orderConfirmed id=\"" + idValue
+"\"
supplierDesc=\"{http://www.jboss.org/overlord/loanBroker}Supplier1\&...
quoteValue=\"10\">" +
+ "</orderConfirmed>");
logger.info(message.getBody().get());
Modified:
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/SetRequestQuoteMessageAction.java
===================================================================
---
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/SetRequestQuoteMessageAction.java 2009-05-05
08:22:26 UTC (rev 636)
+++
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/java/org/jboss/soa/overlord/samples/jbossesb/loan/broker/SetRequestQuoteMessageAction.java 2009-05-05
10:39:08 UTC (rev 637)
@@ -48,7 +48,7 @@
message.getBody().add("<requestForQuote id=\"" + idValue
+"\" supplierDesc=\"" + serviceDescription+ "\"
></requestForQuote>");
- logger.info("Set 'requestForQuote' : "+message);
+ logger.info("Set 'requestForQuote' : " + message.getBody().get());
return message;
}
Modified:
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/resources/META-INF/jboss-esb.xml
===================================================================
---
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/resources/META-INF/jboss-esb.xml 2009-05-05
08:22:26 UTC (rev 636)
+++
cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main/resources/META-INF/jboss-esb.xml 2009-05-05
10:39:08 UTC (rev 637)
@@ -82,6 +82,8 @@
<property name="clientRole"
value="Buyer"/>
<property name="eprStore"
value="org.jboss.soa.overlord.samples.jbossesb.loan.broker.MemoryEPRStorage"
/>
</action>
+ <action
class="org.jboss.soa.overlord.samples.jbossesb.loan.broker.ResetMemoryStoreAction"
name="resetMemoryStore" process="process">
+ </action>
<action
class="org.jboss.soa.overlord.jbossesb.stateless.actions.IfAction"
name="ESBBrokerProcess_Broker__1_action_2" process="process">
<property name="paths">
<if
service-category="org.pi4soa.esbbroker.esbbroker"
service-name="ESBBrokerProcess_Broker__2"
decision-class="org.jboss.soa.overlord.samples.jbossesb.loan.broker.SendReqForQuoteDecision"/>