src/org/apache/kandula/utility/EndpointReferenceFactory.java

/*
 * Copyright 2004 The Apache Software Foundation.
 * 
 * Licensed 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.kandula.utility;

import java.io.IOException;
import java.io.InputStream;
import java.net.InetAddress;
import java.util.Properties;

import javax.xml.namespace.QName;

import org.apache.axis2.addressing.AnyContentType;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.kandula.wsat.completion.CompletionInitiatorServiceListener;

/**
 * @author Dasarath Weeratunge
 * @author <a href="mailto:thilina@apache.org"> Thilina Gunarathne </a>
 */

public class EndpointReferenceFactory {
    static final String PROPERTY_FILE = "endpoints.conf";

    static final String PROTOCOL_PROPERTY = "protocol";

    static final String HOST_PROPERTY = "host";

    static final String PORT_PROPERTY = "port";

    private static EndpointReferenceFactory instance = null;

    Properties properties = null;

    String location = null;

    private EndpointReferenceFactory() {
        InputStream in = getClass().getClassLoader().getResourceAsStream(
                PROPERTY_FILE);
        properties = new Properties();
        try {
            properties.load(in);
            in.close();
            String host = properties.getProperty(HOST_PROPERTY);
            if (host == null)
                host = InetAddress.getLocalHost().getHostAddress();
            location = properties.getProperty(PROTOCOL_PROPERTY) + "://" + host
                    + ":" + properties.getProperty(PORT_PROPERTY);
        } catch (Exception e) {
            if (e instanceof RuntimeException)
                throw (RuntimeException) e;
            else
                throw new RuntimeException(e);
        }
    }
    
    public static EndpointReferenceFactory getInstance() {
        if (instance == null)
            instance = new EndpointReferenceFactory();
        return instance;
    }

    public EndpointReference getRegistrationEndpoint(String id) {
        //TODO set this somehow reading the conf file
        EndpointReference epr = new EndpointReference(
                "http://localhost:8082/axis/services/RegistrationCoordinator");
        AnyContentType refProperties = new AnyContentType();
        refProperties.addReferenceValue(
                new QName("http://ws.apache.org/Kandula", "id"), id);
        epr.setReferenceProperties(refProperties);
        return epr;
    }

    public EndpointReference getCompletionParticipantEndpoint(String id) throws IOException {
        CompletionInitiatorServiceListener serviceListener = CompletionInitiatorServiceListener.getInstance();
        EndpointReference epr = serviceListener.getEpr();
        AnyContentType refProperties = new AnyContentType();
        refProperties.addReferenceValue(
                new QName("http://ws.apache.org/Kandula", "id"), id);
        epr.setReferenceProperties(refProperties);
        return epr;
    }

    public EndpointReference getCompletionEndpoint(String id) {
        //TODO set this somehow reading the conf file
        EndpointReference epr = new EndpointReference(
                "http://localhost:8082/axis/services/RegistrationCoordinator");
        AnyContentType refProperties = new AnyContentType();
        refProperties.addReferenceValue(
                new QName("http://ws.apache.org/Kandula", "id"), id);
        epr.setReferenceProperties(refProperties);
        return epr;
    }

    public EndpointReference get2PCEndpoint(String id) {
        //TODO set this somehow reading the conf file
        EndpointReference epr = new EndpointReference(
                "http://localhost:8082/axis/services/RegistrationCoordinator");
        AnyContentType refProperties = new AnyContentType();
        refProperties.addReferenceValue(
                new QName("http://ws.apache.org/Kandula", "id"), id);
        epr.setReferenceProperties(refProperties);
        return epr;
    }
    //	public EndpointReferenceTypeImpl
    // getEndpointReference(PortReferenceTypeImpl portType,
    // ReferencePropertiesType referenceProperties) {
    //		try {
    //			EndpointReferenceTypeImpl endpointReference = new
    // EndpointReferenceTypeImpl(SchemaTypeImpl.);
    //			endpointReference.setPortTypesetPortType(portType);
    //			endpointReference.setProperties(referenceProperties);
    //			return endpointReference;
    //		}
    //		catch (Exception e) {
    //			if (e instanceof RuntimeException)
    //				throw (RuntimeException)e;
    //			else
    //				throw new RuntimeException(e);
    //		}
    //	}
}