[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