Examples of buildOutboundEndpoint()

Examples of org.mule.api.endpoint.EndpointBuilder.buildOutboundEndpoint()

64
65
66
67
68
69
70
71
72
73
74
        }
        //TODO MULE-4952 what is the strategy here for proxy components?
        endpointBuilder.setExchangePattern(MessageExchangePattern.REQUEST_RESPONSE);

        OutboundEndpoint endpoint = endpointBuilder.buildOutboundEndpoint();

        MuleEvent responseEvent = endpoint.process(event);

        if (responseEvent != null)
        {
View Full Code Here

Examples of org.mule.api.endpoint.EndpointBuilder.buildOutboundEndpoint()

141
142
143
144
145
146
147
148
149
150
151
        {
            endpoint = endpointBuilder.buildInboundEndpoint();
        }
        else if (epData.getType() == ChannelType.Outbound)
        {
            endpoint = endpointBuilder.buildOutboundEndpoint();
        }
        else
        {
            throw new IllegalArgumentException("Channel type not recognised: " + epData.getType());
        }
View Full Code Here

Examples of org.mule.api.endpoint.EndpointBuilder.buildOutboundEndpoint()

453
454
455
456
457
458
459
460
461
462
463
                    else
                    {
                        EndpointBuilder epb = event.getMuleContext().getRegistry().lookupEndpointBuilder(tempReplyTo.toString());
                        if (epb != null)
                        {
                            tempReplyTo = epb.buildOutboundEndpoint().getEndpointURI().getAddress();
                        }
                    }
                }
            }
            if (tempReplyTo != null)
View Full Code Here

Examples of org.mule.api.endpoint.EndpointBuilder.buildOutboundEndpoint()

119
120
121
122
123
124
125
126
127
128
129
    public void testOutputAppendEndpointOverride() throws Exception
    {
        FileConnector connector = (FileConnector) getConnector();

        EndpointBuilder endpointBuilder = new EndpointURIEndpointBuilder(new URIBuilder("file://foo", muleContext));
        OutboundEndpoint endpoint = endpointBuilder.buildOutboundEndpoint();

        // Endpoint wants String-typed properties
        endpoint.getProperties().put("outputAppend", "true");

        try
View Full Code Here

Examples of org.mule.api.endpoint.EndpointBuilder.buildOutboundEndpoint()

158
159
160
161
162
163
164
165
166
167
168
    public void testPermanentDeliveryFailureDLQ() throws Exception
    {
        targetMessageProcessor.setNumberOfFailuresToSimulate(Integer.MAX_VALUE);
        EndpointBuilder dlqEndpointBuilder = mock(EndpointBuilder.class);
        OutboundEndpoint dlqEndpoint = mock(OutboundEndpoint.class);
        when(dlqEndpointBuilder.buildOutboundEndpoint()).thenReturn(dlqEndpoint);
        untilSuccessful.setDlqEndpoint(dlqEndpointBuilder);
        untilSuccessful.initialise();
        untilSuccessful.start();

        final MuleEvent testEvent = getTestEvent("ERROR");
View Full Code Here

Examples of org.mule.api.endpoint.EndpointBuilder.buildOutboundEndpoint()

54
55
56
57
58
59
60
61
62
63
64
        }

        //TODO MULE-4952 what is the strategy here for proxy components?
        endpointBuilder.setExchangePattern(MessageExchangePattern.REQUEST_RESPONSE);
        OutboundEndpoint endpoint = endpointBuilder.buildOutboundEndpoint();
       
        MuleEvent responseEvent = endpoint.process(event);

        if (responseEvent != null)
        {
View Full Code Here

Examples of org.mule.api.endpoint.EndpointBuilder.buildOutboundEndpoint()

72
73
74
75
76
77
78
79
80
81
82
    }
   
    private OutboundEndpoint lookupOutboundEndpoint(String name) throws Exception
    {
        EndpointBuilder endpointBuilder = lookupEndpointBuilder(name);
        return endpointBuilder.buildOutboundEndpoint();
    }

    private InboundEndpoint lookupInboundEndpoint(String name) throws Exception
    {
        EndpointBuilder endpointBuilder = lookupEndpointBuilder(name);
View Full Code Here

Examples of org.mule.api.endpoint.EndpointBuilder.buildOutboundEndpoint()

152
153
154
155
156
157
158
159
160
161
162
        message.addProperties(messageProperties, PropertyScope.INVOCATION);

        //TODO should probably cache this
        EndpointBuilder endpointBuilder = muleContext.getEndpointFactory().getEndpointBuilder(endpoint);
        endpointBuilder.setExchangePattern(exchangePattern);
        OutboundEndpoint ep = endpointBuilder.buildOutboundEndpoint();
      
        DefaultMuleEvent event = new DefaultMuleEvent(message, ep.getExchangePattern(),
            new DefaultMuleSession(flowConstruct, muleContext));

        RequestContext.setEvent(event);
View Full Code Here

Examples of org.mule.api.endpoint.EndpointBuilder.buildOutboundEndpoint()

204
205
206
207
208
209
210
211
212
213
214
        event.getMessage().setOutboundProperty(HttpConnector.HTTP_METHOD_PROPERTY, httpMethod);

        EndpointBuilder endpointBuilder = new EndpointURIEndpointBuilder(tempUrl, muleContext);
        endpointBuilder.setExchangePattern(MessageExchangePattern.REQUEST_RESPONSE);
        OutboundEndpoint outboundEndpoint = endpointBuilder.buildOutboundEndpoint();

        MuleEventContext eventContext = new DefaultMuleEventContext(event);
        result = eventContext.sendEvent(
            new DefaultMuleMessage(requestBody, event.getMessage(), muleContext), outboundEndpoint);
        if (isErrorPayload(result))
View Full Code Here

Examples of org.mule.api.endpoint.EndpointBuilder.buildOutboundEndpoint()

44
45
46
47
48
49
50
51
52
53
54
    public void testBuildOutboundEndpoint() throws MuleException
    {
        String uri = "test://address";
        EndpointBuilder endpointBuilder = new EndpointURIEndpointBuilder(uri, muleContext);
        ImmutableEndpoint ep = endpointBuilder.buildOutboundEndpoint();
        assertFalse(ep instanceof InboundEndpoint);
        assertTrue(ep instanceof OutboundEndpoint);
        // We no longer apply default transport transformers as part of endpoint processing
        assertEquals(0, ep.getTransformers().size());
        assertNotNull(ep.getResponseTransformers());
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.