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.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:8081/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/CompletionCoordinator");
        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:8081/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);
    //		}
    //	}
}