Examples of org.apache.cxf.transport.Conduit.prepare()

org.apache.cxf.transport.Conduit.prepare()
Prepare the message for sending. This will typically involve setting an OutputStream on the message, but it may do nothing at all. @param message the message to be sent.

                    + "start=\"<soap.xml@xfire.codehaus.org>\"; "
                    + "start-info=\"text/xml; charset=utf-8\"; "
                    + "boundary=\"----=_Part_4_701508.1145579811786\"";


        m.put(Message.CONTENT_TYPE, ct);
        conduit.prepare(m);


        OutputStream os = m.getContent(OutputStream.class);
        InputStream is = getResourceAsStream("request");
        if (is == null) {
            throw new RuntimeException("Could not find resource " + "request");

View Full Code Here

                    .getBackChannel(message, null, null);
                if (conduit != null) {
                    message.getExchange().setInMessage(null);
                    //for a one-way, the back channel could be
                    //null if it knows it cannot send anything.
                    conduit.prepare(partial);
                    conduit.close(partial);
                    message.getExchange().setInMessage(message);
                }
            } catch (IOException e) {
                //IGNORE

View Full Code Here

            }
            in.close();
            
            Conduit backChannel = message.getDestination().getBackChannel(message, null, null);


            backChannel.prepare(message);


            OutputStream out = message.getContent(OutputStream.class);
            Assert.assertNotNull(out);
            InputStream  res = getClass().getResourceAsStream(responseMessage);
            IOUtils.copy(res, out, 2045);

View Full Code Here


        public void onMessage(Message message) {
            try {
                Conduit backChannel = message.getDestination().getBackChannel(message, null, null);


                backChannel.prepare(message);


                OutputStream out = message.getContent(OutputStream.class);
                assertNotNull(out);
                InputStream in = message.getContent(InputStream.class);
                assertNotNull(in);

View Full Code Here

                        //for a one-way, the back channel could be
                        //null if it knows it cannot send anything.
                        Message partial = createMessage(message.getExchange());
                        partial.remove(Message.CONTENT_TYPE);
                        partial.setExchange(message.getExchange());
                        conduit.prepare(partial);
                        conduit.close(partial);
                    }
                } catch (IOException e) {
                    LOG.log(Level.SEVERE, e.getMessage());
                    throw new RMException(e);

View Full Code Here


        TestMessageObserver obs = new TestMessageObserver();
        conduit.setMessageObserver(obs);


        Message m = new MessageImpl();
        conduit.prepare(m);


        OutputStream os = m.getContent(OutputStream.class);
        InputStream is = getResourceAsStream(message);
        if (is == null) {
            throw new RuntimeException("Could not find resource " + message);

View Full Code Here


        TestMessageObserver obs = new TestMessageObserver();
        conduit.setMessageObserver(obs);


        Message m = new MessageImpl();
        conduit.prepare(m);


        OutputStream os = m.getContent(OutputStream.class);
        os.write(message);


        // TODO: shouldn't have to do this. IO caching needs cleaning

View Full Code Here

        destination.doService(request, response);
        setUpInMessage();
        Conduit backChannel =
            destination.getBackChannel(inMessage, null, null);
        outMessage = setUpOutMessage();
        backChannel.prepare(outMessage);
        verifyBackChannelSend(backChannel, outMessage, 200);
    }


    @Test
    public void testGetBackChannelSendFault() throws Exception {

View Full Code Here

        destination.doService(request, response);
        setUpInMessage();
        Conduit backChannel =
            destination.getBackChannel(inMessage, null, null);
        outMessage = setUpOutMessage();
        backChannel.prepare(outMessage);
        verifyBackChannelSend(backChannel, outMessage, 500);
    }
    
    @Test
    public void testGetBackChannelSendOneway() throws Exception {

View Full Code Here

        destination.doService(request, response);
        setUpInMessage();
        Conduit backChannel =
            destination.getBackChannel(inMessage, null, null);
        outMessage = setUpOutMessage();
        backChannel.prepare(outMessage);
        verifyBackChannelSend(backChannel, outMessage, 500, true);
    }


    @Test
    public void testGetBackChannelSendDecoupled() throws Exception {

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.