You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@juddi.apache.org by ks...@apache.org on 2009/10/20 05:02:18 UTC
svn commit: r826935 -
/webservices/juddi/trunk/juddi-console/uddi-portlets/src/main/java/org/apache/juddi/portlets/server/service/SubscriptionServiceImpl.java
Author: kstam
Date: Tue Oct 20 03:02:18 2009
New Revision: 826935
URL: http://svn.apache.org/viewvc?rev=826935&view=rev
Log:
JUDDI-240 adding sync subscription
Modified:
webservices/juddi/trunk/juddi-console/uddi-portlets/src/main/java/org/apache/juddi/portlets/server/service/SubscriptionServiceImpl.java
Modified: webservices/juddi/trunk/juddi-console/uddi-portlets/src/main/java/org/apache/juddi/portlets/server/service/SubscriptionServiceImpl.java
URL: http://svn.apache.org/viewvc/webservices/juddi/trunk/juddi-console/uddi-portlets/src/main/java/org/apache/juddi/portlets/server/service/SubscriptionServiceImpl.java?rev=826935&r1=826934&r2=826935&view=diff
==============================================================================
--- webservices/juddi/trunk/juddi-console/uddi-portlets/src/main/java/org/apache/juddi/portlets/server/service/SubscriptionServiceImpl.java (original)
+++ webservices/juddi/trunk/juddi-console/uddi-portlets/src/main/java/org/apache/juddi/portlets/server/service/SubscriptionServiceImpl.java Tue Oct 20 03:02:18 2009
@@ -33,6 +33,8 @@
import org.apache.juddi.api_v3.SaveClerk;
import org.apache.juddi.api_v3.SaveClientSubscriptionInfo;
import org.apache.juddi.api_v3.SaveNode;
+import org.apache.juddi.api_v3.SyncSubscription;
+import org.apache.juddi.api_v3.SyncSubscriptionDetail;
import org.apache.juddi.jaxb.JAXBMarshaller;
import org.apache.juddi.portlets.client.model.Node;
import org.apache.juddi.portlets.client.model.Subscription;
@@ -313,14 +315,19 @@
UDDIClerk clerk = UDDIClerkManager.getClientConfig().getUDDIClerks().get(modelSubscription.getClerkName());
String authToken = (String) session.getAttribute("token-" + clerk.getName());
getSubscriptionResults.setAuthInfo(authToken);
+ SyncSubscription syncSubscription = new SyncSubscription();
+ syncSubscription.getGetSubscriptionResultsList().add(getSubscriptionResults);
- String clazz = UDDIClerkManager.getClientConfig().getUDDINode(clerk.getUDDINode().getName()).getProxyTransport();
- Class<?> transportClass = Loader.loadClass(clazz);
- Transport transport = (Transport) transportClass.getConstructor(String.class).newInstance(clerk.getUDDINode().getName());
- UDDISubscriptionPortType subscriptionService = transport.getUDDISubscriptionService();
-
- SubscriptionResultsList list = subscriptionService.getSubscriptionResults(getSubscriptionResults);
+ String clazz = UDDIClerkManager.getClientConfig().getUDDINode(Constants.NODE_NAME).getProxyTransport();
+ Class<?> transportClass = Loader.loadClass(clazz);
+ Transport transport = (Transport) transportClass.getConstructor(String.class).newInstance(Constants.NODE_NAME);
+ JUDDIApiPortType apiService = transport.getJUDDIApiService();
+
+ syncSubscription.setAuthInfo(userAuthToken);
+ SyncSubscriptionDetail detail = apiService.invokeSyncSubscription(syncSubscription);
+ SubscriptionResultsList list = detail.getSubscriptionResultsList().get(0);
System.out.println("list=" + list);
+
response.setSuccess(true);
} catch (Exception e) {
logger.error("Could not save subscription. " + e.getMessage(), e);
---------------------------------------------------------------------
To unsubscribe, e-mail: juddi-cvs-unsubscribe@ws.apache.org
For additional commands, e-mail: juddi-cvs-help@ws.apache.org