Refactor tuscany-endpoint module into tuscany-core

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@819786 13f79535-47bb-0310-9956-ffa450edef68

5 files changed, 625 insertions, 0 deletions

diff --git a/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/EndpointReferenceBuilderImpl.java b/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/EndpointReferenceBuilderImpl.java
new file mode 100644
index 0000000000..e1bb50a2b9
--- /dev/null
+++ b/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/EndpointReferenceBuilderImpl.java
@@ -0,0 +1,311 @@
+/*
+ * 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.tuscany.sca.core.assembly.impl;
+
+import java.util.List;
+
+import org.apache.tuscany.sca.assembly.AssemblyFactory;
+import org.apache.tuscany.sca.assembly.Composite;
+import org.apache.tuscany.sca.assembly.Endpoint;
+import org.apache.tuscany.sca.assembly.EndpointReference;
+import org.apache.tuscany.sca.assembly.builder.EndpointReferenceBuilder;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.core.FactoryExtensionPoint;
+import org.apache.tuscany.sca.core.UtilityExtensionPoint;
+import org.apache.tuscany.sca.interfacedef.InterfaceContractMapper;
+import org.apache.tuscany.sca.monitor.Monitor;
+import org.apache.tuscany.sca.monitor.MonitorFactory;
+import org.apache.tuscany.sca.monitor.Problem;
+import org.apache.tuscany.sca.runtime.EndpointRegistry;
+
+/**
+ * An builder that takes endpoint references and resolves them. It either finds local
+ * service endpoints if they are available or asks the domain. The main function here
+ * is to perform binding and policy matching.
+ * This is a separate builder in case it is required by undresolved endpoints
+ * once the runtime has started.
+ *
+ * @version $Rev$ $Date$
+ */
+public class EndpointReferenceBuilderImpl implements EndpointReferenceBuilder {
+
+    protected ExtensionPointRegistry extensionPoints;
+    protected AssemblyFactory assemblyFactory;
+    protected InterfaceContractMapper interfaceContractMapper;
+    protected EndpointRegistry endpointRegistry;
+    private Monitor monitor;
+
+
+    public EndpointReferenceBuilderImpl(ExtensionPointRegistry extensionPoints) {
+        this.extensionPoints = extensionPoints;
+
+        FactoryExtensionPoint factories = extensionPoints.getExtensionPoint(FactoryExtensionPoint.class);
+        this.assemblyFactory = factories.getFactory(AssemblyFactory.class);
+
+        UtilityExtensionPoint utils = extensionPoints.getExtensionPoint(UtilityExtensionPoint.class);
+        this.interfaceContractMapper = utils.getUtility(InterfaceContractMapper.class);
+        this.endpointRegistry = utils.getUtility(EndpointRegistry.class);
+        MonitorFactory monitorFactory = utils.getUtility(MonitorFactory.class);
+        monitor = monitorFactory.createMonitor();
+    }
+    
+    /**
+     * Build a composite
+     *
+     * @param endpoint
+     * @param monitor
+     */
+    public void buildtimeBuild(Composite composite) { 
+        // TODO - ready for reorganization of the builders
+        //        build all the endpoint references in a composite
+        //        that it is possible to build in order to get any
+        //        errors out as early as possible. Any that can't
+        //        be built now must wait until runtime
+    }
+
+    /**
+     * Build a single endpoint reference
+     *
+     * @param endpoint
+     * @param monitor
+     */
+    public Problem runtimeBuild(EndpointReference endpointReference) {
+        
+        Problem problem = null;
+
+        if ( endpointReference.getStatus() == EndpointReference.WIRED_TARGET_FOUND_AND_MATCHED ||
+             endpointReference.getStatus() == EndpointReference.RESOLVED_BINDING ) {
+            // The endpoint reference is already resolved to either
+            // a service endpoint local to this composite or it has
+            // a remote binding
+            
+            // still need to check that the callback endpoint is set correctly
+            if (hasCallback(endpointReference) &&
+                endpointReference.getCallbackEndpoint() == null &&
+                endpointReference.getCallbackEndpoint().isUnresolved() == true ){
+                problem = selectCallbackEndpoint(endpointReference,
+                                                 endpointReference.getReference().getCallbackService().getEndpoints());
+            } 
+        } else if (endpointReference.getStatus() == EndpointReference.WIRED_TARGET_FOUND_READY_FOR_MATCHING ){
+            // The endpoint reference is already resolved to either
+            // a service endpoint but no binding was specified in the 
+            // target URL and/or the policies have yet to be matched.         
+            
+            problem = selectForwardEndpoint(endpointReference,
+                                            endpointReference.getTargetEndpoint().getService().getEndpoints());
+
+            if (problem == null && hasCallback(endpointReference)){
+                problem = selectCallbackEndpoint(endpointReference,
+                                                 endpointReference.getReference().getCallbackService().getEndpoints());
+            } 
+            
+        } else if (endpointReference.getStatus() == EndpointReference.WIRED_TARGET_NOT_FOUND ||
+                   endpointReference.getStatus() == EndpointReference.NOT_CONFIGURED){
+            // The service is in a remote composite somewhere else in the domain
+
+            // find the service in the endpoint registry
+            List<Endpoint> endpoints = endpointRegistry.findEndpoint(endpointReference);
+
+            if (endpoints.size() == 0) {
+                problem = monitor.createProblem(this.getClass().getName(), 
+                                                "endpoint-validation-messages", 
+                                                Problem.Severity.ERROR, 
+                                                this, 
+                                                "NoEndpointsFound", 
+                                                endpointReference.toString());
+            }
+
+            problem = selectForwardEndpoint(endpointReference,
+                                            endpoints);
+
+            if (problem == null && hasCallback(endpointReference)){
+                problem = selectCallbackEndpoint(endpointReference,
+                                                 endpointReference.getReference().getCallbackService().getEndpoints());
+            }             
+        } 
+        
+        if (problem != null){
+            return problem;
+        }
+
+        if (endpointReference.getStatus() != EndpointReference.WIRED_TARGET_FOUND_AND_MATCHED &&
+            endpointReference.getStatus() != EndpointReference.RESOLVED_BINDING){
+            problem = monitor.createProblem(this.getClass().getName(), 
+                                            "endpoint-validation-messages", 
+                                            Problem.Severity.ERROR, 
+                                            this, 
+                                            "EndpointReferenceCantBeMatched", 
+                                            endpointReference.toString());
+        }
+        
+        return problem;
+    }
+
+    private Problem selectForwardEndpoint(EndpointReference endpointReference, List<Endpoint> endpoints) {    
+             
+        Endpoint matchedEndpoint = null;
+        
+        if (endpointReference.getReference().getName().startsWith("$self$.")){
+            // just select the first one and don't do any policy matching
+            matchedEndpoint = endpoints.get(0);
+        } else {
+            // find the first endpoint that matches this endpoint reference
+            for (Endpoint endpoint : endpoints){
+                if (haveMatchingPolicy(endpointReference, endpoint)){
+                    matchedEndpoint = endpoint;
+                }
+            }
+        }
+        
+        if (matchedEndpoint == null){
+            return null;
+        }
+        
+        endpointReference.setTargetEndpoint(matchedEndpoint);
+        endpointReference.setBinding(endpointReference.getTargetEndpoint().getBinding());
+        endpointReference.setStatus(EndpointReference.WIRED_TARGET_FOUND_AND_MATCHED);
+        endpointReference.setUnresolved(false);
+        
+        return null;
+    }
+    
+    private boolean hasCallback(EndpointReference endpointReference){
+        if (endpointReference.getReference().getInterfaceContract() == null ||
+            endpointReference.getReference().getInterfaceContract().getCallbackInterface() == null ||
+            endpointReference.getReference().getName().startsWith("$self$.")){
+            return false;
+        } else {
+            return true;
+        }
+    }
+
+    private Problem selectCallbackEndpoint(EndpointReference endpointReference, List<Endpoint> endpoints) {
+
+        Problem problem = null;
+        
+        // find the first callback endpoint that matches a callback endpoint reference
+        // at the service
+        Endpoint matchedEndpoint = null;
+        match:
+        for ( EndpointReference callbackEndpointReference : endpointReference.getTargetEndpoint().getCallbackEndpointReferences()){
+            for (Endpoint endpoint : endpoints){
+                if (haveMatchingPolicy(callbackEndpointReference, endpoint)){
+                    matchedEndpoint = endpoint;
+                    break match;
+                }
+            }
+        }
+        
+        if (matchedEndpoint == null){
+            return null;
+        }
+        
+        endpointReference.setCallbackEndpoint(matchedEndpoint);
+        
+        return problem;
+    }
+
+    // FIXME: [rfeng] This implementation is wrong. It is the responsibility of the policy language
+    // to compare the reference and service side setting to determine if they are compatible. Some of
+    // policies apply to the reference side only, some of the policies apply to the service side only, 
+    // while others apply to both sides. Even for those policies that apply to both side, they can be 
+    // independent or related. 
+    private boolean haveMatchingPolicy(EndpointReference endpointReference, Endpoint endpoint){
+        
+        /*
+        // if no policy sets or intents are present then they match
+        if ((endpointReference.getRequiredIntents().size() == 0) &&
+            (endpoint.getRequiredIntents().size() == 0) &&
+            (endpointReference.getPolicySets().size() == 0) &&
+            (endpoint.getPolicySets().size() == 0)) {
+            return true;
+        }
+        
+        // if there are different numbers of intents 
+        // then they don't match
+        if (endpointReference.getRequiredIntents().size() !=
+            endpoint.getRequiredIntents().size()) {
+            return false;
+        }
+        
+        // if there are different numbers of policy sets 
+        // then they don't match
+        if (endpointReference.getPolicySets().size() !=
+            endpoint.getPolicySets().size()) {
+            return false;
+        }        
+        
+        // check intents for compatibility
+        for(Intent intentEPR : endpointReference.getRequiredIntents()){
+            boolean matched = false;
+            for (Intent intentEP : endpoint.getRequiredIntents()){ 
+                if (intentEPR.getName().equals(intentEP.getName())){
+                    matched = true;
+                    break;
+                }
+            }
+            if (matched == false){
+                return false;
+            }
+        }
+        
+        // check policy sets for compatibility. The list of policy sets
+        // may be a subset of the list of intents as some of the intents 
+        // may be directly provided. We can't just rely on intent compatibility
+        // as different policy sets might have been attached at each end to 
+        // satisfy the listed intents
+        
+        // if all of the policy sets on the endpoint reference match a 
+        // policy set on the endpoint then they match
+        for(PolicySet policySetEPR : endpointReference.getPolicySets()){
+            boolean matched = false;
+            for (PolicySet policySetEP : endpoint.getPolicySets()){ 
+                // find if there is a policy set with the same name
+                if (policySetEPR.getName().equals(policySetEP.getName())){
+                    matched = true;
+                    break;
+                }
+                // find if the policies inside the policy set match the 
+                // policies inside a policy set on the endpoint
+                
+                // TODO - need a policy specific matcher to do this
+                //        so need a new extension point
+                
+            }
+            
+            if (matched == false){
+                return false;
+            }
+        }
+        */
+        
+        return true;
+    }
+
+    public boolean isOutOfDate(EndpointReference endpointReference) {
+        Endpoint te = endpointReference.getTargetEndpoint();
+        if (!te.isUnresolved() && te.getURI()!= null) {
+            List<Endpoint> endpoints = endpointRegistry.findEndpoint(endpointReference);
+            return ! endpoints.contains(endpointReference.getTargetEndpoint());
+        }
+        return false;
+    }
+
+}
diff --git a/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/EndpointRegistryImpl.java b/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/EndpointRegistryImpl.java
new file mode 100644
index 0000000000..1317c3fc8f
--- /dev/null
+++ b/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/EndpointRegistryImpl.java
@@ -0,0 +1,256 @@
+/*
+ * 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.tuscany.sca.core.assembly.impl;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.CopyOnWriteArrayList;
+import java.util.logging.Logger;
+
+import org.apache.tuscany.sca.assembly.Endpoint;
+import org.apache.tuscany.sca.assembly.EndpointReference;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.core.LifeCycleListener;
+import org.apache.tuscany.sca.runtime.EndpointListener;
+import org.apache.tuscany.sca.runtime.EndpointRegistry;
+
+/**
+ * A EndpointRegistry implementation that sees registrations from the same JVM
+ */
+public class EndpointRegistryImpl implements EndpointRegistry, LifeCycleListener {
+    private final Logger logger = Logger.getLogger(EndpointRegistryImpl.class.getName());
+
+    private MappedList<EndpointRegistry, Endpoint> endpoints = new MappedList<EndpointRegistry, Endpoint>();
+    private MappedList<EndpointRegistry, EndpointReference> endpointreferences =
+        new MappedList<EndpointRegistry, EndpointReference>();
+
+    private List<EndpointListener> listeners = new CopyOnWriteArrayList<EndpointListener>();
+
+    public EndpointRegistryImpl(ExtensionPointRegistry extensionPoints) {
+    }
+
+    public void addEndpoint(Endpoint endpoint) {
+        endpoints.putValue(this, endpoint);
+        for (EndpointListener listener : listeners) {
+            listener.endpointAdded(endpoint);
+        }
+        logger.info("Add endpoint - " + endpoint.toString());
+    }
+
+    public void addEndpointReference(EndpointReference endpointReference) {
+        endpointreferences.putValue(this, endpointReference);
+        logger.fine("Add endpoint reference - " + endpointReference.toString());
+    }
+
+    /**
+     * Parse the component/service/binding URI into an array of parts (componentURI, serviceName, bindingName)
+     * @param uri
+     * @return
+     */
+    private String[] parse(String uri) {
+        String[] names = new String[3];
+        int index = uri.lastIndexOf('#');
+        if (index == -1) {
+            names[0] = uri;
+        } else {
+            names[0] = uri.substring(0, index);
+            String str = uri.substring(index + 1);
+            if (str.startsWith("service-binding(") && str.endsWith(")")) {
+                str = str.substring("service-binding(".length(), str.length() - 1);
+                String[] parts = str.split("/");
+                if (parts.length != 2) {
+                    throw new IllegalArgumentException("Invalid service-binding URI: " + uri);
+                }
+                names[1] = parts[0];
+                names[2] = parts[1];
+            } else if (str.startsWith("service(") && str.endsWith(")")) {
+                str = str.substring("service(".length(), str.length() - 1);
+                names[1] = str;
+            } else {
+                throw new IllegalArgumentException("Invalid component/service/binding URI: " + uri);
+            }
+        }
+        return names;
+    }
+
+    private boolean matches(String target, String uri) {
+        String[] parts1 = parse(target);
+        String[] parts2 = parse(uri);
+        for (int i = 0; i < parts1.length; i++) {
+            if (parts1[i] == null || parts1[i].equals(parts2[i])) {
+                continue;
+            } else {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    public List<Endpoint> findEndpoint(EndpointReference endpointReference) {
+        List<Endpoint> foundEndpoints = new ArrayList<Endpoint>();
+
+        logger.fine("Find endpoint for reference - " + endpointReference.toString());
+
+        if (endpointReference.getReference() != null) {
+            Endpoint targetEndpoint = endpointReference.getTargetEndpoint();
+            for (List<Endpoint> collection : endpoints.values()) {
+                for (Endpoint endpoint : collection) {
+                    // TODO: implement more complete matching
+                    if (matches(targetEndpoint.getURI(), endpoint.getURI())) {
+                        foundEndpoints.add(endpoint);
+                        logger.fine("Found endpoint with matching service  - " + endpoint);
+                    }
+                    // else the service name doesn't match
+                }
+            }
+        }
+
+        return foundEndpoints;
+    }
+
+    public List<EndpointReference> findEndpointReference(Endpoint endpoint) {
+        return null;
+    }
+
+    public void removeEndpoint(Endpoint endpoint) {
+        endpoints.removeValue(this, endpoint);
+        for (EndpointListener listener : listeners) {
+            listener.endpointRemoved(endpoint);
+        }
+        logger.info("Remove endpoint - " + endpoint.toString());
+    }
+
+    public void removeEndpointReference(EndpointReference endpointReference) {
+        endpointreferences.removeValue(this, endpointReference);
+        logger.fine("Remove endpoint reference - " + endpointReference.toString());
+    }
+
+    public List<EndpointReference> getEndpointRefereneces() {
+        return endpointreferences.getAllValues();
+    }
+
+    public List<Endpoint> getEndpoints() {
+        return endpoints.getAllValues();
+    }
+
+    public void addListener(EndpointListener listener) {
+        listeners.add(listener);
+    }
+
+    public List<EndpointListener> getListeners() {
+        return listeners;
+    }
+
+    public void removeListener(EndpointListener listener) {
+        listeners.remove(listener);
+    }
+
+    public Endpoint getEndpoint(String uri) {
+        for (List<Endpoint> collection : endpoints.values()) {
+            for (Endpoint ep : collection) {
+                String epURI =
+                    ep.getComponent().getURI() + "#" + ep.getService().getName() + "/" + ep.getBinding().getName();
+                if (epURI.equals(uri)) {
+                    return ep;
+                }
+                if (ep.getBinding().getName() == null || ep.getBinding().getName().equals(ep.getService().getName())) {
+                    epURI = ep.getComponent().getURI() + "#" + ep.getService().getName();
+                    if (epURI.equals(uri)) {
+                        return ep;
+                    }
+                }
+            }
+        }
+        return null;
+
+    }
+
+    public void updateEndpoint(String uri, Endpoint endpoint) {
+        Endpoint oldEndpoint = getEndpoint(uri);
+        if (oldEndpoint == null) {
+            throw new IllegalArgumentException("Endpoint is not found: " + uri);
+        }
+        endpoints.removeValue(this, oldEndpoint);
+        endpoints.putValue(this, endpoint);
+        for (EndpointListener listener : listeners) {
+            listener.endpointUpdated(oldEndpoint, endpoint);
+        }
+    }
+
+    public void start() {
+    }
+
+    public void stop() {
+        List<Endpoint> localEndpoints = endpoints.remove(this);
+        if (localEndpoints != null) {
+            for (Endpoint endpoint : localEndpoints) {
+                removeEndpoint(endpoint);
+            }
+        }
+        List<EndpointReference> localEndpointReferences = endpointreferences.remove(this);
+        if (localEndpointReferences != null) {
+            for (EndpointReference endpointReference : localEndpointReferences) {
+                removeEndpointReference(endpointReference);
+            }
+        }
+        listeners.clear();
+    }
+
+    private static class MappedList<K, V> extends ConcurrentHashMap<K, List<V>> {
+        private static final long serialVersionUID = -8926174610229029369L;
+
+        public boolean putValue(K key, V value) {
+            List<V> collection = get(key);
+            if (collection == null) {
+                collection = new ArrayList<V>();
+                put(key, collection);
+            }
+            return collection.add(value);
+        }
+
+        public boolean putValue(K key, List<? extends V> value) {
+            List<V> collection = get(key);
+            if (collection == null) {
+                collection = new ArrayList<V>();
+                put(key, collection);
+            }
+            return collection.addAll(value);
+        }
+
+        public boolean removeValue(K key, V value) {
+            List<V> collection = get(key);
+            if (collection == null) {
+                return false;
+            }
+            return collection.remove(value);
+        }
+
+        public List<V> getAllValues() {
+            List<V> values = new ArrayList<V>();
+            for (List<V> collection : values()) {
+                values.addAll(collection);
+            }
+            return values;
+        }
+
+    }
+
+}
diff --git a/java/sca/modules/core/src/main/resources/META-INF/services/org.apache.tuscany.sca.assembly.builder.EndpointReferenceBuilder b/java/sca/modules/core/src/main/resources/META-INF/services/org.apache.tuscany.sca.assembly.builder.EndpointReferenceBuilder
new file mode 100644
index 0000000000..8f721db536
--- /dev/null
+++ b/java/sca/modules/core/src/main/resources/META-INF/services/org.apache.tuscany.sca.assembly.builder.EndpointReferenceBuilder
@@ -0,0 +1,18 @@
+# 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. 

+

+org.apache.tuscany.sca.core.assembly.impl.EndpointReferenceBuilderImpl
\ No newline at end of file
diff --git a/java/sca/modules/core/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.EndpointRegistry b/java/sca/modules/core/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.EndpointRegistry
new file mode 100644
index 0000000000..9a52ac0355
--- /dev/null
+++ b/java/sca/modules/core/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.EndpointRegistry
@@ -0,0 +1,18 @@
+# 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.

+

+org.apache.tuscany.sca.core.assembly.impl.EndpointRegistryImpl;ranking=100,scheme=vm
\ No newline at end of file
diff --git a/java/sca/modules/core/src/main/resources/endpoint-validation-messages.properties b/java/sca/modules/core/src/main/resources/endpoint-validation-messages.properties
new file mode 100644
index 0000000000..7be0f2b4a2
--- /dev/null
+++ b/java/sca/modules/core/src/main/resources/endpoint-validation-messages.properties
@@ -0,0 +1,22 @@
+#
+#
+#    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.
+#
+#
+NoEndpointsFound = No endpoints found in the domain that match the reference {0} 
+EndpointReferenceCantBeMatched = = Unable to match the endpoint reference {0} with the policy of the service to which it refers.