[jboss-svn-commits] JBL Code SVN: r31363 - in labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry: server and 1 other directory.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Tue Feb 2 11:37:13 EST 2010
Author: kevin.conner at jboss.com
Date: 2010-02-02 11:37:12 -0500 (Tue, 02 Feb 2010)
New Revision: 31363
Modified:
labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/client/ESBInVMTransport.java
labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/client/JuddiInVMTransport.java
labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/client/JuddiRMITransport.java
labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/server/ESBInVMServerTransport.java
labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/server/JuddiInVMServerTransport.java
Log:
Add support for managerName in juddi transports: JBESB-3163
Modified: labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/client/ESBInVMTransport.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/client/ESBInVMTransport.java 2010-02-02 16:08:33 UTC (rev 31362)
+++ labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/client/ESBInVMTransport.java 2010-02-02 16:37:12 UTC (rev 31363)
@@ -39,71 +39,78 @@
{
/**
* Return an API service for the specified node name and endpoint URL.
+ * @param managerName The manager name.
* @param nodeName The node name.
* @param endpointURL The endpoint URL
* @return The API service implementation.
* @throws TransportException For exceptions obtaining the service implementation.
*/
- public JUDDIApiPortType getJUDDIApiService(final String nodeName, final String endpointURL)
+ public JUDDIApiPortType getJUDDIApiService(final String managerName, final String nodeName, final String endpointURL)
throws TransportException ;
/**
* Return a Custody Transfer service for the specified node name and endpoint URL.
+ * @param managerName The manager name.
* @param nodeName The node name.
* @param endpointURL The endpoint URL
* @return The Custody Transfer service implementation.
* @throws TransportException For exceptions obtaining the service implementation.
*/
- public UDDICustodyTransferPortType getUDDICustodyTransferService(final String nodeName, final String endpointURL)
+ public UDDICustodyTransferPortType getUDDICustodyTransferService(final String managerName, final String nodeName, final String endpointURL)
throws TransportException ;
/**
* Return an Inquiry service for the specified node name and endpoint URL.
+ * @param managerName The manager name.
* @param nodeName The node name.
* @param endpointURL The endpoint URL
* @return The Inquiry service implementation.
* @throws TransportException For exceptions obtaining the service implementation.
*/
- public UDDIInquiryPortType getUDDIInquiryService(final String nodeName, final String endpointURL)
+ public UDDIInquiryPortType getUDDIInquiryService(final String managerName, final String nodeName, final String endpointURL)
throws TransportException ;
/**
* Return a Publish service for the specified node name and endpoint URL.
+ * @param managerName The manager name.
* @param nodeName The node name.
* @param endpointURL The endpoint URL
* @return The Publish service implementation.
* @throws TransportException For exceptions obtaining the service implementation.
*/
- public UDDIPublicationPortType getUDDIPublishService(final String nodeName, final String endpointURL)
+ public UDDIPublicationPortType getUDDIPublishService(final String managerName, final String nodeName, final String endpointURL)
throws TransportException ;
/**
* Return a Security service for the specified node name and endpoint URL.
+ * @param managerName The manager name.
* @param nodeName The node name.
* @param endpointURL The endpoint URL
* @return The Security service implementation.
* @throws TransportException For exceptions obtaining the service implementation.
*/
- public UDDISecurityPortType getUDDISecurityService(final String nodeName, final String endpointURL)
+ public UDDISecurityPortType getUDDISecurityService(final String managerName, final String nodeName, final String endpointURL)
throws TransportException ;
/**
* Return a Subscription Listener service for the specified node name and endpoint URL.
+ * @param managerName The manager name.
* @param nodeName The node name.
* @param endpointURL The endpoint URL
* @return The Subscription Listener service implementation.
* @throws TransportException For exceptions obtaining the service implementation.
*/
- public UDDISubscriptionListenerPortType getUDDISubscriptionListenerService(final String nodeName, final String endpointURL)
+ public UDDISubscriptionListenerPortType getUDDISubscriptionListenerService(final String managerName, final String nodeName, final String endpointURL)
throws TransportException ;
/**
* Return a Subscription service for the specified node name and endpoint URL.
+ * @param managerName The manager name.
* @param nodeName The node name.
* @param endpointURL The endpoint URL
* @return The Subscription service implementation.
* @throws TransportException For exceptions obtaining the service implementation.
*/
- public UDDISubscriptionPortType getUDDISubscriptionService(final String nodeName, final String endpointURL)
+ public UDDISubscriptionPortType getUDDISubscriptionService(final String managerName, final String nodeName, final String endpointURL)
throws TransportException ;
}
Modified: labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/client/JuddiInVMTransport.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/client/JuddiInVMTransport.java 2010-02-02 16:08:33 UTC (rev 31362)
+++ labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/client/JuddiInVMTransport.java 2010-02-02 16:37:12 UTC (rev 31363)
@@ -45,6 +45,10 @@
private static ESBInVMTransport implementation ;
/**
+ * The manager name of the current transport.
+ */
+ private final String managerName ;
+ /**
* The node name of the current transport.
*/
private final String nodeName ;
@@ -63,6 +67,17 @@
*/
public JuddiInVMTransport(final String nodeName)
{
+ this(null, nodeName) ;
+ }
+
+ /**
+ * Construct a transport for the specified node.
+ * @param managerName The manager name.
+ * @param nodeName The node name.
+ */
+ public JuddiInVMTransport(final String managerName, final String nodeName)
+ {
+ this.managerName = managerName ;
this.nodeName = (nodeName != null ? nodeName : Transport.DEFAULT_NODE_NAME) ;
}
@@ -70,49 +85,49 @@
public JUDDIApiPortType getJUDDIApiService(final String endpointURL)
throws TransportException
{
- return getImplementation().getJUDDIApiService(nodeName, endpointURL) ;
+ return getImplementation().getJUDDIApiService(managerName, nodeName, endpointURL) ;
}
@Override
public UDDICustodyTransferPortType getUDDICustodyTransferService(final String endpointURL)
throws TransportException
{
- return getImplementation().getUDDICustodyTransferService(nodeName, endpointURL) ;
+ return getImplementation().getUDDICustodyTransferService(managerName, nodeName, endpointURL) ;
}
@Override
public UDDIInquiryPortType getUDDIInquiryService(final String endpointURL)
throws TransportException
{
- return getImplementation().getUDDIInquiryService(nodeName, endpointURL) ;
+ return getImplementation().getUDDIInquiryService(managerName, nodeName, endpointURL) ;
}
@Override
public UDDIPublicationPortType getUDDIPublishService(final String endpointURL)
throws TransportException
{
- return getImplementation().getUDDIPublishService(nodeName, endpointURL) ;
+ return getImplementation().getUDDIPublishService(managerName, nodeName, endpointURL) ;
}
@Override
public UDDISecurityPortType getUDDISecurityService(final String endpointURL)
throws TransportException
{
- return getImplementation().getUDDISecurityService(nodeName, endpointURL) ;
+ return getImplementation().getUDDISecurityService(managerName, nodeName, endpointURL) ;
}
@Override
public UDDISubscriptionListenerPortType getUDDISubscriptionListenerService(final String endpointURL)
throws TransportException
{
- return getImplementation().getUDDISubscriptionListenerService(nodeName, endpointURL) ;
+ return getImplementation().getUDDISubscriptionListenerService(managerName, nodeName, endpointURL) ;
}
@Override
public UDDISubscriptionPortType getUDDISubscriptionService(final String endpointURL)
throws TransportException
{
- return getImplementation().getUDDISubscriptionService(nodeName, endpointURL) ;
+ return getImplementation().getUDDISubscriptionService(managerName, nodeName, endpointURL) ;
}
/**
Modified: labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/client/JuddiRMITransport.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/client/JuddiRMITransport.java 2010-02-02 16:08:33 UTC (rev 31362)
+++ labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/client/JuddiRMITransport.java 2010-02-02 16:37:12 UTC (rev 31363)
@@ -52,6 +52,10 @@
*/
private static final Logger logger = Logger.getLogger(JuddiRMITransport.class) ;
/**
+ * The manager name to use for this transport.
+ */
+ private final String managerName ;
+ /**
* The node name to use for this transport.
*/
private final String nodeName ;
@@ -95,7 +99,7 @@
public JuddiRMITransport()
throws ConfigurationException
{
- this(Transport.DEFAULT_NODE_NAME) ;
+ this(null) ;
}
/**
@@ -105,10 +109,22 @@
public JuddiRMITransport(final String nodeName)
throws ConfigurationException
{
- this.nodeName = nodeName ;
- jndiEnv = createEnvironment(nodeName) ;
+ this(null, nodeName) ;
}
+ /**
+ * Construct a transport for the specified node.
+ * @param managerName The manager name.
+ * @param nodeName The node name.
+ */
+ public JuddiRMITransport(final String managerName, final String nodeName)
+ throws ConfigurationException
+ {
+ this.managerName = managerName ;
+ this.nodeName = (nodeName == null ? Transport.DEFAULT_NODE_NAME : nodeName) ;
+ jndiEnv = createEnvironment(managerName, nodeName) ;
+ }
+
@Override
public JUDDIApiPortType getJUDDIApiService(final String endpointURL)
throws TransportException
@@ -118,7 +134,7 @@
{
return currentApiService ;
}
- final String apiURL = getUDDINode(nodeName).getJuddiApiUrl() ;
+ final String apiURL = getUDDINode(managerName, nodeName).getJuddiApiUrl() ;
final JUDDIApiPortType newApiService = lookupService(jndiEnv, apiURL) ;
if (apiService.compareAndSet(null, newApiService))
{
@@ -139,7 +155,7 @@
{
return currentCustodyTransferService ;
}
- final String custodyTransferURL = getUDDINode(nodeName).getCustodyTransferUrl() ;
+ final String custodyTransferURL = getUDDINode(managerName, nodeName).getCustodyTransferUrl() ;
final UDDICustodyTransferPortType newCustodyTransferService = lookupService(jndiEnv, custodyTransferURL) ;
if (custodyTransferService.compareAndSet(null, newCustodyTransferService))
{
@@ -160,7 +176,7 @@
{
return currentInquiryService ;
}
- final String inquiryURL = getUDDINode(nodeName).getInquiryUrl() ;
+ final String inquiryURL = getUDDINode(managerName, nodeName).getInquiryUrl() ;
final UDDIInquiryPortType newInquiryService = lookupService(jndiEnv, inquiryURL) ;
if (inquiryService.compareAndSet(null, newInquiryService))
{
@@ -181,7 +197,7 @@
{
return currentPublishService ;
}
- final String publishURL = getUDDINode(nodeName).getPublishUrl() ;
+ final String publishURL = getUDDINode(managerName, nodeName).getPublishUrl() ;
final UDDIPublicationPortType newPublishService = lookupService(jndiEnv, publishURL) ;
if (publishService.compareAndSet(null, newPublishService))
{
@@ -202,7 +218,7 @@
{
return currentSecurityService ;
}
- final String securityURL = getUDDINode(nodeName).getSecurityUrl() ;
+ final String securityURL = getUDDINode(managerName, nodeName).getSecurityUrl() ;
final UDDISecurityPortType newSecurityService = lookupService(jndiEnv, securityURL) ;
if (securityService.compareAndSet(null, newSecurityService))
{
@@ -223,7 +239,7 @@
{
return currentSubscriptionListenerService ;
}
- final String subscriptionListenerURL = getUDDINode(nodeName).getSubscriptionListenerUrl() ;
+ final String subscriptionListenerURL = getUDDINode(managerName, nodeName).getSubscriptionListenerUrl() ;
final UDDISubscriptionListenerPortType newSubscriptionListenerService = lookupService(jndiEnv, subscriptionListenerURL) ;
if (subscriptionListenerService.compareAndSet(null, newSubscriptionListenerService))
{
@@ -244,7 +260,7 @@
{
return currentSubscriptionService ;
}
- final String subscriptionURL = getUDDINode(nodeName).getSubscriptionUrl() ;
+ final String subscriptionURL = getUDDINode(managerName, nodeName).getSubscriptionUrl() ;
final UDDISubscriptionPortType newSubscriptionService = lookupService(jndiEnv, subscriptionURL) ;
if (subscriptionService.compareAndSet(null, newSubscriptionService))
{
@@ -256,11 +272,11 @@
}
}
- private static Properties createEnvironment(final String nodeName)
+ private static Properties createEnvironment(final String managerName, final String nodeName)
throws ConfigurationException
{
final Properties jndiEnv = new Properties() ;
- final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(null) ;
+ final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(managerName) ;
final UDDINode uddiNode = manager.getClientConfig().getUDDINode(nodeName) ;
final String initialContextFactory = uddiNode.getFactoryInitial() ;
final String providerURL = uddiNode.getFactoryNamingProvider() ;
@@ -312,12 +328,12 @@
return (T)service ;
}
- private static UDDINode getUDDINode(final String nodeName)
+ private static UDDINode getUDDINode(final String managerName, final String nodeName)
throws TransportException
{
try
{
- final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(null) ;
+ final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(managerName) ;
return manager.getClientConfig().getUDDINode(nodeName) ;
}
catch (final ConfigurationException ce)
Modified: labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/server/ESBInVMServerTransport.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/server/ESBInVMServerTransport.java 2010-02-02 16:08:33 UTC (rev 31362)
+++ labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/server/ESBInVMServerTransport.java 2010-02-02 16:37:12 UTC (rev 31363)
@@ -54,9 +54,14 @@
private final ClassLoader classLoader = getClass().getClassLoader() ;
/**
+ * Default key for null managers.
+ */
+ private static final byte[] DEFAULT_KEY = new byte[0] ;
+
+ /**
* The configured transports.
*/
- private final ConcurrentHashMap<String, Transport> transports = new ConcurrentHashMap<String, Transport>() ;
+ private final ConcurrentHashMap<Object, ConcurrentHashMap<String, Transport>> managerTransports = new ConcurrentHashMap<Object, ConcurrentHashMap<String, Transport>>() ;
/**
* The executor service.
@@ -65,120 +70,148 @@
/**
* Return an API service for the specified node name and endpoint URL.
+ * @param managerName The manager name.
* @param nodeName The node name.
* @param endpointURL The endpoint URL
* @return The API service implementation.
* @throws TransportException For exceptions obtaining the service implementation.
*/
- public JUDDIApiPortType getJUDDIApiService(final String nodeName, final String endpointURL)
+ public JUDDIApiPortType getJUDDIApiService(final String managerName, final String nodeName, final String endpointURL)
throws TransportException
{
- return getTransport(nodeName).getJUDDIApiService(endpointURL) ;
+ return getTransport(managerName, nodeName).getJUDDIApiService(endpointURL) ;
}
/**
* Return a Custody Transfer service for the specified node name and endpoint URL.
+ * @param managerName The manager name.
* @param nodeName The node name.
* @param endpointURL The endpoint URL
* @return The Custody Transfer service implementation.
* @throws TransportException For exceptions obtaining the service implementation.
*/
- public UDDICustodyTransferPortType getUDDICustodyTransferService(final String nodeName, final String endpointURL)
+ public UDDICustodyTransferPortType getUDDICustodyTransferService(final String managerName, final String nodeName, final String endpointURL)
throws TransportException
{
- return getTransport(nodeName).getUDDICustodyTransferService(endpointURL) ;
+ return getTransport(managerName, nodeName).getUDDICustodyTransferService(endpointURL) ;
}
/**
* Return an Inquiry service for the specified node name and endpoint URL.
+ * @param managerName The manager name.
* @param nodeName The node name.
* @param endpointURL The endpoint URL
* @return The Inquiry service implementation.
* @throws TransportException For exceptions obtaining the service implementation.
*/
- public UDDIInquiryPortType getUDDIInquiryService(final String nodeName, final String endpointURL)
+ public UDDIInquiryPortType getUDDIInquiryService(final String managerName, final String nodeName, final String endpointURL)
throws TransportException
{
- return getTransport(nodeName).getUDDIInquiryService(endpointURL) ;
+ return getTransport(managerName, nodeName).getUDDIInquiryService(endpointURL) ;
}
/**
* Return a Publish service for the specified node name and endpoint URL.
+ * @param managerName The manager name.
* @param nodeName The node name.
* @param endpointURL The endpoint URL
* @return The Publish service implementation.
* @throws TransportException For exceptions obtaining the service implementation.
*/
- public UDDIPublicationPortType getUDDIPublishService(final String nodeName, final String endpointURL)
+ public UDDIPublicationPortType getUDDIPublishService(final String managerName, final String nodeName, final String endpointURL)
throws TransportException
{
- return getTransport(nodeName).getUDDIPublishService(endpointURL) ;
+ return getTransport(managerName, nodeName).getUDDIPublishService(endpointURL) ;
}
/**
* Return a Security service for the specified node name and endpoint URL.
+ * @param managerName The manager name.
* @param nodeName The node name.
* @param endpointURL The endpoint URL
* @return The Security service implementation.
* @throws TransportException For exceptions obtaining the service implementation.
*/
- public UDDISecurityPortType getUDDISecurityService(final String nodeName, final String endpointURL)
+ public UDDISecurityPortType getUDDISecurityService(final String managerName, final String nodeName, final String endpointURL)
throws TransportException
{
- return getTransport(nodeName).getUDDISecurityService(endpointURL) ;
+ return getTransport(managerName, nodeName).getUDDISecurityService(endpointURL) ;
}
/**
* Return a Subscription Listener service for the specified node name and endpoint URL.
+ * @param managerName The manager name.
* @param nodeName The node name.
* @param endpointURL The endpoint URL
* @return The Subscription Listener service implementation.
* @throws TransportException For exceptions obtaining the service implementation.
*/
- public UDDISubscriptionListenerPortType getUDDISubscriptionListenerService(final String nodeName, final String endpointURL)
+ public UDDISubscriptionListenerPortType getUDDISubscriptionListenerService(final String managerName, final String nodeName, final String endpointURL)
throws TransportException
{
- return getTransport(nodeName).getUDDISubscriptionListenerService(endpointURL) ;
+ return getTransport(managerName, nodeName).getUDDISubscriptionListenerService(endpointURL) ;
}
/**
* Return a Subscription service for the specified node name and endpoint URL.
+ * @param managerName The manager name.
* @param nodeName The node name.
* @param endpointURL The endpoint URL
* @return The Subscription service implementation.
* @throws TransportException For exceptions obtaining the service implementation.
*/
- public UDDISubscriptionPortType getUDDISubscriptionService(final String nodeName, final String endpointURL)
+ public UDDISubscriptionPortType getUDDISubscriptionService(final String managerName, final String nodeName, final String endpointURL)
throws TransportException
{
- return getTransport(nodeName).getUDDISubscriptionService(endpointURL) ;
+ return getTransport(managerName, nodeName).getUDDISubscriptionService(endpointURL) ;
}
/**
* Get the transport for the specified node.
+ * @param managerName The manager name.
* @param nodeName The node name.
* @return The in vm transport.
*/
- private Transport getTransport(final String nodeName)
+ private Transport getTransport(final String managerName, final String nodeName)
{
+ final ConcurrentHashMap<String, Transport> transports = getTransports(managerName) ;
final Transport transport = transports.get(nodeName) ;
if (transport != null)
{
return transport ;
}
- final JuddiInVMServerTransport juddiTransport = new JuddiInVMServerTransport(nodeName, executorServiceReference) ;
+ final JuddiInVMServerTransport juddiTransport = new JuddiInVMServerTransport(managerName, nodeName, executorServiceReference) ;
final Transport current = transports.putIfAbsent(nodeName, juddiTransport) ;
return (current != null ? current: juddiTransport) ;
}
+
/**
+ * Get the transports for the specified manager.
+ * @param managerName The manager name.
+ * @return The manager transports.
+ */
+ private ConcurrentHashMap<String, Transport> getTransports(final String managerName)
+ {
+ final Object key = (managerName != null ? managerName : DEFAULT_KEY) ;
+ final ConcurrentHashMap<String, Transport> transports = managerTransports.get(key) ;
+ if (transports != null)
+ {
+ return transports ;
+ }
+ final ConcurrentHashMap<String, Transport> newTransports = new ConcurrentHashMap<String, Transport>() ;
+ final ConcurrentHashMap<String, Transport> current = managerTransports.putIfAbsent(key, newTransports) ;
+ return (current != null ? current: newTransports) ;
+ }
+
+ /**
* Start the background executor.
* @param numThreads The number of threads for the background executor.
*/
Modified: labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/server/JuddiInVMServerTransport.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/server/JuddiInVMServerTransport.java 2010-02-02 16:08:33 UTC (rev 31362)
+++ labs/jbossesb/branches/JBESB_4_7_CP/product/rosetta/src/org/jboss/internal/soa/esb/registry/server/JuddiInVMServerTransport.java 2010-02-02 16:37:12 UTC (rev 31363)
@@ -53,6 +53,10 @@
public class JuddiInVMServerTransport extends Transport
{
/**
+ * The current transport manager name.
+ */
+ private final String managerName ;
+ /**
* The current transport node name.
*/
private final String nodeName ;
@@ -97,10 +101,13 @@
/**
* Construct the InVM server transport instance with the delegated instance.
+ * @param managerName The manager name of the transport.
* @param nodeName The node name of the transport.
+ * @param executorServiceReference The task executor.
*/
- public JuddiInVMServerTransport(final String nodeName, final AtomicReference<ExecutorService> executorServiceReference)
+ public JuddiInVMServerTransport(final String managerName, final String nodeName, final AtomicReference<ExecutorService> executorServiceReference)
{
+ this.managerName = managerName ;
this.nodeName = nodeName ;
this.executorServiceReference = executorServiceReference ;
}
@@ -119,7 +126,7 @@
{
try
{
- final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(null) ;
+ final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(managerName) ;
juddiApiUrl = manager.getClientConfig().getUDDINode(nodeName).getJuddiApiUrl() ;
}
catch (final ConfigurationException ce)
@@ -160,7 +167,7 @@
{
try
{
- final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(null) ;
+ final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(managerName) ;
custodyTransferUrl = manager.getClientConfig().getUDDINode(nodeName).getCustodyTransferUrl() ;
}
catch (final ConfigurationException ce)
@@ -200,7 +207,7 @@
{
try
{
- final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(null) ;
+ final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(managerName) ;
inquiryUrl = manager.getClientConfig().getUDDINode(nodeName).getInquiryUrl() ;
}
catch (final ConfigurationException ce)
@@ -240,7 +247,7 @@
{
try
{
- final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(null) ;
+ final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(managerName) ;
publishUrl = manager.getClientConfig().getUDDINode(nodeName).getPublishUrl() ;
}
catch (final ConfigurationException ce)
@@ -280,7 +287,7 @@
{
try
{
- final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(null) ;
+ final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(managerName) ;
securityUrl = manager.getClientConfig().getUDDINode(nodeName).getSecurityUrl() ;
}
catch (final ConfigurationException ce)
@@ -320,7 +327,7 @@
{
try
{
- final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(null) ;
+ final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(managerName) ;
subscriptionListenerUrl = manager.getClientConfig().getUDDINode(nodeName).getSubscriptionListenerUrl() ;
}
catch (final ConfigurationException ce)
@@ -360,7 +367,7 @@
{
try
{
- final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(null) ;
+ final UDDIClerkManager manager = UDDIClientContainer.getUDDIClerkManager(managerName) ;
subscriptionUrl = manager.getClientConfig().getUDDINode(nodeName).getSubscriptionUrl() ;
}
catch (final ConfigurationException ce)
More information about the jboss-svn-commits
mailing list