Package org.mule.api

Examples of org.mule.api.MuleSession

133
134
135
136
137
138
139
140
141
142
143
    }

    @Test
    public void testBadRecipientListRouter() throws Exception
    {
        MuleSession session = mock(MuleSession.class);

        OutboundEndpoint endpoint1 = getTestOutboundEndpoint("Test1Provider");
        assertNotNull(endpoint1);

        List<String> recipients = new ArrayList<String>();
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
                   
                    // Ensure ENCODING message property is set to give exactly same behavior as before
                    // OutboundRewriteResponseEventMessageProcessor was removed (MULE-7535).
                    resultMessage.setEncoding(resultMessage.getEncoding());
                   
                    MuleSession storedSession = connector.getSessionHandler().retrieveSessionInfoFromMessage(
                        resultMessage);
                    event.getSession().merge(storedSession);
                    MuleEvent resultEvent = new DefaultMuleEvent(resultMessage, event);
                    OptimizedRequestContext.unsafeSetEvent(resultEvent);
                    return resultEvent;
View Full Code Here
33
34
35
36
37
38
39
40
41
42
43
    }

    @Test
    public void testMessageProcessor() throws Exception
    {
        MuleSession session = getTestSession(null, muleContext);
        Service testService = getTestService("test", Apple.class);
        assertNotNull(testService);

        MessageChunkAggregator router = new MessageChunkAggregator();
        router.setMuleContext(muleContext);
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
                                        handler = ((AbstractConnector) endpoint.getConnector()).getSessionHandler();
                                    } else
                                    {
                                        handler = new MuleSessionHandler();
                                    }
                                    MuleSession session;
                                    try
                                    {
                                        session = handler.retrieveSessionInfoFromMessage(muleMessage);
                                    }
                                    catch (SerializationException e)
View Full Code Here
105
106
107
108
109
110
111
112
113
114
115
        MuleMessage message2 = new DefaultMuleMessage("test event B", muleContext);
        message2.setInvocationProperty("key2", "value2");
        MuleMessage message3 = new DefaultMuleMessage("test event C", muleContext);
        message3.setInvocationProperty("key3", "value3");
        MuleEvent event1 = new DefaultMuleEvent(message1, endpoint, flow);
        MuleSession session = event1.getSession();
        MuleEvent event2 = new DefaultMuleEvent(message2, endpoint, flow, session);
        MuleEvent event3 = new DefaultMuleEvent(message3, endpoint, flow, session);
        event1.getSession().setProperty("key", "value");
        event2.getSession().setProperty("key1", "value1");
        event2.getSession().setProperty("key2", "value2");
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
    }

    @Test
    public void testAggregateMultipleEvents() throws Exception
    {
        MuleSession session1 = getTestSession(getTestService(), muleContext);
        session1.setProperty("key1", "value1");
        MuleSession session2 = getTestSession(getTestService(), muleContext);
        session1.setProperty("key1", "value1NEW");
        session1.setProperty("key2", "value2");
        MuleSession session3 = getTestSession(getTestService(), muleContext);
        session1.setProperty("key3", "value3");

        Service testService = getTestService("test", Apple.class);
        assertNotNull(testService);
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
    }

    @Test
    public void testAggregateSingleEvent() throws Exception
    {
        MuleSession session = getTestSession(getTestService(), muleContext);
        Service testService = getTestService("test", Apple.class);
        assertNotNull(testService);

        SimpleCollectionAggregator router = new SimpleCollectionAggregator();
        SensingNullMessageProcessor sensingMessageProcessor = getSensingNullMessageProcessor();
View Full Code Here
138
139
140
141
142
143
144
145
146
147
148
    }

    @Test
    public void testAggregateMessageCollections() throws Exception
    {
        MuleSession session = getTestSession(getTestService(), muleContext);
        Service testService = getTestService("test", Apple.class);
        assertNotNull(testService);

        SimpleCollectionAggregator router = new SimpleCollectionAggregator();
        router.setMuleContext(muleContext);
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
        ((OutboundRouterCollection) service.getOutboundMessageProcessor()).addRoute(passThroughRouter);
        //muleContext.getRegistry().registerComponent(service);

        MuleMessage message = new DefaultMuleMessage(MESSAGE, muleContext);
        message.setOutboundProperty(MailProperties.TO_ADDRESSES_PROPERTY, EMAIL);
        MuleSession session = getTestSession(null, muleContext);
        DefaultMuleEvent event = new DefaultMuleEvent(message, MessageExchangePattern.ONE_WAY,
            getTestService("apple", Apple.class), session, new ResponseOutputStream(System.out));
        endpoint.process(event);

        getServers().waitForIncomingEmail(AbstractEmailFunctionalTestCase.DELIVERY_DELAY_MS, 1);
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
        MuleMessage message = new DefaultMuleMessage("test event", muleContext);

        assertTrue(router.isMatch(message));

        when(mockEndpoint.process(any(MuleEvent.class))).thenAnswer(new MuleEventCheckAnswer());
        MuleSession session = mock(MuleSession.class);
        router.route(new OutboundRoutingTestEvent(message, session, muleContext));

        //Test with transform
        message = new DefaultMuleMessage(new Exception("test event"), muleContext);
View Full Code Here
TOP

Related Classes of org.mule.api.MuleSession

  • org.mule.construct.Flow
  • org.mule.MessagePropertiesContext
  • org.mule.module.client.MuleClient
  • org.mule.module.client.RemoteDispatcher
  • org.mule.module.client.remoting.RemoteDispatcherComponent
  • org.mule.module.cxf.CxfWsdlTestCase
  • org.mule.module.cxf.transport.MuleUniversalConduit
  • org.mule.module.ibeans.spi.MuleCallAnnotationHandler
  • org.mule.module.jca.DefaultMuleConnection
  • org.mule.module.spring.events.MuleEventMulticaster
    • 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.