Package org.switchyard

Examples of org.switchyard.Exchange.createMessage()

58
59
60
61
62
63
64
65
66
67
68
    @Test
    public void testInFaultMessageTrace() throws Exception {
        ServiceReference service = _domain.createInOutService(
                new QName("InFaultTrace"), new MockHandler().forwardInToOut());
        Exchange exchange = service.createExchange(new MockHandler());
        exchange.send(exchange.createMessage());
    }
   
    @Test
    public void testStreamContent() throws Exception {
        String contentAsString = "abc-InputStream-xyz";
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
        _domain.getTransformerRegistry().addTransformer(new StreamTransformer());
        ServiceReference service = _domain.createInOnlyService(new QName("StreamTest"), provider);
       
        InputStream contentAsStream = new ByteArrayInputStream(contentAsString.getBytes());
        Exchange ex = service.createExchange();
        Message msg = ex.createMessage();
        msg.setContent(contentAsStream);
        ex.send(msg);

        Message rcvdMsg = provider.getMessages().poll().getMessage();
        Assert.assertTrue(rcvdMsg.getContent(InputStream.class).available() > 0);
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
        _domain.getTransformerRegistry().addTransformer(new ReaderTransformer());
        ServiceReference service = _domain.createInOnlyService(new QName("ReaderTest"), provider);
       
        StringReader contentAsReader = new StringReader(contentAsString);
        Exchange ex = service.createExchange();
        Message msg = ex.createMessage();
        msg.setContent(contentAsReader);
        ex.send(msg);

        Message rcvdMsg = provider.getMessages().poll().getMessage();
        Assert.assertTrue(rcvdMsg.getContent(Reader.class).read() != -1);
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
    private void sendMessage(final ServiceReference ref, final Object content) throws Exception {
        new Thread(new Runnable() {
            public void run() {
                Exchange exchange = ref.createExchange(new MockHandler());
                exchange.send(exchange.createMessage().setContent(content));
            }
        }).start();
    }
   
    class TakesForeverHandler extends BaseHandler {
View Full Code Here
424
425
426
427
428
429
430
431
432
433
434
        final int NUM_SENDS = 5;
        for (int i = 0; i < NUM_SENDS; i++) {
            new Thread(new Runnable() {
                public void run() {
                    Exchange exchange = reference.createExchange();
                    Message message = exchange.createMessage();
                    exchange.send(message);
                }
            }).start();
        }
       
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.