[overlord-commits] Overlord SVN: r637 - in cdl/trunk/samples/jbossesb/brokerage/broker/stateless/src/main: resources/META-INF and 1 other directory.
overlord-commits at lists.jboss.org
overlord-commits at lists.jboss.org
Tue May 5 06:39:09 EDT 2009
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"/>
More information about the overlord-commits
mailing list