Package org.mule.api.client

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

52
53
54
55
56
57
58
59
60
61
62
            public void onNotification(ServerNotification notification)
            {
                messageConsumed.release();
            }
        });
        client.dispatch("jms://in1?connector=activeMq", MESSAGE, null);
        messageConsumed.await(TIMEOUT, TimeUnit.MILLISECONDS);
        stopFlowConstruct("singleTransactionBehavior");
        MuleMessage request = client.request("jms://in?connector=activeMq", TIMEOUT);
        assertThat(request, IsNull.<Object>nullValue());
    }
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
            public void onNotification(ServerNotification notification)
            {
                messageConsumed.release();
            }
        });
        client.dispatch("jms://in2?connector=activeMq", MESSAGE, null);
        messageConsumed.await(TIMEOUT, TimeUnit.MILLISECONDS);
        stopFlowConstruct("xaTransactionBehavior");
        MuleMessage outMessage = client.request("jms://out2?connector=activeMq", TIMEOUT);
        assertThat(outMessage,IsNull.<Object>notNullValue());
        assertThat(outMessage.getPayloadAsString(), is(MESSAGE));
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
    {
        LocalMuleClient client = muleContext.getClient();
        MuleMessage message = new DefaultMuleMessage("test", muleContext);
        message.setOutboundProperty("foo", "fooValue");

        client.dispatch("vm://queueIn", message);
        MuleMessage result = client.request("vm://queueOut", 2000);
        assertEquals("test bar", result.getPayload());
        assertEquals("fooValue", result.<Object> getInboundProperty("foo2"));
    }
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
    {
        LocalMuleClient client = muleContext.getClient();
        MuleMessage message = new DefaultMuleMessage("test", muleContext);
        message.setOutboundProperty("foo", "rrfooValue");

        client.dispatch("vm://notInConfig", message);
        MuleMessage result = client.request("vm://notInConfig", 2000);
        assertEquals("test", result.getPayload());
        assertEquals("rrfooValue", result.<Object> getInboundProperty("foo"));
    }
}
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
            public void onNotification(ExceptionNotification notification)
            {
                latch.countDown();
            }
        });
        client.dispatch("vm://in8", "test", null);
        if (!latch.await(RECEIVE_TIMEOUT, TimeUnit.MILLISECONDS))
        {
            fail("message should have been delivered at least 5 times");
        }
        MuleMessage response = client.request("vm://dlqCounter", 20000);
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
        LocalMuleClient client = muleContext.getClient();
        MuleMessage message = new DefaultMuleMessage("test", muleContext);
        message.setOutboundProperty("foo", "fooValue");
        message.setReplyTo("jms://reply");

        client.dispatch("inbound", message);
        MuleMessage result = client.request("jms://reply", 10000);

        assertNotNull(result);
        assertEquals("test bar", result.getPayload());
        assertEquals("fooValue", result.<Object> getInboundProperty("foo"));
View Full Code Here
30
31
32
33
34
35
36
37
38
39
40
    @Test
    public void testName() throws Exception
    {
        LocalMuleClient client = muleContext.getClient();
        client.dispatch("vm://testInput", TEST_MESSAGE, null);
        client.dispatch("vm://testInput", TEST_MESSAGE, null);

        Prober prober = new PollingProber(1000, 10);
        prober.check(new Probe()
        {
View Full Code Here
31
32
33
34
35
36
37
38
39
40
41
    @Test
    public void testName() throws Exception
    {
        LocalMuleClient client = muleContext.getClient();
        client.dispatch("vm://testInput", TEST_MESSAGE, null);
        client.dispatch("vm://testInput", TEST_MESSAGE, null);

        Prober prober = new PollingProber(1000, 10);
        prober.check(new Probe()
        {
            @Override
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
                messageProcessedLatch.release();
                throw new RuntimeException();
            }
        });
        LocalMuleClient client = muleContext.getClient();
        client.dispatch("jms://in1?connector=jmsConnector", MESSAGE_TO_SEND, null);
        if (!messageProcessedLatch.await(TIMEOUT, TimeUnit.MILLISECONDS))
        {
            fail("Message never received by mule");
        }
        MuleMessage response = client.request("jms://dead.letter1?connector=jmsConnector", TIMEOUT);
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
                messageProcessedLatch.release();
                throw new RuntimeException();
            }
        });
        LocalMuleClient client = muleContext.getClient();
        client.dispatch("jms://in2?connector=jmsConnector", MESSAGE_TO_SEND, null);
        if (!messageProcessedLatch.await(TIMEOUT, TimeUnit.MILLISECONDS))
        {
            fail("Message never received by mule");
        }
        MuleMessage response = client.request("jms://dead.letter2?connector=jmsConnector", TIMEOUT);
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.