Package org.apache.cxf.phase

Examples of org.apache.cxf.phase.PhaseInterceptorChain.doIntercept()

478
479
480
481
482
483
484
485
486
487
488
            // add additional interceptors and such
            modifyChain(chain, message, false);
           
            // execute chain
            chain.doIntercept(message);

            return processResult(message, exchange, oi, resContext);

        } finally {
            BusFactory.setThreadDefaultBus(origBus);
View Full Code Here
666
667
668
669
670
671
672
673
674
675
676
            } else if (startingInterceptorID != null) {
                chain.doInterceptStartingAt(message, startingInterceptorID);
            } else if (message.getContent(Exception.class) != null) {
                outFaultObserver.onMessage(message);
            } else {
                chain.doIntercept(message);
            }

            callback = message.getExchange().get(ClientCallback.class);

            if (callback != null && !isPartialResponse(message)) {
View Full Code Here
160
161
162
163
164
165
166
167
168
169
170
       
        chain.add(new SOAPHandlerInterceptor(binding));
        message.setInterceptorChain(chain);
        control.replay();

        chain.doIntercept(message);
       
        control.verify();

        writer.flush();
       
View Full Code Here
363
364
365
366
367
368
369
370
371
372
373
        });
        chain.add(new SOAPHandlerInterceptor(binding));
        message.setInterceptorChain(chain);
        control.replay();

        chain.doIntercept(message);
       
        control.verify();

        // Verify SOAPMessage header
        SOAPMessage soapMessageNew = message.getContent(SOAPMessage.class);
View Full Code Here
177
178
179
180
181
182
183
184
185
186
187
   
            // setup conduit selector
            prepareConduitSelector(message);
           
            // execute chain
            chain.doIntercept(message);
           
            Exception exp = message.getContent(Exception.class);
            if (exp == null && exchange.getInMessage() != null) {
                exp = exchange.getInMessage().getContent(Exception.class);
            }
View Full Code Here
328
329
330
331
332
333
334
335
336
337
338
        // execute chain
        Bus origBus = BusFactory.getThreadDefaultBus(false);
        BusFactory.setThreadDefaultBus(bus);
        try {
            chain.doIntercept(message);
        } finally {
            synchronized (message.getExchange()) {
                message.getExchange().put(FINISHED, Boolean.TRUE);
                message.getExchange().setInMessage(message);
                message.getExchange().notifyAll();
View Full Code Here
149
150
151
152
153
154
155
156
157
158
159
            copyDataBindingInterceptors(chain, inMessage.getInterceptorChain());

            InterceptorChain oldChain = inMessage.getInterceptorChain();
            inMessage.setInterceptorChain(chain);
            try {
                chain.doIntercept(inMessage);
            } finally {
                inMessage.setInterceptorChain(oldChain);
            }

            // TODO: the result should be deserialized from SOAPMessage
View Full Code Here
464
465
466
467
468
469
470
471
472
473
474
           
            // setup conduit selector
            prepareConduitSelector(message);
           
            // execute chain       
            chain.doIntercept(message);
   
            return processResult(message, exchange, oi, resContext);
           
        } finally {
            BusFactory.setThreadDefaultBus(origBus);
View Full Code Here
636
637
638
639
640
641
642
643
644
645
646
            if (startingAfterInterceptorID != null) {
                chain.doInterceptStartingAfter(message, startingAfterInterceptorID);
            } else if (startingInterceptorID != null) {
                chain.doInterceptStartingAt(message, startingInterceptorID);
            } else {
                chain.doIntercept(message);
            }
           
            callback = message.getExchange().get(ClientCallback.class);
           
            if (callback != null && !isPartialResponse(message)) {
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
            PhaseInterceptorChain chain = new PhaseInterceptorChain(getPhases());
            initializeInterceptors(faultMessage.getExchange(), chain);
           
            faultMessage.setInterceptorChain(chain);
            try {
                chain.doIntercept(faultMessage);
            } catch (Exception exc) {
                LOG.log(Level.SEVERE, "Error occurred during error handling, give up!", exc);
                throw new RuntimeException(exc);
            }
        } finally {
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.