[SAGA-RG] saga-ogf SVN commit 1328: /trunk/documents/saga-core-binding-java/implementation/VU/src/org/ogf/saga/stream/

ceriel at cs.vu.nl ceriel at cs.vu.nl
Tue Jul 12 10:02:22 CDT 2011


User: svn_ceriel
Date: 2011/07/12 10:02 AM

Modified:
 /trunk/documents/saga-core-binding-java/implementation/VU/src/org/ogf/saga/stream/
  StreamFactory.java

Log:
 Missed some URLFactory method invocations.

File Changes:

Directory: /trunk/documents/saga-core-binding-java/implementation/VU/src/org/ogf/saga/stream/
=============================================================================================

File [modified]: StreamFactory.java
Delta lines: +15 -3
===================================================================
--- trunk/documents/saga-core-binding-java/implementation/VU/src/org/ogf/saga/stream/StreamFactory.java	2011-07-11 08:49:34 UTC (rev 1327)
+++ trunk/documents/saga-core-binding-java/implementation/VU/src/org/ogf/saga/stream/StreamFactory.java	2011-07-12 15:02:15 UTC (rev 1328)
@@ -39,6 +39,18 @@
         }
         return url;
     }
+    
+    private static URL createDefaultURL(String sagaFactoryClassname) {
+        URL url;
+        try {
+            url = URLFactory.createURL(sagaFactoryClassname, DEFAULT_SERVER_URL);
+        } catch (Throwable e) {
+            // Cannot happen.
+            throw new Error("Implementation error", e);
+                        
+        }
+        return url;
+    }
 
     /**
      * Creates a Stream. To be provided by the implementation.
@@ -488,7 +500,7 @@
             BadParameterException, AuthenticationFailedException,
             AuthorizationFailedException, PermissionDeniedException,
             TimeoutException, NoSuccessException {
-        return createStreamServer(sagaFactoryClassname, session, createDefaultURL());
+        return createStreamServer(sagaFactoryClassname, session, createDefaultURL(sagaFactoryClassname));
     }
 
 
@@ -858,7 +870,7 @@
     public static Task<StreamFactory, StreamServer> createStreamServer(
             String sagaFactoryClassname, TaskMode mode, Session session) throws NotImplementedException,
             NoSuccessException {
-        return createStreamServer(sagaFactoryClassname, mode, session, createDefaultURL());
+        return createStreamServer(sagaFactoryClassname, mode, session, createDefaultURL(sagaFactoryClassname));
     }
 
     /**
@@ -941,6 +953,6 @@
      */
     public static Task<StreamFactory, StreamServer> createStreamServer(
             String sagaFactoryClassname, TaskMode mode) throws NotImplementedException, NoSuccessException {
-        return createStreamServer(sagaFactoryClassname, mode, createDefaultURL());
+        return createStreamServer(sagaFactoryClassname, mode, createDefaultURL(sagaFactoryClassname));
     }
 }



More information about the saga-rg mailing list