ws-fx-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From thil...@apache.org
Subject svn commit: r330669 - /webservices/kandula/trunk/java/src/org/apache/kandula/utility/EndpointReferenceFactory.java
Date Fri, 04 Nov 2005 00:30:53 GMT
Author: thilina
Date: Thu Nov  3 16:30:42 2005
New Revision: 330669

URL: http://svn.apache.org/viewcvs?rev=330669&view=rev
Log:
Added Configurations for the user to set the desired ports & hosts

Modified:
    webservices/kandula/trunk/java/src/org/apache/kandula/utility/EndpointReferenceFactory.java

Modified: webservices/kandula/trunk/java/src/org/apache/kandula/utility/EndpointReferenceFactory.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/utility/EndpointReferenceFactory.java?rev=330669&r1=330668&r2=330669&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/utility/EndpointReferenceFactory.java
(original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/utility/EndpointReferenceFactory.java
Thu Nov  3 16:30:42 2005
@@ -17,6 +17,8 @@
 package org.apache.kandula.utility;
 
 import java.io.IOException;
+import java.io.InputStream;
+import java.net.InetAddress;
 import java.util.Properties;
 
 import org.apache.axis2.addressing.AnyContentType;
@@ -30,105 +32,125 @@
  */
 
 public class EndpointReferenceFactory {
-    static final String PROPERTY_FILE = "endpoints.conf";
+	static final String PROPERTY_FILE = "endpoints.conf";
 
-    static final String PROTOCOL_PROPERTY = "protocol";
+	//  static final String PROTOCOL_PROPERTY = "protocol";
 
-    static final String HOST_PROPERTY = "host";
+	static final String HOST_PROPERTY = "host";
 
-    static final String PORT_PROPERTY = "port";
+	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 refParameters = new AnyContentType();
-        refParameters.addReferenceValue(Constants.TRANSACTION_ID_PARAMETER, id);
-        epr.setReferenceParameters(refParameters);
-        return epr;
-    }
-
-    public EndpointReference getCompletionParticipantEndpoint(String id)
-            throws IOException {
-        CompletionInitiatorServiceListener serviceListener = CompletionInitiatorServiceListener
-                .getInstance();
-        EndpointReference epr = serviceListener.getEpr();
-        AnyContentType refParameters = new AnyContentType();
-        refParameters.addReferenceValue(Constants.REQUESTER_ID_PARAMETER, id);
-        epr.setReferenceParameters(refParameters);
-        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 refParameters = new AnyContentType();
-        refParameters.addReferenceValue(Constants.TRANSACTION_ID_PARAMETER, id);
-        epr.setReferenceParameters(refParameters);
-        return epr;
-    }
-
-    public EndpointReference get2PCCoordinatorEndpoint(String activityId, String enlistmentId)
{
-        //TODO set this somehow reading the conf file
-        EndpointReference epr = new EndpointReference(
-                "http://localhost:8082/axis/services/AtomicTransactionCoordinator");
-        AnyContentType refParameters = new AnyContentType();
-        refParameters.addReferenceValue(Constants.TRANSACTION_ID_PARAMETER, activityId);
-        refParameters.addReferenceValue(Constants.ENLISTMENT_ID_PARAMETER, enlistmentId);
-        epr.setReferenceParameters(refParameters);
-        return epr;
-    }
-    public EndpointReference get2PCParticipantEndpoint(String id) {
-        //TODO set this somehow reading the conf file
-        EndpointReference epr = new EndpointReference(
-                "http://localhost:8082/axis/services/AtomicTransactionParticipant");
-        AnyContentType refParameters = new AnyContentType();
-        refParameters.addReferenceValue(Constants.REQUESTER_ID_PARAMETER, id);
-        epr.setReferenceParameters(refParameters);
-        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);
-    //		}
-    //	}
+	static final String TCPMON_ENABLE = "tcpmon_enable";
+	
+	static final String REPO = "PARTICIPANT_REPOSITORY";
+
+	private static EndpointReferenceFactory instance = null;
+
+	Properties properties = null;
+
+	String location = null;
+	
+	String participantRepository =null;
+
+	private EndpointReferenceFactory() {
+
+		String port = null;
+
+		String host = null;
+		InputStream in = getClass().getClassLoader().getResourceAsStream(
+				PROPERTY_FILE);
+		properties = new Properties();
+		try {
+			properties.load(in);
+			in.close();
+			host = properties.getProperty(HOST_PROPERTY);
+			port = properties.getProperty(PORT_PROPERTY);
+			participantRepository = properties.getProperty(REPO);
+			if (participantRepository ==null)
+			{
+				participantRepository = ".";
+			}
+			
+			if (port == null) {
+				port = "8080";
+			}
+			if (host == null) {
+				host = InetAddress.getLocalHost().getHostAddress();
+			}
+			
+
+			location = "http://" + host + ":"+port;
+		} 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) {
+
+		EndpointReference epr = new EndpointReference(location
+				+ "/axis2/services/RegistrationCoordinator");
+		AnyContentType refParameters = new AnyContentType();
+		refParameters.addReferenceValue(Constants.TRANSACTION_ID_PARAMETER, id);
+		epr.setReferenceParameters(refParameters);
+		return epr;
+	}
+
+	public EndpointReference getCompletionParticipantEndpoint(String id)
+			throws IOException {
+		CompletionInitiatorServiceListener serviceListener = CompletionInitiatorServiceListener
+				.getInstance();
+		EndpointReference epr = serviceListener.getEpr();
+		AnyContentType refParameters = new AnyContentType();
+		refParameters.addReferenceValue(Constants.REQUESTER_ID_PARAMETER, id);
+		epr.setReferenceParameters(refParameters);
+		return epr;
+	}
+
+	public EndpointReference getCompletionEndpoint(String id) {
+
+		EndpointReference epr = new EndpointReference(location
+				+ "/axis2/services/CompletionCoordinator");
+		AnyContentType refParameters = new AnyContentType();
+		refParameters.addReferenceValue(Constants.TRANSACTION_ID_PARAMETER, id);
+		epr.setReferenceParameters(refParameters);
+		return epr;
+	}
+
+	public EndpointReference get2PCCoordinatorEndpoint(String activityId,
+			String enlistmentId) {
+
+		EndpointReference epr = new EndpointReference(location
+				+ "/axis2/services/AtomicTransactionCoordinator");
+		AnyContentType refParameters = new AnyContentType();
+		refParameters.addReferenceValue(Constants.TRANSACTION_ID_PARAMETER,
+				activityId);
+		refParameters.addReferenceValue(Constants.ENLISTMENT_ID_PARAMETER,
+				enlistmentId);
+		epr.setReferenceParameters(refParameters);
+		return epr;
+	}
+
+	public EndpointReference get2PCParticipantEndpoint(String id) {
+
+		EndpointReference epr = new EndpointReference(location
+				+ "/axis2/services/AtomicTransactionParticipant");
+		AnyContentType refParameters = new AnyContentType();
+		refParameters.addReferenceValue(Constants.REQUESTER_ID_PARAMETER, id);
+		epr.setReferenceParameters(refParameters);
+		return epr;
+	}
+	public String getPariticipantRepository()
+	{
+		return participantRepository;
+	}
 }



---------------------------------------------------------------------
To unsubscribe, e-mail: kandula-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: kandula-dev-help@ws.apache.org


Mime
View raw message