- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
@Test(timeout = 120000)
public void testFlow() throws MuleException, InterruptedException {
MuleClient client = new MuleClient(muleContext);
MuleMessage message = client.send("vm://sfdc.process", new DefaultMuleMessage("abakadabra", muleContext));
Thread.sleep(30000);
Assert.assertNotNull(message);
}
http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/module/client/MuleClient.html
MuleMessage send(String url, MuleMessage message)
FutureMessageResult sendAsync(String url, MuleMessage message)