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