[jbpm-commits] JBoss JBPM SVN: r1811 - in jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket: server and 1 other directory.

do-not-reply at jboss.org do-not-reply at jboss.org
Sun Aug 3 20:31:52 EDT 2008


Author: thomas.diesler at jboss.com
Date: 2008-08-03 20:31:52 -0400 (Sun, 03 Aug 2008)
New Revision: 1811

Modified:
   jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/AirticketProcessBuilder.java
   jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/AvailabilityHandler.java
   jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/ValidationHandler.java
   jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/server/AirticketServiceImpl.java
Log:
Sync with BPMN names

Modified: jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/AirticketProcessBuilder.java
===================================================================
--- jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/AirticketProcessBuilder.java	2008-08-02 23:47:24 UTC (rev 1810)
+++ jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/AirticketProcessBuilder.java	2008-08-04 00:31:52 UTC (rev 1811)
@@ -42,6 +42,47 @@
  */
 public class AirticketProcessBuilder
 {
+  public static final String PROCESS_NAME = "Airticket";
+  
+  public static final String EVENT_END = "End";
+
+  public static final String GATEWAY_IS_ACCEPTED = "IsAccepted";
+  public static final String GATEWAY_IS_AVAILABLE = "IsAvailable";
+  public static final String GATEWAY_IS_VALID = "IsValid";
+  public static final String GATEWAY_SPLIT = "Split";
+  public static final String GATEWAY_SYNC_JOIN = "SyncJoin";
+  
+  public static final String TASK_BOOKING = "Booking";
+  public static final String TASK_CHECK_AVAILABLE = "CheckAvailable";
+  public static final String TASK_CREDIT_CARD = "CreditCard";
+  public static final String TASK_RECEIVE_ORDER = "ReceiveOrder";
+  public static final String TASK_RECEIVE_REQUEST = "ReceiveReq";
+  public static final String TASK_SEND_CONFIRM = "SendConfirm";
+  public static final String TASK_SEND_NOT_AVAILABLE = "SendNotAvailable";
+  public static final String TASK_SEND_OFFER = "SendOffer";
+  public static final String TASK_SEND_INVALID = "SendInvalid";
+  public static final String TASK_VALIDATE = "Validate";
+  
+  public static final String MESSAGE_CONFIRM = "ConfirmMsg";
+  public static final String MESSAGE_ACCEPT_OFFER = "AcceptOfferMsg";
+  public static final String MESSAGE_OFFER = "OfferMsg";
+  public static final String MESSAGE_NOT_AVAILABLE = "NotAvailableMsg";
+  public static final String MESSAGE_INVALID_DATA = "InvalidDataMsg";
+  public static final String MESSAGE_REQ_DATA = "ReqDataMsg";
+  
+  public static final String PROPERTY_NAME = "Name";
+  public static final String PROPERTY_FROM = "From";
+  public static final String PROPERTY_TO = "To";
+  public static final String PROPERTY_DATE = "Date";
+  public static final String PROPERTY_SEATS = "Seats";
+  public static final String PROPERTY_CREDIT_CARD = "CreditCard";
+  public static final String PROPERTY_EXPIRE = "Expire";
+  public static final String PROPERTY_PRICE = "Price";
+  
+  public static final String PROPERTY_IS_VALID_REQUEST = "isReqDataValid";
+  public static final String PROPERTY_IS_AVAILABLE = "isAvailable";
+  public static final String PROPERTY_IS_OFFER_ACCEPTED = "isOfferAccepted";
+  
   private ObjectName listenerID;
   
   public AirticketProcessBuilder(ObjectName listenerID)
@@ -54,163 +95,163 @@
     // Create a Process through the ProcessBuilder
     ProcessBuilderFactory procFactory = ProcessBuilderFactory.newInstance();
     ProcessBuilder procBuilder = procFactory.newProcessBuilder();
-    procBuilder.addProcess("Airticket");
+    procBuilder.addProcess(PROCESS_NAME);
     
     // Add Start Event
-    procBuilder.addStartEvent().addSequenceFlow("ReceiveReq");
+    procBuilder.addStartEvent().addSequenceFlow(TASK_RECEIVE_REQUEST);
 
     // Build the ReceiveReqTask
-    TaskBuilder taskBuilder = procBuilder.addTask("ReceiveReq", TaskType.Receive);
-    taskBuilder.addMessageRef("ReqDataMsg").
-    addSequenceFlow("Validate");
+    TaskBuilder taskBuilder = procBuilder.addTask(TASK_RECEIVE_REQUEST, TaskType.Receive);
+    taskBuilder.addMessageRef(MESSAGE_REQ_DATA).
+    addSequenceFlow(TASK_VALIDATE);
 
     // Build the ValidateTask
-    taskBuilder = procBuilder.addTask("Validate");
+    taskBuilder = procBuilder.addTask(TASK_VALIDATE);
     taskBuilder.addExecutionHandler(ValidationHandler.class).
     addInputSet().
-    addPropertyInput("Name", null).
-    addPropertyInput("From", null).
-    addPropertyInput("To", null).
-    addPropertyInput("Date", null).
-    addPropertyInput("Seats", null).
+    addPropertyInput(PROPERTY_NAME, null).
+    addPropertyInput(PROPERTY_FROM, null).
+    addPropertyInput(PROPERTY_TO, null).
+    addPropertyInput(PROPERTY_DATE, null).
+    addPropertyInput(PROPERTY_SEATS, null).
     addOutputSet().
-    addPropertyOutput("isReqDataValid", null).
-    addSequenceFlow("IsValid");
+    addPropertyOutput(PROPERTY_IS_VALID_REQUEST, null).
+    addSequenceFlow(GATEWAY_IS_VALID);
 
     // Build the ValidateGateway
-    GatewayBuilder gatewayBuilder = procBuilder.addGateway("IsValid", GatewayType.Exclusive);
-    gatewayBuilder.addConditionalGate("CheckAvailable", ExpressionLanguage.MVEL, "isReqDataValid == true").
-    addDefaultGate("SendInvalid");
+    GatewayBuilder gatewayBuilder = procBuilder.addGateway(GATEWAY_IS_VALID, GatewayType.Exclusive);
+    gatewayBuilder.addConditionalGate(TASK_CHECK_AVAILABLE, ExpressionLanguage.MVEL, "isReqDataValid == true").
+    addDefaultGate(TASK_SEND_INVALID);
 
     // Build the CheckAvailabilityTask
-    taskBuilder = procBuilder.addTask("CheckAvailable");
+    taskBuilder = procBuilder.addTask(TASK_CHECK_AVAILABLE);
     taskBuilder.addExecutionHandler(AvailabilityHandler.class).
     addInputSet().
-    addPropertyInput("From", null).
-    addPropertyInput("To", null).
-    addPropertyInput("Date", null).
-    addPropertyInput("Seats", null).
+    addPropertyInput(PROPERTY_FROM, null).
+    addPropertyInput(PROPERTY_TO, null).
+    addPropertyInput(PROPERTY_DATE, null).
+    addPropertyInput(PROPERTY_SEATS, null).
     addOutputSet().
-    addPropertyOutput("isAvailable", null).
-    addPropertyOutput("Price", null).
-    addSequenceFlow("IsAvailable");
+    addPropertyOutput(PROPERTY_IS_AVAILABLE, null).
+    addPropertyOutput(PROPERTY_PRICE, null).
+    addSequenceFlow(GATEWAY_IS_AVAILABLE);
 
     // Build the SendInvalidTask
-    taskBuilder = procBuilder.addTask("SendInvalid", TaskType.Send);
-    taskBuilder.addMessageRef("InvalidDataMsg").
-    addSequenceFlow("ReceiveReq");
+    taskBuilder = procBuilder.addTask(TASK_SEND_INVALID, TaskType.Send);
+    taskBuilder.addMessageRef(MESSAGE_INVALID_DATA).
+    addSequenceFlow(TASK_RECEIVE_REQUEST);
 
     // Build the AvailabilityGateway
-    gatewayBuilder = procBuilder.addGateway("IsAvailable", GatewayType.Exclusive);
-    gatewayBuilder.addConditionalGate("SendOffer", ExpressionLanguage.MVEL, "isAvailable == true").
-    addDefaultGate("SendNotAvailable");
+    gatewayBuilder = procBuilder.addGateway(GATEWAY_IS_AVAILABLE, GatewayType.Exclusive);
+    gatewayBuilder.addConditionalGate(TASK_SEND_OFFER, ExpressionLanguage.MVEL, "isAvailable == true").
+    addDefaultGate(TASK_SEND_NOT_AVAILABLE);
     
     // Build the SendOfferTask
-    taskBuilder = procBuilder.addTask("SendOffer", TaskType.Send);
-    taskBuilder.addMessageRef("OfferMsg").
-    addSequenceFlow("ReceiveOrder");
+    taskBuilder = procBuilder.addTask(TASK_SEND_OFFER, TaskType.Send);
+    taskBuilder.addMessageRef(MESSAGE_OFFER).
+    addSequenceFlow(TASK_RECEIVE_ORDER);
 
     // Build the SendNotAvailableTask
-    taskBuilder = procBuilder.addTask("SendNotAvailable", TaskType.Send);
-    taskBuilder.addMessageRef("NotAvailableMsg").
-    addSequenceFlow("ReceiveReq");
+    taskBuilder = procBuilder.addTask(TASK_SEND_NOT_AVAILABLE, TaskType.Send);
+    taskBuilder.addMessageRef(MESSAGE_NOT_AVAILABLE).
+    addSequenceFlow(TASK_RECEIVE_REQUEST);
 
     // Build the ReceiveReqTask
-    taskBuilder = procBuilder.addTask("ReceiveOrder", TaskType.Receive);
-    taskBuilder.addMessageRef("AcceptOfferMsg").
-    addSequenceFlow("IsAccepted");
+    taskBuilder = procBuilder.addTask(TASK_RECEIVE_ORDER, TaskType.Receive);
+    taskBuilder.addMessageRef(MESSAGE_ACCEPT_OFFER).
+    addSequenceFlow(GATEWAY_IS_ACCEPTED);
     
     // Build the AcceptOfferGateway
-    gatewayBuilder = procBuilder.addGateway("IsAccepted", GatewayType.Exclusive);
-    gatewayBuilder.addConditionalGate("Split", ExpressionLanguage.MVEL, "isOfferAccepted == true").
-    addDefaultGate("ReceiveReq");
+    gatewayBuilder = procBuilder.addGateway(GATEWAY_IS_ACCEPTED, GatewayType.Exclusive);
+    gatewayBuilder.addConditionalGate(GATEWAY_SPLIT, ExpressionLanguage.MVEL, "isOfferAccepted == true").
+    addDefaultGate(TASK_RECEIVE_REQUEST);
     
     // Build the AcceptOfferGateway
-    gatewayBuilder = procBuilder.addGateway("Split", GatewayType.Parallel);
-    gatewayBuilder.addGate("CreditCard").
-    addGate("Booking");
+    gatewayBuilder = procBuilder.addGateway(GATEWAY_SPLIT, GatewayType.Parallel);
+    gatewayBuilder.addGate(TASK_CREDIT_CARD).
+    addGate(TASK_BOOKING);
     
     // Build the CreditCardTask
-    taskBuilder = procBuilder.addTask("CreditCard");
+    taskBuilder = procBuilder.addTask(TASK_CREDIT_CARD);
     taskBuilder.addInputSet().
-    addPropertyInput("CreditCard", null).
-    addPropertyInput("Expire", null).
-    addPropertyInput("Price", null).
-    addSequenceFlow("SyncJoin");
+    addPropertyInput(PROPERTY_CREDIT_CARD, null).
+    addPropertyInput(PROPERTY_EXPIRE, null).
+    addPropertyInput(PROPERTY_PRICE, null).
+    addSequenceFlow(GATEWAY_SYNC_JOIN);
     
     // Build the BookingTask
-    taskBuilder = procBuilder.addTask("Booking");
+    taskBuilder = procBuilder.addTask(TASK_BOOKING);
     taskBuilder.addInputSet().
-    addPropertyInput("Name", null).
-    addPropertyInput("From", null).
-    addPropertyInput("To", null).
-    addPropertyInput("Date", null).
-    addPropertyInput("Seats", null).
-    addSequenceFlow("SyncJoin");
+    addPropertyInput(PROPERTY_NAME, null).
+    addPropertyInput(PROPERTY_FROM, null).
+    addPropertyInput(PROPERTY_TO, null).
+    addPropertyInput(PROPERTY_DATE, null).
+    addPropertyInput(PROPERTY_SEATS, null).
+    addSequenceFlow(GATEWAY_SYNC_JOIN);
     
     // Build the SynchronizedJoinGateway
-    gatewayBuilder = procBuilder.addGateway("SyncJoin", GatewayType.Parallel);
-    gatewayBuilder.addGate("SendConfirm");
+    gatewayBuilder = procBuilder.addGateway(GATEWAY_SYNC_JOIN, GatewayType.Parallel);
+    gatewayBuilder.addGate(TASK_SEND_CONFIRM);
     
     // Build the SendConfirmTask
-    taskBuilder = procBuilder.addTask("SendConfirm", TaskType.Send);
-    taskBuilder.addMessageRef("ConfirmMsg").
-    addSequenceFlow("End");
+    taskBuilder = procBuilder.addTask(TASK_SEND_CONFIRM, TaskType.Send);
+    taskBuilder.addMessageRef(MESSAGE_CONFIRM).
+    addSequenceFlow(EVENT_END);
     
     // Add the EndEvent
-    procBuilder.addEndEvent("End");
+    procBuilder.addEndEvent(EVENT_END);
 
     // Add ReqDataMsg 
-    procBuilder.addMessage("ReqDataMsg").
-    addProperty("Name", null, true).
-    addProperty("From", null, true).
-    addProperty("To", null, true).
-    addProperty("Date", null, true).
-    addProperty("Seats", null, true);
+    procBuilder.addMessage(MESSAGE_REQ_DATA).
+    addProperty(PROPERTY_NAME, null, true).
+    addProperty(PROPERTY_FROM, null, true).
+    addProperty(PROPERTY_TO, null, true).
+    addProperty(PROPERTY_DATE, null, true).
+    addProperty(PROPERTY_SEATS, null, true);
     
     // Add InvalidDataMsg 
-    procBuilder.addMessage("InvalidDataMsg").
+    procBuilder.addMessage(MESSAGE_INVALID_DATA).
     addToRef(listenerID).
-    addProperty("Name", null, true).
-    addProperty("From", null, true).
-    addProperty("To", null, true).
-    addProperty("Date", null, true).
-    addProperty("Seats", null, true);
+    addProperty(PROPERTY_NAME, null, true).
+    addProperty(PROPERTY_FROM, null, true).
+    addProperty(PROPERTY_TO, null, true).
+    addProperty(PROPERTY_DATE, null, true).
+    addProperty(PROPERTY_SEATS, null, true);
     
     // Add NotAvailableMsg 
-    procBuilder.addMessage("NotAvailableMsg").
+    procBuilder.addMessage(MESSAGE_NOT_AVAILABLE).
     addToRef(listenerID).
-    addProperty("Name", null, true).
-    addProperty("From", null, true).
-    addProperty("To", null, true).
-    addProperty("Date", null, true).
-    addProperty("Seats", null, true);
+    addProperty(PROPERTY_NAME, null, true).
+    addProperty(PROPERTY_FROM, null, true).
+    addProperty(PROPERTY_TO, null, true).
+    addProperty(PROPERTY_DATE, null, true).
+    addProperty(PROPERTY_SEATS, null, true);
     
     // Add OfferMsg 
-    procBuilder.addMessage("OfferMsg").
+    procBuilder.addMessage(MESSAGE_OFFER).
     addToRef(listenerID).
-    addProperty("Name", null, true).
-    addProperty("From", null, true).
-    addProperty("To", null, true).
-    addProperty("Date", null, true).
-    addProperty("Seats", null, true).
-    addProperty("Price", null, true);
+    addProperty(PROPERTY_NAME, null, true).
+    addProperty(PROPERTY_FROM, null, true).
+    addProperty(PROPERTY_TO, null, true).
+    addProperty(PROPERTY_DATE, null, true).
+    addProperty(PROPERTY_SEATS, null, true).
+    addProperty(PROPERTY_PRICE, null, true);
     
     // Add AcceptOfferMsg 
-    procBuilder.addMessage("AcceptOfferMsg").
-    addProperty("CreditCard", null, true).
-    addProperty("Expire", null, true).
-    addProperty("isOfferAccepted", null, true);
+    procBuilder.addMessage(MESSAGE_ACCEPT_OFFER).
+    addProperty(TASK_CREDIT_CARD, null, true).
+    addProperty(PROPERTY_EXPIRE, null, true).
+    addProperty(PROPERTY_IS_OFFER_ACCEPTED, null, true);
     
     // Add ConfirmMsg 
-    procBuilder.addMessage("ConfirmMsg").
+    procBuilder.addMessage(MESSAGE_CONFIRM).
     addToRef(listenerID).
-    addProperty("Name", null, true).
-    addProperty("From", null, true).
-    addProperty("To", null, true).
-    addProperty("Date", null, true).
-    addProperty("Seats", null, true).
-    addProperty("Price", null, true);
+    addProperty(PROPERTY_NAME, null, true).
+    addProperty(PROPERTY_FROM, null, true).
+    addProperty(PROPERTY_TO, null, true).
+    addProperty(PROPERTY_DATE, null, true).
+    addProperty(PROPERTY_SEATS, null, true).
+    addProperty(PROPERTY_PRICE, null, true);
     
     // Get the process
     Process proc = procBuilder.getProcess(true);

Modified: jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/AvailabilityHandler.java
===================================================================
--- jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/AvailabilityHandler.java	2008-08-02 23:47:24 UTC (rev 1810)
+++ jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/AvailabilityHandler.java	2008-08-04 00:31:52 UTC (rev 1811)
@@ -42,8 +42,8 @@
   public void execute(Token token, InputSet inputSet, OutputSet outputSet)
   {
     PropertyBuilder builder = PropertyBuilderFactory.newInstance().newPropertyBuilder();
-    Integer seats = Integer.valueOf(inputSet.getPropertyValue("Seats"));
-    outputSet.addProperty(builder.newProperty("isAvailable", new Boolean(seats < 10).toString()));
-    outputSet.addProperty(builder.newProperty("Price", new Integer(seats * 111).toString()));
+    Integer seats = Integer.valueOf(inputSet.getPropertyValue(AirticketProcessBuilder.PROPERTY_SEATS));
+    outputSet.addProperty(builder.newProperty(AirticketProcessBuilder.PROPERTY_IS_AVAILABLE, new Boolean(seats < 10).toString()));
+    outputSet.addProperty(builder.newProperty(AirticketProcessBuilder.PROPERTY_PRICE, new Integer(seats * 111).toString()));
   }
 }

Modified: jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/ValidationHandler.java
===================================================================
--- jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/ValidationHandler.java	2008-08-02 23:47:24 UTC (rev 1810)
+++ jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/ValidationHandler.java	2008-08-04 00:31:52 UTC (rev 1811)
@@ -41,11 +41,11 @@
 {
   public void execute(Token token, InputSet inputSet, OutputSet outputSet)
   {
-    String name = inputSet.getPropertyValue("Name");
-    String from = inputSet.getPropertyValue("From");
-    String to = inputSet.getPropertyValue("To");
-    String date = inputSet.getPropertyValue("Date");
-    String seats = inputSet.getPropertyValue("Seats");
+    String name = inputSet.getPropertyValue(AirticketProcessBuilder.PROPERTY_NAME);
+    String from = inputSet.getPropertyValue(AirticketProcessBuilder.PROPERTY_FROM);
+    String to = inputSet.getPropertyValue(AirticketProcessBuilder.PROPERTY_TO);
+    String date = inputSet.getPropertyValue(AirticketProcessBuilder.PROPERTY_DATE);
+    String seats = inputSet.getPropertyValue(AirticketProcessBuilder.PROPERTY_SEATS);
     
     boolean isValid = name != null && name.length() > 0;
     isValid &= from != null && from.length() > 0;
@@ -54,6 +54,6 @@
     isValid &= seats != null && seats.length() > 0 && 0 < Integer.valueOf(seats);
     
     PropertyBuilder builder = PropertyBuilderFactory.newInstance().newPropertyBuilder();
-    outputSet.addProperty(builder.newProperty("isReqDataValid", "" + isValid));
+    outputSet.addProperty(builder.newProperty(AirticketProcessBuilder.PROPERTY_IS_VALID_REQUEST, "" + isValid));
   }
 }

Modified: jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/server/AirticketServiceImpl.java
===================================================================
--- jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/server/AirticketServiceImpl.java	2008-08-02 23:47:24 UTC (rev 1810)
+++ jbossbpm/spec/trunk/modules/samples/airticket/server/src/main/java/org/jboss/bpm/samples/airticket/server/AirticketServiceImpl.java	2008-08-04 00:31:52 UTC (rev 1811)
@@ -74,17 +74,17 @@
       if (httpSession.isNew() == false)
       {
         ProcessManager pm = ProcessManager.locateProcessManager();
-        procID = pm.startProcess("Airticket", null);
+        procID = pm.startProcess(AirticketProcessBuilder.PROCESS_NAME, null);
         httpSession.setAttribute("procID", procID);
       }
 
       Message msg = getRequestMessage((RequestMessage)gwtMsg);
-      mm.sendMessage(procID, "ReceiveReqTask", msg);
+      mm.sendMessage(procID, AirticketProcessBuilder.TASK_RECEIVE_REQUEST, msg);
     }
     else if (gwtMsg instanceof OrderMessage)
     {
       Message msg = getOrderMessage((OrderMessage)gwtMsg);
-      mm.sendMessage(procID, "ReceiveOrderTask", msg);
+      mm.sendMessage(procID, AirticketProcessBuilder.TASK_RECEIVE_ORDER, msg);
     }
     else
     {
@@ -103,46 +103,46 @@
     {
       Message bpmMsg = messageQueue.remove(0);
       String msgName = bpmMsg.getName();
-      if (msgName.equals("OfferMsg"))
+      if (msgName.equals(AirticketProcessBuilder.MESSAGE_OFFER))
       {
         OfferMessage gwtMsg = new OfferMessage();
-        gwtMsg.name = bpmMsg.getPropertyValue("Name");
-        gwtMsg.from = bpmMsg.getPropertyValue("From");
-        gwtMsg.to = bpmMsg.getPropertyValue("To");
-        gwtMsg.date = bpmMsg.getPropertyValue("Date");
-        gwtMsg.seats = bpmMsg.getPropertyValue("Seats");
-        gwtMsg.price = bpmMsg.getPropertyValue("Price");
+        gwtMsg.name = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_NAME);
+        gwtMsg.from = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_FROM);
+        gwtMsg.to = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_TO);
+        gwtMsg.date = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_DATE);
+        gwtMsg.seats = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_SEATS);
+        gwtMsg.price = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_PRICE);
         returnMsg = gwtMsg;
       }
-      else if (msgName.equals("InvalidDataMsg"))
+      else if (msgName.equals(AirticketProcessBuilder.MESSAGE_INVALID_DATA))
       {
         InvalidDataMessage gwtMsg = new InvalidDataMessage();
-        gwtMsg.name = bpmMsg.getPropertyValue("Name");
-        gwtMsg.from = bpmMsg.getPropertyValue("From");
-        gwtMsg.to = bpmMsg.getPropertyValue("To");
-        gwtMsg.date = bpmMsg.getPropertyValue("Date");
-        gwtMsg.seats = bpmMsg.getPropertyValue("Seats");
+        gwtMsg.name = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_NAME);
+        gwtMsg.from = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_FROM);
+        gwtMsg.to = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_TO);
+        gwtMsg.date = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_DATE);
+        gwtMsg.seats = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_SEATS);
         returnMsg = gwtMsg;
       }
-      else if (msgName.equals("NotAvailableMsg"))
+      else if (msgName.equals(AirticketProcessBuilder.MESSAGE_NOT_AVAILABLE))
       {
         NotAvailableMessage gwtMsg = new NotAvailableMessage();
-        gwtMsg.name = bpmMsg.getPropertyValue("Name");
-        gwtMsg.from = bpmMsg.getPropertyValue("From");
-        gwtMsg.to = bpmMsg.getPropertyValue("To");
-        gwtMsg.date = bpmMsg.getPropertyValue("Date");
-        gwtMsg.seats = bpmMsg.getPropertyValue("Seats");
+        gwtMsg.name = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_NAME);
+        gwtMsg.from = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_FROM);
+        gwtMsg.to = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_TO);
+        gwtMsg.date = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_DATE);
+        gwtMsg.seats = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_SEATS);
         returnMsg = gwtMsg;
       }
-      else if (msgName.equals("ConfirmMsg"))
+      else if (msgName.equals(AirticketProcessBuilder.MESSAGE_CONFIRM))
       {
         ConfirmMessage gwtMsg = new ConfirmMessage();
-        gwtMsg.name = bpmMsg.getPropertyValue("Name");
-        gwtMsg.from = bpmMsg.getPropertyValue("From");
-        gwtMsg.to = bpmMsg.getPropertyValue("To");
-        gwtMsg.date = bpmMsg.getPropertyValue("Date");
-        gwtMsg.seats = bpmMsg.getPropertyValue("Seats");
-        gwtMsg.price = bpmMsg.getPropertyValue("Price");
+        gwtMsg.name = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_NAME);
+        gwtMsg.from = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_FROM);
+        gwtMsg.to = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_TO);
+        gwtMsg.date = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_DATE);
+        gwtMsg.seats = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_SEATS);
+        gwtMsg.price = bpmMsg.getPropertyValue(AirticketProcessBuilder.PROPERTY_PRICE);
         returnMsg = gwtMsg;
       }
       else
@@ -157,12 +157,12 @@
   {
     MessageBuilderFactory msgFactory = MessageBuilderFactory.newInstance();
     MessageBuilder msgBuilder = msgFactory.newMessageBuilder();
-    Message msg = msgBuilder.newMessage("ReqDataMsg").
-    addProperty("Name", gwtMsg.name).
-    addProperty("From", gwtMsg.from).
-    addProperty("To", gwtMsg.to).
-    addProperty("Date", gwtMsg.date).
-    addProperty("Seats", gwtMsg.seats).
+    Message msg = msgBuilder.newMessage(AirticketProcessBuilder.MESSAGE_REQ_DATA).
+    addProperty(AirticketProcessBuilder.PROPERTY_NAME, gwtMsg.name).
+    addProperty(AirticketProcessBuilder.PROPERTY_FROM, gwtMsg.from).
+    addProperty(AirticketProcessBuilder.PROPERTY_TO, gwtMsg.to).
+    addProperty(AirticketProcessBuilder.PROPERTY_DATE, gwtMsg.date).
+    addProperty(AirticketProcessBuilder.PROPERTY_SEATS, gwtMsg.seats).
     getMessage();
     return msg;
   }
@@ -171,10 +171,10 @@
   {
     MessageBuilderFactory msgFactory = MessageBuilderFactory.newInstance();
     MessageBuilder msgBuilder = msgFactory.newMessageBuilder();
-    Message msg = msgBuilder.newMessage("AcceptOfferMsg").
-    addProperty("CreditCard", gwtMsg.creditCard).
-    addProperty("Expire", gwtMsg.expire).
-    addProperty("isOfferAccepted", "" + gwtMsg.acceptOffer).
+    Message msg = msgBuilder.newMessage(AirticketProcessBuilder.MESSAGE_ACCEPT_OFFER).
+    addProperty(AirticketProcessBuilder.PROPERTY_CREDIT_CARD, gwtMsg.creditCard).
+    addProperty(AirticketProcessBuilder.PROPERTY_EXPIRE, gwtMsg.expire).
+    addProperty(AirticketProcessBuilder.PROPERTY_IS_OFFER_ACCEPTED, "" + gwtMsg.acceptOffer).
     getMessage();
     return msg;
   }




More information about the jbpm-commits mailing list