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));
}
}
