Examples of CorrelationSet

org.camunda.bpm.engine.impl.runtime.CorrelationSet
org.eclipse.bpel.model.CorrelationSet
A representation of the model object 'Correlation Set'. A named group of properties that, taken together, serve to define a way of identifying an application-level conversation within a business protocol instance. A given message can cary multiple correlation sets. After initialization, the values of the properties for a correlation set in a business process instance must be identical for all the messages in all the operations that carry the correlation set.
The following features are supported:
- {@link org.eclipse.bpel.model.CorrelationSet#getName Name}
- {@link org.eclipse.bpel.model.CorrelationSet#getProperties Properties}
@see org.eclipse.bpel.model.BPELPackage#getCorrelationSet() @model @generated
org.uengine.smcp.twister.engine.priv.core.definition.CorrelationSet
A correlation set is a set of named properties used to add contextual information to a message. The goal of a correlation set is to give a stateful meaning to message exchange (for example customer ids, order number...).

Examples of org.camunda.bpm.engine.impl.runtime.CorrelationSet


    CorrelationHandler correlationHandler = Context
      .getProcessEngineConfiguration()
      .getCorrelationHandler();


    CorrelationSet correlationSet = new CorrelationSet(businessKey, processInstanceId, correlationKeys);
    List<MessageCorrelationResult> correlationResults = correlationHandler
      .correlateMessages(commandContext, messageName, correlationSet);


    for (MessageCorrelationResult correlationResult : correlationResults) {
      if (MessageCorrelationResult.TYPE_EXECUTION.equals(correlationResult.getResultType())) {

View Full Code Here

Examples of org.camunda.bpm.engine.impl.runtime.CorrelationSet

    ensureAtLeastOneNotNull("At least one of the following correlation criteria has to be present: "
        + "messageName, businessKey, correlationKeys, processInstanceId", messageName, businessKey, correlationKeys, processInstanceId);


    CorrelationHandler correlationHandler = Context.getProcessEngineConfiguration().getCorrelationHandler();


    CorrelationSet correlationSet = new CorrelationSet(businessKey, processInstanceId, correlationKeys);
    MessageCorrelationResult correlationResult = correlationHandler.correlateMessage(commandContext, messageName, correlationSet);


    if (correlationResult == null) {
      throw new MismatchingMessageCorrelationException(messageName, "No process definition or execution matches the parameters");

View Full Code Here

Examples of org.camunda.bpm.engine.impl.runtime.CorrelationSet


    CorrelationHandler correlationHandler = Context
      .getProcessEngineConfiguration()
      .getCorrelationHandler();


    CorrelationSet correlationSet = new CorrelationSet(businessKey, processInstanceId, correlationKeys);
    List<MessageCorrelationResult> correlationResults = correlationHandler
      .correlateMessages(commandContext, messageName, correlationSet);


    for (MessageCorrelationResult correlationResult : correlationResults) {
      if (MessageCorrelationResult.TYPE_EXECUTION.equals(correlationResult.getResultType())) {

View Full Code Here

Examples of org.camunda.bpm.engine.impl.runtime.CorrelationSet

  public Void execute(CommandContext commandContext) {
    ensureNotNull("messageName", messageName);


    CorrelationHandler correlationHandler = Context.getProcessEngineConfiguration().getCorrelationHandler();


    CorrelationSet correlationSet = new CorrelationSet(businessKey, processInstanceId, correlationKeys);
    MessageCorrelationResult correlationResult = correlationHandler.correlateMessage(commandContext, messageName, correlationSet);


    if (correlationResult == null) {
      throw new MismatchingMessageCorrelationException(messageName, "No process definition or execution matches the parameters");

View Full Code Here

Examples of org.eclipse.bpel.model.CorrelationSet

      else if (container instanceof OnEvent)
        correlationSets = ((OnEvent)container).getCorrelationSets();
      
      if (correlationSets != null) {
        for (Iterator<?> it = correlationSets.getChildren().iterator(); it.hasNext(); ) {
          CorrelationSet correlationSet = (CorrelationSet)it.next();
          if (correlationSet.getName().equals(correlationSetName))
            return correlationSet;
        }
      }
      container = container.eContainer();
    }

View Full Code Here

Examples of org.eclipse.bpel.model.CorrelationSet

        if (result == null) result = caseWSDLElement(activity);
        if (result == null) result = defaultCase(theEObject);
        return result;
      }
      case BPELPackage.CORRELATION_SET: {
        CorrelationSet correlationSet = (CorrelationSet)theEObject;
        Object result = caseCorrelationSet(correlationSet);
        if (result == null) result = caseExtensibleElement(correlationSet);
        if (result == null) result = caseExtensibleElement_1(correlationSet);
        if (result == null) result = caseWSDLElement(correlationSet);
        if (result == null) result = defaultCase(theEObject);

View Full Code Here

Examples of org.eclipse.bpel.model.CorrelationSet

  protected Element correlationSets2XML(CorrelationSets correlationSets) {
    Element correlationSetsElement = createBPELElement("correlationSets");


    Iterator it = correlationSets.getChildren().iterator();
    while (it.hasNext()) {
      CorrelationSet correlationSet = (CorrelationSet)it.next();
      correlationSetsElement.appendChild(correlationSet2XML(correlationSet));      
    }


    // serialize local namespace prefixes to XML
    bpelNamespacePrefixManager.serializePrefixes(correlationSets, correlationSetsElement);

View Full Code Here

Examples of org.eclipse.bpel.model.CorrelationSet

   * <!-- begin-user-doc -->
   * <!-- end-user-doc -->
   * @generated
   */
  public void setSet(CorrelationSet newSet) {
    CorrelationSet oldSet = set;
    set = newSet;
    if (eNotificationRequired())
      eNotify(new ENotificationImpl(this, Notification.SET, BPELPackage.CORRELATION__SET, oldSet, set));
  }

View Full Code Here

Examples of org.uengine.smcp.twister.engine.priv.core.definition.CorrelationSet

    return correlationSets;
  }




    public CorrelationSet getCorrelationSet(String setName) {
        CorrelationSet result = null;
        for (Iterator corIter = correlationSets.iterator(); corIter.hasNext();) {
            CorrelationSet correlationSet = (CorrelationSet) corIter.next();
            if (correlationSet.getName().equals(setName)) {
                result = correlationSet;
            }
        }
        return result;
    }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.