Examples of createInOutExchange()

Examples of javax.jbi.messaging.MessageExchangeFactory.createInOutExchange()

96
97
98
99
100
101
102
103
104
105
106
        NormalizedMessage message = EasyMock.createMock(NormalizedMessage.class);
        ByteArrayInputStream messageStream = new ByteArrayInputStream(TEST_MESSAGE.getBytes());
       
        channel.createExchangeFactoryForService(serviceName);
        EasyMock.expectLastCall().andReturn(factory);
        factory.createInOutExchange();
        EasyMock.expectLastCall().andReturn(exchange);
        exchange.createMessage();
        EasyMock.expectLastCall().andReturn(message);
        exchange.getEndpoint();
        EasyMock.expectLastCall().andReturn(null);
View Full Code Here

Examples of javax.jbi.messaging.MessageExchangeFactory.createInOutExchange()

70
71
72
73
74
75
76
77
78
79
80
            assert ws != null;
            QName interfaceName = new QName(ws.targetNamespace(), ws.name());
           
            MessageExchangeFactory factory = channel.createExchangeFactoryForService(serviceName);
            LOG.fine("create message exchange svc: " + serviceName);
            InOut xchng = factory.createInOutExchange();
           
            NormalizedMessage inMsg = xchng.createMessage();
            LOG.fine("exchange endpoint: " + xchng.getEndpoint());
           
            InputStream ins = null;
View Full Code Here

Examples of javax.jbi.messaging.MessageExchangeFactory.createInOutExchange()

46
47
48
49
50
51
52
53
54
55
56
                channel.send(io);
            }
        } else {
            if (exchange.getStatus() == ExchangeStatus.ACTIVE) {
                MessageExchangeFactory factory = channel.createExchangeFactory();
                InOut io = factory.createInOutExchange();
                MessageUtil.transferInToIn(exchange, io);
                io.setService(new QName("echo"));
                io.setProperty("exchange", exchange);
                channel.send(io);
            } else if (exchange.getStatus() == ExchangeStatus.DONE) {
View Full Code Here

Examples of javax.jbi.messaging.MessageExchangeFactory.createInOutExchange()

233
234
235
236
237
238
239
240
241
242
243
        }
       
        public Source twoWay(Source src) throws Exception {
            DeliveryChannel channel = context.getDeliveryChannel();
            MessageExchangeFactory factory = channel.createExchangeFactory();
            InOut inout = factory.createInOutExchange();
            inout.setService(ReceiverComponent.SERVICE);
            NormalizedMessage msg = inout.createMessage();
            msg.setContent(src);
            inout.setInMessage(msg);
            channel.sendSync(inout);
View Full Code Here

Examples of org.apache.servicemix.client.DefaultServiceMixClient.createInOutExchange()

32
33
34
35
36
37
38
39
40
41
42
public class ScriptComponentTest extends SpringTestSupport {
    private static transient Log log = LogFactory.getLog(ScriptComponentTest.class);

    public void testGroovy() throws Exception {
        DefaultServiceMixClient client = new DefaultServiceMixClient(jbi);
        InOut me = client.createInOutExchange();
        me.setService(new QName("urn:test", "groovy"));
        me.getInMessage().setContent(new StringSource("<hello>world</hello>"));
        client.sendSync(me);
        if (me.getStatus() == ExchangeStatus.ERROR) {
            if (me.getError() != null) {
View Full Code Here

Examples of org.apache.servicemix.client.DefaultServiceMixClient.createInOutExchange()

51
52
53
54
55
56
57
58
59
60
61
        client.done(me);
    }
   
    public void testRuby() throws Exception {
        DefaultServiceMixClient client = new DefaultServiceMixClient(jbi);
        InOut me = client.createInOutExchange();
        me.setService(new QName("urn:test", "jruby"));
        me.getInMessage().setContent(new StringSource("<hello>world</hello>"));
        client.sendSync(me);
        if (me.getStatus() == ExchangeStatus.ERROR) {
            if (me.getError() != null) {
View Full Code Here

Examples of org.apache.servicemix.client.DefaultServiceMixClient.createInOutExchange()

124
125
126
127
128
129
130
131
132
133
134
                        container.getRegistry().getExternalEndpointsForService(
                                        new QName("http://test", "MySoapService"))[0]));

        // Test
        DefaultServiceMixClient client = new DefaultServiceMixClient(container);
        InOut me = client.createInOutExchange();
        me.setService(new QName("http://test", "MyProviderService"));
        me.getInMessage().setContent(new StringSource("<echo xmlns='http://test'><echoin0>world</echoin0></echo>"));
        client.sendSync(me);
        if (me.getStatus() == ExchangeStatus.ERROR) {
            if (me.getFault() != null) {
View Full Code Here

Examples of org.apache.servicemix.client.DefaultServiceMixClient.createInOutExchange()

200
201
202
203
204
205
206
207
208
209
210
        component.getServiceUnitManager().deploy("provider", path.getAbsolutePath());
        component.getServiceUnitManager().start("provider");

        // Call it
        DefaultServiceMixClient client = new DefaultServiceMixClient(container);
        InOut inout = client.createInOutExchange();
        inout.setInterfaceName(new QName("http://http.servicemix.org/Test", "ProviderInterface"));
        inout.getInMessage().setContent(new StreamSource(new ByteArrayInputStream(msg.getBytes())));

        long t0 = System.currentTimeMillis();
        client.sendSync(inout);
View Full Code Here

Examples of org.apache.servicemix.client.DefaultServiceMixClient.createInOutExchange()

42
43
44
45
46
47
48
49
50
51
52
    private static transient Log log = LogFactory.getLog(HttpAddressingTest.class);

    public void testOk() throws Exception {
        DefaultServiceMixClient client = new DefaultServiceMixClient(jbi);
        InOut me = client.createInOutExchange();
        me.setService(new QName("http://test", "MyProviderService"));
        InputStream fis = getClass().getResourceAsStream("addressing-request.xml");
        me.getInMessage().setContent(new StreamSource(fis));
        client.sendSync(me);
        if (me.getStatus() == ExchangeStatus.ERROR) {
View Full Code Here

Examples of org.apache.servicemix.client.DefaultServiceMixClient.createInOutExchange()

64
65
66
67
68
69
70
71
72
73
74
        DocumentFragment epr = URIResolver.createWSAEPR("bean:listenerBean");
        ServiceEndpoint se = client.getContext().resolveEndpointReference(epr);
        assertNotNull("We should find a service endpoint!", se);

        InOut exchange = client.createInOutExchange();
        exchange.setEndpoint(se);
        exchange.getInMessage().setContent(new StringSource("<hello>world</hello>"));
        client.sendSync(exchange);
        client.done(exchange);
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.