| /** |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| */ |
| |
| package org.apache.cxf.endpoint; |
| |
| import java.io.Closeable; |
| import java.util.Collections; |
| import java.util.List; |
| import java.util.Map; |
| import java.util.ResourceBundle; |
| import java.util.concurrent.CopyOnWriteArrayList; |
| import java.util.concurrent.Executor; |
| import java.util.logging.Logger; |
| |
| import javax.xml.namespace.QName; |
| |
| import org.apache.cxf.Bus; |
| import org.apache.cxf.BusException; |
| import org.apache.cxf.BusFactory; |
| import org.apache.cxf.binding.Binding; |
| import org.apache.cxf.binding.BindingFactory; |
| import org.apache.cxf.binding.BindingFactoryManager; |
| import org.apache.cxf.common.i18n.Message; |
| import org.apache.cxf.common.logging.LogUtils; |
| import org.apache.cxf.configuration.Configurable; |
| import org.apache.cxf.feature.Feature; |
| import org.apache.cxf.helpers.CastUtils; |
| import org.apache.cxf.interceptor.AbstractAttributedInterceptorProvider; |
| import org.apache.cxf.interceptor.ClientFaultConverter; |
| import org.apache.cxf.interceptor.InFaultChainInitiatorObserver; |
| import org.apache.cxf.interceptor.MessageSenderInterceptor; |
| import org.apache.cxf.interceptor.OutFaultChainInitiatorObserver; |
| import org.apache.cxf.service.Service; |
| import org.apache.cxf.service.model.BindingInfo; |
| import org.apache.cxf.service.model.EndpointInfo; |
| import org.apache.cxf.transport.MessageObserver; |
| |
| public class EndpointImpl extends AbstractAttributedInterceptorProvider implements Endpoint, Configurable { |
| |
| private static final long serialVersionUID = -7660560719050162091L; |
| private static final Logger LOG = LogUtils.getL7dLogger(EndpointImpl.class); |
| private static final ResourceBundle BUNDLE = LOG.getResourceBundle(); |
| |
| private Service service; |
| private Binding binding; |
| private EndpointInfo endpointInfo; |
| private Executor executor; |
| private Bus bus; |
| private MessageObserver inFaultObserver; |
| private MessageObserver outFaultObserver; |
| private List<Feature> activeFeatures; |
| private List<Closeable> cleanupHooks; |
| |
| public EndpointImpl(Bus bus, Service s, QName endpointName) throws EndpointException { |
| this(bus, s, s.getEndpointInfo(endpointName)); |
| } |
| |
| public EndpointImpl(Bus bus, Service s, EndpointInfo ei) throws EndpointException { |
| if (ei == null) { |
| throw new NullPointerException("EndpointInfo can not be null!"); |
| } |
| |
| if (bus == null) { |
| this.bus = BusFactory.getThreadDefaultBus(); |
| } else { |
| this.bus = bus; |
| } |
| service = s; |
| endpointInfo = ei; |
| |
| createBinding(endpointInfo.getBinding()); |
| |
| inFaultObserver = new InFaultChainInitiatorObserver(bus); |
| outFaultObserver = new OutFaultChainInitiatorObserver(bus); |
| |
| getInFaultInterceptors().add(new ClientFaultConverter()); |
| getOutInterceptors().add(new MessageSenderInterceptor()); |
| getOutFaultInterceptors().add(new MessageSenderInterceptor()); |
| } |
| |
| public String getBeanName() { |
| return endpointInfo.getName().toString() + ".endpoint"; |
| } |
| |
| |
| public EndpointInfo getEndpointInfo() { |
| return endpointInfo; |
| } |
| |
| public Service getService() { |
| return service; |
| } |
| |
| public Binding getBinding() { |
| return binding; |
| } |
| |
| public Executor getExecutor() { |
| return executor == null ? service.getExecutor() : executor; |
| } |
| |
| public void setExecutor(Executor e) { |
| executor = e; |
| } |
| |
| public Bus getBus() { |
| return bus; |
| } |
| |
| public void setBus(Bus bus) { |
| this.bus = bus; |
| } |
| |
| final void createBinding(BindingInfo bi) throws EndpointException { |
| if (null != bi) { |
| String namespace = bi.getBindingId(); |
| try { |
| final BindingFactory bf = bus.getExtension(BindingFactoryManager.class).getBindingFactory(namespace); |
| if (null == bf) { |
| Message msg = new Message("NO_BINDING_FACTORY", BUNDLE, namespace); |
| throw new EndpointException(msg); |
| } |
| binding = bf.createBinding(bi); |
| } catch (BusException ex) { |
| throw new EndpointException(ex); |
| } |
| } |
| } |
| |
| |
| public MessageObserver getInFaultObserver() { |
| return inFaultObserver; |
| } |
| |
| public MessageObserver getOutFaultObserver() { |
| return outFaultObserver; |
| } |
| |
| public void setInFaultObserver(MessageObserver observer) { |
| inFaultObserver = observer; |
| } |
| |
| public void setOutFaultObserver(MessageObserver observer) { |
| outFaultObserver = observer; |
| |
| } |
| |
| /** |
| * Utility method to make it easy to set properties from Spring. |
| * |
| * @param properties |
| */ |
| public void setProperties(Map<String, Object> properties) { |
| this.putAll(properties); |
| } |
| |
| /** |
| * @return the list of features <b>already</b> activated for this endpoint. |
| */ |
| public List<Feature> getActiveFeatures() { |
| return activeFeatures; |
| } |
| |
| /** |
| * @param features the list of features <b>already</b> activated for this endpoint. |
| */ |
| public void initializeActiveFeatures(List<? extends Feature> features) { |
| activeFeatures = CastUtils.cast(features); |
| } |
| |
| @Override |
| public boolean equals(Object obj) { |
| if (this == obj) { |
| return true; |
| } |
| if (!(obj instanceof EndpointImpl)) { |
| return false; |
| } |
| |
| return super.equals(obj); |
| } |
| |
| /** |
| * Returns the hashCode based on the EndpointInfo so that this object |
| * can be used as a map key. |
| */ |
| @Override |
| public int hashCode() { |
| return endpointInfo.hashCode(); |
| } |
| |
| public synchronized void addCleanupHook(Closeable c) { |
| if (cleanupHooks == null) { |
| cleanupHooks = new CopyOnWriteArrayList<>(); |
| } |
| cleanupHooks.add(c); |
| } |
| public List<Closeable> getCleanupHooks() { |
| if (cleanupHooks == null) { |
| return Collections.emptyList(); |
| } |
| return cleanupHooks; |
| } |
| } |