Package org.apache.cxf.interceptor

Examples of org.apache.cxf.interceptor.Interceptor

57
58
59
60
61
62
63
64
65
66
67
        new Integer(4);
    }
   
    @SuppressWarnings("unchecked")
    private List<Interceptor<? extends Message>> createMockInterceptorList() {
        Interceptor i = control.createMock(Interceptor.class);
        Interceptor<? extends Message> m = i;
        List<Interceptor<? extends Message>> a = new ArrayList<Interceptor<? extends Message>>();
        a.add(m);
        return a;
    }
View Full Code Here
551
552
553
554
555
556
557
558
559
560
561
    private RMManager getManager(SoapMessage message) {
        InterceptorChain chain = message.getInterceptorChain();
        ListIterator it = chain.getIterator();
        while (it.hasNext()) {
            Interceptor i = (Interceptor)it.next();
            if (i instanceof AbstractRMInterceptor) {
                return ((AbstractRMInterceptor)i).getManager();
            }
        }
        return null;
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
        control = EasyMock.createNiceControl();
    }
   
    @SuppressWarnings("unchecked")
    private List<Interceptor<? extends Message>> createMockInterceptorList() {
        Interceptor i = control.createMock(Interceptor.class);
        Interceptor<? extends Message> m = i;
        List<Interceptor<? extends Message>> a = new ArrayList<Interceptor<? extends Message>>();
        a.add(m);
        return a;
    }
View Full Code Here
68
69
70
71
72
73
74
75
76
77
78
        bus = control.createMock(Bus.class);      
    }
   
    @SuppressWarnings("unchecked")
    private List<Interceptor<? extends Message>> createMockInterceptorList() {
        Interceptor i = control.createMock(Interceptor.class);
        Interceptor<? extends Message> m = i;
        List<Interceptor<? extends Message>> a = new ArrayList<Interceptor<? extends Message>>();
        a.add(m);
        return a;
    }
View Full Code Here
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
        updateIterator();
       
        pausedMessage = message;
        while (state == State.EXECUTING && iterator.hasNext()) {
            try {
                Interceptor currentInterceptor = iterator.next();
              
                if (LOG.isLoggable(Level.FINE)) {
                    LOG.fine("Invoking handleMessage on interceptor " + currentInterceptor);
                }
                //System.out.println("-----------" + currentInterceptor);
                currentInterceptor.handleMessage(message);
               
            } catch (RuntimeException ex) {
                if (!faultOccurred) {
                    faultOccurred = true;
View Full Code Here
323
324
325
326
327
328
329
330
331
332
333
334
    }
   
    @SuppressWarnings("unchecked")
    private void unwind(Message message) {
        while (iterator.hasPrevious()) {
            Interceptor currentInterceptor = iterator.previous();
            if (LOG.isLoggable(Level.FINE)) {
                LOG.fine("Invoking handleFault on interceptor " + currentInterceptor);
            }
            currentInterceptor.handleFault(message);
        }
    }
View Full Code Here
558
559
560
561
562
563
564
565
566
567
568
        public boolean remove(Object o) {
            other.remove(o);
            return orig.remove(o);
        }
        public Interceptor remove(int index) {
            Interceptor o = orig.remove(index);
            if (o == null) {
                other.remove(o);
            }
            return o;
        }
View Full Code Here
572
573
574
575
576
577
578
579
580
581
582
        }
        public boolean retainAll(Collection<?> c) {
            throw new UnsupportedOperationException();
        }
        public Interceptor set(int index, Interceptor element) {
            Interceptor o = orig.set(index, element);
            if (o != null) {
                int idx = other.indexOf(o);
                other.set(idx, element);
            }
            return o;
View Full Code Here
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
                && message.getExchange() != oldMessage.getExchange()) {
                message.put(PREVIOUS_MESSAGE, new WeakReference<Message>(oldMessage));
            }
            while (state == State.EXECUTING && iterator.hasNext()) {
                try {
                    Interceptor currentInterceptor = iterator.next();
                    if (isFineLogging) {
                        LOG.fine("Invoking handleMessage on interceptor " + currentInterceptor);
                    }
                    //System.out.println("-----------" + currentInterceptor);
                    currentInterceptor.handleMessage(message);
                    if (state == State.SUSPENDED) {
                         // throw the exception to make sure thread exit without interrupt
                        throw new SuspendedInvocationException();
                    }
                   
View Full Code Here
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
    }
   
    @SuppressWarnings("unchecked")
    public void unwind(Message message) {
        while (iterator.hasPrevious()) {
            Interceptor currentInterceptor = iterator.previous();
            if (isFineLogging) {
                LOG.fine("Invoking handleFault on interceptor " + currentInterceptor);
            }
            try {
                currentInterceptor.handleFault(message);
            } catch (RuntimeException e) {
                LOG.log(Level.WARNING, "Exception in handleFault on interceptor " + currentInterceptor, e);
                throw e;
            } catch (Exception e) {
                LOG.log(Level.WARNING, "Exception in handleFault on interceptor " + currentInterceptor, e);
View Full Code Here
TOP

Related Classes of org.apache.cxf.interceptor.Interceptor

  • org.apache.cxf.jaxws.EndpointImpl$DoubleAddInterceptorList
  • org.apache.cxf.management.counters.CounterRepository
  • org.apache.cxf.phase.PhaseInterceptorChain
  • org.apache.cxf.systest.ws.rm.ControlImpl
  • org.apache.cxf.systest.ws.rm.SequenceTest
  • org.apache.cxf.ws.policy.EffectivePolicyImplTest
  • org.apache.cxf.ws.policy.EndpointPolicyImplTest
  • org.apache.cxf.ws.policy.PolicyInterceptorsTest
  • org.apache.cxf.ws.rm.soap.RMSoapInterceptor
  • org.apache.servicemix.cxfbc.ws.rm.CxfBcRMSequenceTest
    • Copyright © 2018 www.massapicom. 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.