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 2011/03/16 01:33:24 UTC
svn commit: r1082012 - in /juddi/trunk:
juddi-core-openjpa/src/test/java/org/apache/juddi/subscription/
juddi-core/src/main/java/org/apache/juddi/api/impl/
Author: kstam
Date: Wed Mar 16 00:33:24 2011
New Revision: 1082012
URL: http://svn.apache.org/viewvc?rev=1082012&view=rev
Log:
JUDDI-243 add support for RMI notification
adding info logging to debug issue on buildbot
Modified:
juddi/trunk/juddi-core-openjpa/src/test/java/org/apache/juddi/subscription/SubscriptionNotifierTest.java
juddi/trunk/juddi-core/src/main/java/org/apache/juddi/api/impl/InquiryHelper.java
juddi/trunk/juddi-core/src/main/java/org/apache/juddi/api/impl/UDDISubscriptionImpl.java
Modified: juddi/trunk/juddi-core-openjpa/src/test/java/org/apache/juddi/subscription/SubscriptionNotifierTest.java
URL: http://svn.apache.org/viewvc/juddi/trunk/juddi-core-openjpa/src/test/java/org/apache/juddi/subscription/SubscriptionNotifierTest.java?rev=1082012&r1=1082011&r2=1082012&view=diff
==============================================================================
--- juddi/trunk/juddi-core-openjpa/src/test/java/org/apache/juddi/subscription/SubscriptionNotifierTest.java (original)
+++ juddi/trunk/juddi-core-openjpa/src/test/java/org/apache/juddi/subscription/SubscriptionNotifierTest.java Wed Mar 16 00:33:24 2011
@@ -97,7 +97,7 @@ public class SubscriptionNotifierTest
tckBusinessService.updateJoePublisherService(authInfoJoe, "updated description");
resultList = notifier.getSubscriptionImpl().getSubscriptionResults(getSubscriptionResults, publisher);
//We're expecting a changed service
- logger.info("Expecting the resultList to have 1 service: " + resultList.getServiceList().getServiceInfos().getServiceInfo().size());
+ logger.info("Expecting the resultList to have 1 service: " + resultList.getServiceList());
Assert.assertNotNull(resultList.getServiceList());
//We should detect these changes.
boolean hasChanges = notifier.resultListContainsChanges(resultList);
Modified: juddi/trunk/juddi-core/src/main/java/org/apache/juddi/api/impl/InquiryHelper.java
URL: http://svn.apache.org/viewvc/juddi/trunk/juddi-core/src/main/java/org/apache/juddi/api/impl/InquiryHelper.java?rev=1082012&r1=1082011&r2=1082012&view=diff
==============================================================================
--- juddi/trunk/juddi-core/src/main/java/org/apache/juddi/api/impl/InquiryHelper.java (original)
+++ juddi/trunk/juddi-core/src/main/java/org/apache/juddi/api/impl/InquiryHelper.java Wed Mar 16 00:33:24 2011
@@ -23,6 +23,8 @@ import java.util.List;
import javax.persistence.EntityManager;
import javax.xml.ws.Holder;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
import org.apache.juddi.mapping.MappingModelToApi;
import org.apache.juddi.query.FetchBindingTemplatesQuery;
import org.apache.juddi.query.FetchBusinessEntitiesQuery;
@@ -70,6 +72,8 @@ import org.uddi.v3_service.DispositionRe
*/
public class InquiryHelper {
+ private static Log logger = LogFactory.getLog(InquiryHelper.class);
+
public static List<?> findBinding(FindBinding body, FindQualifiers findQualifiers, EntityManager em) throws DispositionReportFaultMessage {
List<?> keysFound = null;
@@ -325,13 +329,14 @@ public class InquiryHelper {
currentIndex = subscriptionStartIndex.value;
int returnedRowCount = 0;
-
+ logger.info("Period = " + modifiedAfter + " ---- " + modifiedBefore);
while (currentIndex < queryResults.size()) {
Object item = queryResults.get(currentIndex);
org.apache.juddi.model.BusinessService modelBusinessService = (org.apache.juddi.model.BusinessService)item;
org.uddi.api_v3.ServiceInfo apiServiceInfo = new org.uddi.api_v3.ServiceInfo();
+ logger.info(modelBusinessService.getEntityKey() + " is modified " + modelBusinessService.getModifiedIncludingChildren());
if (modifiedAfter != null && modifiedAfter.after(modelBusinessService.getModifiedIncludingChildren())) {
currentIndex++;
continue;
Modified: juddi/trunk/juddi-core/src/main/java/org/apache/juddi/api/impl/UDDISubscriptionImpl.java
URL: http://svn.apache.org/viewvc/juddi/trunk/juddi-core/src/main/java/org/apache/juddi/api/impl/UDDISubscriptionImpl.java?rev=1082012&r1=1082011&r2=1082012&view=diff
==============================================================================
--- juddi/trunk/juddi-core/src/main/java/org/apache/juddi/api/impl/UDDISubscriptionImpl.java (original)
+++ juddi/trunk/juddi-core/src/main/java/org/apache/juddi/api/impl/UDDISubscriptionImpl.java Wed Mar 16 00:33:24 2011
@@ -290,7 +290,8 @@ public class UDDISubscriptionImpl extend
if (subscriptionFilter.getFindService() != null) {
//Get the current matching keys
List<?> currentMatchingKeys = getSubscriptionMatches(subscriptionFilter, em);
- if (logger.isDebugEnabled()) logger.debug("current matching keys=" + currentMatchingKeys);
+ //if (logger.isDebugEnabled())
+ logger.info("current matching keys=" + currentMatchingKeys);
List<String> missingKeys = getMissingKeys(currentMatchingKeys, modelSubscription.getSubscriptionMatches());
if (missingKeys != null && missingKeys.size() > 0) {
KeyBag missingKeyBag = new KeyBag();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@juddi.apache.org
For additional commands, e-mail: commits-help@juddi.apache.org