Package org.mule.construct

Examples of org.mule.construct.Flow.process()

174
175
176
177
178
179
180
181
182
183
184
    public void measureSynchronousWait() throws Exception {
        final String payload = RandomStringUtils.randomAlphanumeric(20);
        Flow flow = (Flow) getFlowConstruct("measureSynchronousWait");
        try
        {
            flow.process(getTestEvent(payload));
            fail("Exception should be thrown");
        }
        catch (Exception e)
        {
            assertThat(WaitMeasure.totalWait >= 1000, is(true));
View Full Code Here
190
191
192
193
194
195
196
197
198
199
200
    {
        final String payload = RandomStringUtils.randomAlphanumeric(20);
        final int expectedCounterExecutions = 4;
        final int expectedCounterInExceptionStrategyExecutions = 1;
        Flow flow = (Flow) getFlowConstruct("asynchronous-using-threading-profile");
        flow.process(getTestEvent(payload));
        new PollingProber(10000, 100).check(new Probe()
        {
            private int executionOfCountInUntilSuccessful;
            private int executionOfCountInExceptionStrategy;
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
        if (variant.equals(ConfigVariant.FLOW))
        {
            Flow flow = muleContext.getRegistry().lookupObject("component1");
            MuleEvent event = new DefaultMuleEvent(new DefaultMuleMessage("Test MuleEvent", muleContext),
                ((InboundEndpoint) flow.getMessageSource()), flow);
            flow.process(event);
        }
        else
        {
            Service service = muleContext.getRegistry().lookupService("component1");
            MuleEvent event = new DefaultMuleEvent(new DefaultMuleMessage("Test MuleEvent", muleContext),
View Full Code Here
236
237
238
239
240
241
242
243
244
245
246
     * @throws Exception
     */
    protected void testFlow(String flowName, MuleEvent event) throws Exception
    {
        Flow flow = this.lookupFlowConstruct(flowName);
        flow.process(event);
        FlowAssert.verify(flowName);
    }

    /**
     * Runs the given flow with a default event
View Full Code Here
275
276
277
278
279
280
281
282
283
284
285
     * @return the resulting <code>MuleEvent</code>
     * @throws Exception
     */
    protected MuleEvent runFlow(String flowName, MuleEvent event) throws Exception {
        Flow flow = lookupFlowConstruct(flowName);
        return flow.process(event);
    }

    /**
     * Run the flow specified by name and assert equality on the expected output
     *
 
View Full Code Here
303
304
305
306
307
308
309
310
311
312
313
    protected <T> void runFlowAndExpectProperty(String flowName, String propertyName, T expect)
        throws Exception
    {
        Flow flow = lookupFlowConstruct(flowName);
        MuleEvent event = getTestEvent(null);
        MuleEvent responseEvent = flow.process(event);

        Assert.assertEquals(expect, responseEvent.getMessage().getOutboundProperty(propertyName));
    }

    /**
 
View Full Code Here
81
82
83
84
85
86
87
88
89
90
    public void runScenario(String flowName) throws Exception
    {
        MuleMessage message = new DefaultMuleMessage("data", muleContext);
        DefaultMuleEvent event = new DefaultMuleEvent(message, getTestInboundEndpoint(""), getTestService());
        Flow flow = (Flow) getFlowConstruct(flowName);
        flow.process(event);
        FlowAssert.verify(flowName);
    }

}
View Full Code Here
33
34
35
36
37
38
39
40
41
42
43
        MuleEvent event = new DefaultMuleEvent(message, getTestInboundEndpoint(""), getTestService());

        message.setProperty("key", "value", PropertyScope.SESSION);

        Flow flowA = (Flow) muleContext.getRegistry().lookupFlowConstruct("A");
        MuleEvent result = flowA.process(event);

        assertEquals("value", result.getMessageAsString());
    }

    @Test
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
    {
        MuleMessage message = new DefaultMuleMessage("data", muleContext);
        MuleEvent event = new DefaultMuleEvent(message, getTestInboundEndpoint(""), getTestService());

        Flow flowA = (Flow) muleContext.getRegistry().lookupFlowConstruct("B");
        MuleEvent result = flowA.process(event);

        assertEquals("value", result.getMessage().getProperty("key", PropertyScope.SESSION));
    }

    @Test
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
    @Test
    public void createJdbcRecordAndConsumeIt() throws Exception
    {
        final MuleContext clientAppMuleContext = getMuleContextForApp(CLIENT_APP);
        Flow flow = (Flow) clientAppMuleContext.getRegistry().lookupFlowConstruct("dbClientService");
        flow.process(AbstractMuleContextTestCase.getTestEvent(new Object(), clientAppMuleContext));
        MuleMessage response = getMuleContextForApp(SERVER_APP).getClient().request("vm://out", 5000);
        assertThat(response, notNullValue());
    }

}
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.