01: /**
02: * Licensed to the Apache Software Foundation (ASF) under one
03: * or more contributor license agreements. See the NOTICE file
04: * distributed with this work for additional information
05: * regarding copyright ownership. The ASF licenses this file
06: * to you under the Apache License, Version 2.0 (the
07: * "License"); you may not use this file except in compliance
08: * with the License. You may obtain a copy of the License at
09: *
10: * http://www.apache.org/licenses/LICENSE-2.0
11: *
12: * Unless required by applicable law or agreed to in writing,
13: * software distributed under the License is distributed on an
14: * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15: * KIND, either express or implied. See the License for the
16: * specific language governing permissions and limitations
17: * under the License.
18: */package org.apache.cxf.binding.soap.interceptor;
19:
20: import java.util.Set;
21:
22: import org.apache.cxf.binding.soap.SoapMessage;
23: import org.apache.cxf.binding.soap.SoapVersion;
24: import org.apache.cxf.binding.soap.model.SoapBindingInfo;
25: import org.apache.cxf.endpoint.Endpoint;
26: import org.apache.cxf.interceptor.AbstractEndpointSelectionInterceptor;
27: import org.apache.cxf.message.Message;
28: import org.apache.cxf.phase.Phase;
29: import org.apache.cxf.service.model.BindingInfo;
30: import org.apache.cxf.service.model.EndpointInfo;
31:
32: /**
33: * Selects the most appropriate endpoint based on the SOAP version used.
34: *
35: * @param message
36: * @param eps
37: * @return
38: */
39: public class EndpointSelectionInterceptor extends
40: AbstractEndpointSelectionInterceptor {
41:
42: public EndpointSelectionInterceptor() {
43: super (Phase.READ);
44: getAfter().add(ReadHeadersInterceptor.class.getName());
45: }
46:
47: protected Endpoint selectEndpoint(Message message, Set<Endpoint> eps) {
48: SoapVersion sv = ((SoapMessage) message).getVersion();
49:
50: for (Endpoint e : eps) {
51: EndpointInfo ei = e.getEndpointInfo();
52: BindingInfo binding = ei.getBinding();
53:
54: if (binding instanceof SoapBindingInfo
55: && ((SoapBindingInfo) binding).getSoapVersion()
56: .equals(sv)) {
57: return e;
58: }
59: }
60:
61: return null;
62: }
63:
64: }
|