Package org.camunda.bpm.engine.impl.jobexecutor

Examples of org.camunda.bpm.engine.impl.jobexecutor.MessageJobDeclaration

1661
1662
1663
1664
1665
1666
1667
1668
1669
1670
1671
1672
1673
1674
1675
1676
1677
1678
1679
1680
1681
1682
1683
    activity.setAsyncBefore(isAsyncBefore);
    activity.setAsyncAfter(isAsyncAfter);

    if(isAsyncBefore) {

      MessageJobDeclaration messageJobDeclaration = new AsyncBeforeMessageJobDeclaration();
      messageJobDeclaration.setExclusive(exclusive);
      messageJobDeclaration.setActivityId(activity.getId());

      addMessageJobDeclarationToActivity(messageJobDeclaration, activity);
      addJobDeclarationToProcessDefinition(messageJobDeclaration, activity.getProcessDefinition());
    }

    if(isAsyncAfter) {

      MessageJobDeclaration messageJobDeclaration = new AsyncAfterMessageJobDeclaration();
      messageJobDeclaration.setExclusive(exclusive);
      messageJobDeclaration.setActivityId(activity.getId());

      addMessageJobDeclarationToActivity(messageJobDeclaration, activity);
      addJobDeclarationToProcessDefinition(messageJobDeclaration, activity.getProcessDefinition());
    }
View Full Code Here
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
  }

  @SuppressWarnings({"unchecked", "deprecation"})
  protected void scheduleAtomicOperationAsync(AtomicOperation executionOperation) {

    MessageJobDeclaration messageJobDeclaration = null;

    List<MessageJobDeclaration> messageJobDeclarations = (List<MessageJobDeclaration>) getActivity().getProperty(BpmnParse.PROPERTYNAME_MESSAGE_JOB_DECLARATION);
    if (messageJobDeclarations != null) {
      for (MessageJobDeclaration declaration : messageJobDeclarations) {
        if (declaration.isApplicableForOperation(executionOperation)) {
          messageJobDeclaration = declaration;
          break;
        }
      }
    }

    if(messageJobDeclaration != null) {
      MessageEntity message = messageJobDeclaration.createJobInstance(this);
      messageJobDeclaration.setJobHandlerConfiguration(message, this, executionOperation);

      Context
        .getCommandContext()
        .getJobManager()
        .send(message);
View Full Code Here
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
  }

  @SuppressWarnings({"unchecked", "deprecation"})
  protected void scheduleAtomicOperationAsync(AtomicOperation executionOperation) {

    MessageJobDeclaration messageJobDeclaration = null;

    List<MessageJobDeclaration> messageJobDeclarations = (List<MessageJobDeclaration>) getActivity().getProperty(BpmnParse.PROPERTYNAME_MESSAGE_JOB_DECLARATION);
    if (messageJobDeclarations != null) {
      for (MessageJobDeclaration declaration : messageJobDeclarations) {
        if (declaration.isApplicableForOperation(executionOperation)) {
          messageJobDeclaration = declaration;
          break;
        }
      }
    }

    if(messageJobDeclaration != null) {
      MessageEntity message = messageJobDeclaration.createJobInstance(this);
      messageJobDeclaration.setJobHandlerConfiguration(message, this, executionOperation);

      Context
        .getCommandContext()
        .getJobManager()
        .send(message);
View Full Code Here
1728
1729
1730
1731
1732
1733
1734
1735
1736
1737
1738
1739
1740
1741
1742
1743
1744
1745
1746
1747
1748
1749
1750
    activity.setAsyncBefore(isAsyncBefore);
    activity.setAsyncAfter(isAsyncAfter);

    if(isAsyncBefore) {

      MessageJobDeclaration messageJobDeclaration = new AsyncBeforeMessageJobDeclaration();
      messageJobDeclaration.setExclusive(exclusive);
      messageJobDeclaration.setActivityId(activity.getId());

      addMessageJobDeclarationToActivity(messageJobDeclaration, activity);
      addJobDeclarationToProcessDefinition(messageJobDeclaration, activity.getProcessDefinition());
    }

    if(isAsyncAfter) {

      MessageJobDeclaration messageJobDeclaration = new AsyncAfterMessageJobDeclaration();
      messageJobDeclaration.setExclusive(exclusive);
      messageJobDeclaration.setActivityId(activity.getId());

      addMessageJobDeclarationToActivity(messageJobDeclaration, activity);
      addJobDeclarationToProcessDefinition(messageJobDeclaration, activity.getProcessDefinition());
    }
View Full Code Here
TOP

Related Classes of org.camunda.bpm.engine.impl.jobexecutor.MessageJobDeclaration

  • org.camunda.bpm.engine.impl.bpmn.parser.BpmnParse
  • org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity
  • org.camunda.bpm.engine.impl.persistence.entity.MessageEntity
  • org.camunda.bpm.engine.impl.pvm.process.ActivityImpl
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.