activiti7 cloud connectors and bpmn testing

0717552340 — Fri, 22 Feb 2019 07:57:20 GMT

i am using activiti cloud 7 and cloud connectors. i would like to write automated (junit-like) tests to test the bpmn processes.i can deploy my bpmn models in my test, but i am having difficulties mocking the service tasks. my service tasks are implemented using cloud connectors.how can i mock my se

Re: activiti7 cloud connectors and bpmn testing

venkataramana_g — Mon, 25 Feb 2019 11:05:20 GMT

Hi,

May be you can try out this way using a junit test case.

@Test
public void testConnectorSuccess() {
try {
IntegrationContextImpl ic=new IntegrationContextImpl();
IntegrationRequest ir=new IntegrationRequestImpl(ic);

// Create an instance of your connector class

Connector con=new Connector();

//Call method in connector e.g. performTask is a sample method in above connector

   con.performTask(ir);
   } catch (InterruptedException e) {
      e.printStackTrace();
   }
}

Re: activiti7 cloud connectors and bpmn testing

0717552340 — Mon, 25 Feb 2019 15:19:45 GMT

thank you venkataramana.

to be more specific, I am talking about the trending-topic-campaigns (https://activiti.gitbook.io/activiti-7-developers-guide/blueprints/trending-topic-campaigns),

and I would like to test the CampaignService.java by starting en-campaign.bpmn20.xml.

the bpmn flow is started, but the workflow hangs at the first service task (there is no one to reply to the integration request).

the connector (TwitterProcessingConnector) is located in another module (connectors-processing), I can not instantiate it in module rb-english-campaign.

here is my test (simplified):

@RunWith(SpringRunner.class)
@SpringBootTest()
@DirtiesContext
public class CampaignServiceTest {

    private static final Logger LOGGER = LoggerFactory.getLogger(CampaignServiceTest.class);

    @Autowired
    private RuntimeService runtimeService;
    @Autowired
    private RepositoryService repositoryService;
    @Autowired
    private CampaignService campaignService;

    @Autowired
    private MessageCollector messageCollector;

    @Autowired
    private ProcessingConnectorChannels processingConnectorChannels;
    @Before
    public void before() {
        deployModels();
    }

    @Test
    public void testProcessTweet() {
        Tweet tweet = new Tweet("text", "author", "en", new Date().getTime());
        campaignService.processTweet(tweet);

        assertEquals(0L, getExecutionCount());
        assertEquals(0L, getActiveProcessesCount());
    }

    private void deployModels() {
        DeploymentBuilder builder = repositoryService.createDeployment();
        builder.addClasspathResource("processes/en-campaign.bpmn20.xml");
        builder.deploy();
    }

public void processTweet(Tweet tweet) {
    Map<String, Object> vars = new HashMap<>();
    vars.put("text",
             tweet.getText());
    vars.put("author",
             tweet.getAuthor());
    vars.put("lang",
             tweet.getLang());
    vars.put("timestamp",
             tweet.getTimestamp());
    vars.put("campaign",
             currentTopic);
    runtimeService.startProcessInstanceByKey("launchCampaign",
                                             currentTopic,
                                             //BusinessKey
                                             vars);
}

}

topic Re: activiti7 cloud connectors and bpmn testing in Alfresco Forum

activiti7 cloud connectors and bpmn testing

Re: activiti7 cloud connectors and bpmn testing

Re: activiti7 cloud connectors and bpmn testing