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

org.mule.api.client.MuleClient.send()
Sends an event synchronously to a endpointUri via a Mule server and a resulting message is returned. @param url the Mule URL used to determine the destination and transport of themessage @param payload the object that is the payload of the event @param messageProperties any properties to be associated with the payload. Inthe case of Jms you could set the JMSReplyTo property in these properties. @return A return message, this could be null if the thecomponents invoked explicitly sets a return as null. @throws org.mule.api.MuleException

    public void testLifecycle() throws Exception
    {


        MuleClient muleClient = muleContext.getClient();


        final MuleMessage result = muleClient.send("vm://EchoService.In", "foo", null);


        final LifecycleTrackerTransformer ltt = (LifecycleTrackerTransformer) result.getPayload();


        muleContext.dispose();

View Full Code Here

    }


    public void testFirstSuccessful() throws Exception
    {
        MuleClient client = muleContext.getClient();
        MuleMessage response = client.send("vm://input", "XYZ", null);
        assertEquals("XYZ is a string", response.getPayloadAsString());


        response = client.send("vm://input", Integer.valueOf(9), null);
        assertEquals("9 is an integer", response.getPayloadAsString());

View Full Code Here

    {
        MuleClient client = muleContext.getClient();
        MuleMessage response = client.send("vm://input", "XYZ", null);
        assertEquals("XYZ is a string", response.getPayloadAsString());


        response = client.send("vm://input", Integer.valueOf(9), null);
        assertEquals("9 is an integer", response.getPayloadAsString());


        response = client.send("vm://input", Long.valueOf(42), null);
        assertEquals("42 is a number", response.getPayloadAsString());

View Full Code Here

        assertEquals("XYZ is a string", response.getPayloadAsString());


        response = client.send("vm://input", Integer.valueOf(9), null);
        assertEquals("9 is an integer", response.getPayloadAsString());


        response = client.send("vm://input", Long.valueOf(42), null);
        assertEquals("42 is a number", response.getPayloadAsString());


        try
        {
            response = client.send("vm://input", Boolean.TRUE, null);

View Full Code Here

        response = client.send("vm://input", Long.valueOf(42), null);
        assertEquals("42 is a number", response.getPayloadAsString());


        try
        {
            response = client.send("vm://input", Boolean.TRUE, null);
            fail("DispatchException expected");
        }
        catch (DispatchException e)
        {
            // this one was expected

View Full Code Here

    }


    public void testFirstSuccessfulWithExpression() throws Exception
    {
        MuleClient client = muleContext.getClient();
        MuleMessage response = client.send("vm://input2", "XYZ", null);
        assertEquals("XYZ is a string", response.getPayloadAsString());
    }


    public void testFirstSuccessfulWithExpressionAllFail() throws Exception
    {

View Full Code Here

    
    public void testSharedInterceptorOnServiceOne() throws MuleException
    {
        MuleClient client = muleContext.getClient();
        
        MuleMessage response = client.send("vm://stackOne", TEST_MESSAGE, null);
        assertEquals(TEST_MESSAGE + " CustomInterceptor ComponentOne", response.getPayload());
    }


    public void testSharedInterceptorOnServiceTwo() throws MuleException
    {

View Full Code Here


    public void testSharedInterceptorOnServiceTwo() throws MuleException
    {
        MuleClient client = muleContext.getClient();
        
        MuleMessage response = client.send("vm://stackTwo", TEST_MESSAGE, null);
        assertEquals(TEST_MESSAGE + " CustomInterceptor ComponentTwo", response.getPayload());
    }


    public static class CustomInterceptor extends AbstractInterceptingMessageProcessor implements Interceptor
    {

View Full Code Here

    {
        MuleClient client = muleContext.getClient();
        MuleMessage message = new DefaultMuleMessage(TEST_MESSAGE, muleContext);
        message.setProperty("foo", "bar", PropertyScope.INBOUND);
        
        MuleMessage response = client.send("vm://in-synch", message);
        assertNotNull(response);
        assertNull("Property should not have been propogated for this scope", response.getProperty("foo", PropertyScope.INBOUND));
    }


    public void testOutboundScopeSynchronous() throws Exception

View Full Code Here

    {
        MuleClient client = muleContext.getClient();
        MuleMessage message = new DefaultMuleMessage(TEST_MESSAGE, muleContext);
        message.setProperty("foo", "bar", PropertyScope.OUTBOUND);


        MuleMessage response = client.send("vm://in-synch", message);
        assertNotNull(response);
        assertNull("Property should not have been propogated for this scope", response.getProperty("foo", PropertyScope.OUTBOUND));
    }


    public void testInvocationScopeSynchronous() throws Exception

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.