Examples of org.mule.api.component.InterfaceBinding.process()

org.mule.api.component.InterfaceBinding.process()

This method is responsible for routing the Message via the MuleSession. The logic for this method will change for each type of router depending on expected behaviour. For example, a MulticastingRouter might just iterate through the list of assoaciated endpoints sending the message. Another type of router such as the ExceptionBasedRouter will hit the first endpoint, if it fails try the second, and so on. Most router implementations will extends the FilteringOutboundRouter which implements all the common logic need for a router. @return a result message if any from the invocation. If the endpoint bound hasa one-way exchange pattern configured a null result will always be returned. @throws MessagingException if any errors occur during the sending of messages @throws MuleException @see org.mule.routing.outbound.FilteringOutboundRouter @see org.mule.routing.outbound.ExceptionBasedRouter @see org.mule.routing.outbound.MulticastingRouter @since 2.1 the synchronous argument has been removed. Instead use thesynchronous attribute of the endpoint you are dispatching to.

        {
            throw new IllegalArgumentException(CoreMessages.cannotFindBindingForMethod(method.getName()).toString());
        }


        MuleEvent currentEvent = RequestContext.getEvent();
        MuleEvent replyEvent = router.process(new DefaultMuleEvent(message,currentEvent));


        if (replyEvent != null && replyEvent.getMessage()!=null)
        {
            MuleMessage reply = replyEvent.getMessage();
            if (reply.getExceptionPayload() != null)

        MuleMessage reply;
        MuleSession session = new DefaultMuleSession(flow, muleContext);


        try
        {
            replyEvent = router.process(new DefaultMuleEvent(message, router.getEndpoint()
                .getExchangePattern(), session));
       }
        catch (Throwable e)
        {
            //Make all exceptions go through the CallException handler

        {
            throw new IllegalArgumentException(CoreMessages.cannotFindBindingForMethod(method.getName()).toString());
        }


        MuleEvent currentEvent = RequestContext.getEvent();
        MuleEvent replyEvent = router.process(new DefaultMuleEvent(message,currentEvent));


        if (replyEvent != null && !VoidMuleEvent.getInstance().equals(replyEvent)
            && replyEvent.getMessage() != null)
        {
            MuleMessage reply = replyEvent.getMessage();

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.