Package org.mule.api.client

Examples of org.mule.api.client.MuleClient.dispatch()

79
80
81
82
83
84
85
86
87
88
89
        MuleClient client = muleContext.getClient();
        Set<String> polos = new HashSet<String>(Arrays.asList(new String[]{"Marco", "Niccolo", "Maffeo"}));
        Iterator<String> people = polos.iterator();
        while (people.hasNext())
        {
            client.dispatch("vm://entry", people.next(), null);
        }

        for (int i = 0; i < 3; ++i)
        {
            MuleMessage response = client.request("queue", WAIT);
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
        MuleClient client = muleContext.getClient();
        Set<String> polos = new HashSet<String>(Arrays.asList(new String[]{"Marco", "Niccolo", "Maffeo"}));
        Iterator<String> people = polos.iterator();
        while (people.hasNext())
        {
            client.dispatch("entry", people.next(), null);
        }

        for (int i = 0; i < 3; ++i)
        {
            MuleMessage response = client.request("queue", WAIT);
View Full Code Here
30
31
32
33
34
35
36
37
38
39
40
    public void testReplyTo() throws Exception
    {
        MuleClient client = muleContext.getClient();
        Map<String, Object> props = new HashMap<String, Object>();
        props.put("JMSReplyTo", "middle");
        client.dispatch("in", DEFAULT_INPUT_MESSAGE, props);

        // Check that the property is still on the outbound message
        MuleMessage output = client.request("out", 2000);
        assertNotNull(output);
        final Object o = output.getOutboundProperty("JMSReplyTo");
View Full Code Here
28
29
30
31
32
33
34
35
36
37
38
    @Test
    public void testOneGlobalTx() throws Exception
    {
        MuleClient client = muleContext.getClient();

        client.dispatch("vm://in", DEFAULT_INPUT_MESSAGE, null);
        MuleMessage result = client.request("vm://out", getTimeout());
        assertNotNull(result);

        result = client.request("vm://out", getSmallTimeout());
        assertNull(result);
View Full Code Here
38
39
40
41
42
43
44
45
46
47
48
        assertNull(result);
        muleContext.getRegistry().lookupConnector(CONNECTOR1_NAME).stop();
        assertEquals(muleContext.getRegistry().lookupConnector(CONNECTOR1_NAME).isStarted(), false);
        log.info(CONNECTOR1_NAME + " is stopped");

        client.dispatch("vm://in", DEFAULT_INPUT_MESSAGE, null);
        Thread.sleep(1000);

        muleContext.getRegistry().lookupConnector(CONNECTOR1_NAME).start();
        Thread.sleep(1000);
        log.info(CONNECTOR1_NAME + " is started");
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
    {
        String input = "Test message";
        String[] output = {"Test", "message"};

        MuleClient client = muleContext.getClient();
        client.dispatch("vm://receiver", input, null);
        MuleMessage result = client.request("vm://out", RECEIVE_TIMEOUT);
        assertNotNull(result);
        assertNotNull(result.getPayload());
        assertNull(result.getExceptionPayload());
        String[] payload = (String[]) result.getPayload();
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
    {
        String input = "Test message";
        String[] output = {"Test", "message"};

        MuleClient client = muleContext.getClient();
        client.dispatch("vm://flowReceiver", input, null);
        MuleMessage result = client.request("vm://flowOut", RECEIVE_TIMEOUT);
        assertNotNull(result);
        assertNotNull(result.getPayload());
        assertNull(result.getExceptionPayload());
        String[] payload = (String[]) result.getPayload();
View Full Code Here
33
34
35
36
37
38
39
40
41
42
43
    @Test
    public void testDefaultConfig() throws Exception
    {
        MuleClient client = muleContext.getClient();
        client.dispatch("vm://in-default", MESSAGE, null);

        MuleMessage message = client.request("vm://out-default", WAIT_MS);
        assertNotNull("null message", message);
        assertNotNull("null payload", message.getPayload());
        assertEquals(MESSAGE, message.getPayloadAsString());
View Full Code Here
30
31
32
33
34
35
36
37
38
39
40
    @Test
    public void testFlowExceptionExceptionStrategy() throws MuleException
    {
        MuleClient client = muleContext.getClient();
        client.dispatch("vm://in", TEST_MESSAGE, null);
        MuleMessage message = client.request("vm://out", RECEIVE_TIMEOUT);

        assertNotNull("request returned no message", message);
        assertTrue(message.getPayload() instanceof ExceptionMessage);
    }
View Full Code Here
28
29
30
31
32
33
34
35
36
37
38
    @Test
    public void testCustomExpressionEvaluatorExceptionStrategy() throws MuleException
    {
        MuleClient client = muleContext.getClient();
        client.dispatch("vm://in", TEST_MESSAGE, null);
        MuleMessage message = client.request("vm://out", RECEIVE_TIMEOUT);

        assertNotNull("request returned no message", message);
        assertTrue(message.getPayload() instanceof ExceptionMessage);
    }
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.