Package org.mule

Examples of org.mule.DefaultMuleEvent$NullInboundEndpoint


        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
View Full Code Here


                    if (logger.isInfoEnabled())
                    {
                        logger.info(String.format("sending part %d of %d (seq # %d)", count + 1, parts, count));
                    }
                    super.route(new DefaultMuleEvent(part, event.getEndpoint(), session));
                    if (logger.isInfoEnabled())
                    {
                        logger.info("sent");
                    }
                }
View Full Code Here

                MuleMessage message =((DynamicRequestEndpoint) inboundEndpoint).request(timeout, event);
                if(message == null)
                {
                    message = new DefaultMuleMessage(NullPayload.getInstance(), event.getMuleContext());
                }
                return new DefaultMuleEvent(message, event);
            }
            else
            {
                return new DefaultMuleEvent(inboundEndpoint.request(event.getMuleContext()
                    .getConfiguration()
                    .getDefaultResponseTimeout()), event);
            }
        }
        catch (Exception e)
View Full Code Here

            {
                throw new RoutingException(CoreMessages.transformFailedBeforeFilter(), event,
                    routes.get(0), e);
            }
        }
        return message == null ? null : new DefaultMuleEvent(message, event);
    }
View Full Code Here

    public MuleEvent process(MuleEvent event) throws MessagingException
    {
        try
        {
            return endpoint.process(new DefaultMuleEvent(event.getMessage(), endpoint.getExchangePattern(),
                event.getSession()));
        }
        catch (MessagingException e)
        {
            throw e;
View Full Code Here

        assertTrue(router.isMatch(message));

        // exception to throw
        MuleSession session = (MuleSession)mockSession.proxy();
        MuleEvent eventToThrow = new DefaultMuleEvent(message, MessageExchangePattern.ONE_WAY, session);
        MuleException rex = new RoutingException(eventToThrow, endpoint1);
        mockendpoint1.expectAndThrow("process", RouterTestUtils.getArgListCheckerMuleEvent(), rex);
        mockendpoint2.expectAndThrow("process", RouterTestUtils.getArgListCheckerMuleEvent(), rex);
        MuleEvent result = null;
        try
View Full Code Here

        assertTrue(router.isMatch(message));

        final MuleSession session = (MuleSession)mockSession.proxy();
        // exception to throw
        MuleEvent eventToThrow = new DefaultMuleEvent(message, MessageExchangePattern.ONE_WAY, session);
        MuleException rex = new RoutingException(eventToThrow, endpoint1);
        // 1st failure
        mockendpoint1.expectAndThrow("process", RouterTestUtils.getArgListCheckerMuleEvent(), rex);
        mockendpoint2.expectAndReturn("process", RouterTestUtils.getArgListCheckerMuleEvent(), event);
        MuleEvent actualResult = router.route(new OutboundRoutingTestEvent(message, session, muleContext));
View Full Code Here

    protected WireFormat requestWireFormat() throws MuleException
    {
        MuleMessage msg = new DefaultMuleMessage(ServerHandshake.SERVER_HANDSHAKE_PROPERTY, muleContext);
        MuleMessage result = null;

        MuleEvent resultEvent = syncServerEndpoint.process(new DefaultMuleEvent(msg,
            MessageExchangePattern.REQUEST_RESPONSE, new DefaultMuleSession(new MuleClientFlowConstruct(
                muleContext), muleContext)));
        if (resultEvent != null)
        {
            result = resultEvent.getMessage();
View Full Code Here

        }

        message.addProperties(action.getProperties());
        MuleSession session = new DefaultMuleSession(muleContext);

        MuleEvent event = new DefaultMuleEvent(message, serverEndpoint.getExchangePattern(), session);
        event.setTimeout(timeout);
        if (logger.isDebugEnabled())
        {
            logger.debug("MuleClient sending remote call to: " + action.getResourceIdentifier() + ". At "
                         + serverEndpoint.toString() + " . Event is: " + event);
        }
View Full Code Here

    }

    protected void updateContext(MuleMessage message, ImmutableEndpoint endpoint, boolean synchronous)
        throws MuleException
    {
        RequestContext.setEvent(new DefaultMuleEvent(message, endpoint.getExchangePattern(),
            new DefaultMuleSession(muleContext)));
    }
View Full Code Here

TOP

Related Classes of org.mule.DefaultMuleEvent$NullInboundEndpoint

Copyright © 2018 www.massapicom. 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.