Author: kstam
Date: Tue Mar 15 20:43:43 2011
New Revision: 1081937
URL: http://svn.apache.org/viewvc?rev=1081937&view=rev
Log:
JUDDI-243 add support for RMI notification
Modified:
juddi/trunk/juddi-core-openjpa/src/test/java/org/apache/juddi/api/impl/API_090_SubscriptionListenerIntegrationTest.java
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/UDDISubscriptionImpl.java
Modified:
juddi/trunk/juddi-core-openjpa/src/test/java/org/apache/juddi/api/impl/API_090_SubscriptionListenerIntegrationTest.java
URL:
http://svn.apache.org/viewvc/juddi/trunk/juddi-core-openjpa/src/test/java/org/apache/juddi/api/impl/API_090_SubscriptionListenerIntegrationTest.java?rev=1081937&r1=1081936&r2=1081937&view=diff
==============================================================================
---
juddi/trunk/juddi-core-openjpa/src/test/java/org/apache/juddi/api/impl/API_090_SubscriptionListenerIntegrationTest.java
(original)
+++
juddi/trunk/juddi-core-openjpa/src/test/java/org/apache/juddi/api/impl/API_090_SubscriptionListenerIntegrationTest.java
Tue Mar 15 20:43:43 2011
@@ -92,7 +92,6 @@ public class API_090_SubscriptionListene
//Saving the Subscription
tckSubscriptionListener.saveNotifierSubscription(authInfoJoe);
//Changing the service we subscribed to
"JoePublisherService"
- logger.info("Updating Service ********** ");
tckBusinessService.updateJoePublisherService(authInfoJoe, "foo");
//tckSubscriptionListener.changeSubscribedObject(authInfoJoe);
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=1081937&r1=1081936&r2=1081937&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
Tue Mar 15 20:43:43 2011
@@ -92,10 +92,12 @@ public class SubscriptionNotifierTest
UddiEntityPublisher publisher = new UddiEntityPublisher();
publisher.setAuthorizedName(subscription.getAuthorizedName());
SubscriptionResultsList resultList =
notifier.getSubscriptionImpl().getSubscriptionResults(getSubscriptionResults,
publisher);
+ logger.info("Expecting the resultList to be null: " +
resultList.getServiceList());
Assert.assertNull(resultList.getServiceList());
tckBusinessService.updateJoePublisherService(authInfoJoe,
"updated description");
resultList =
notifier.getSubscriptionImpl().getSubscriptionResults(getSubscriptionResults,
publisher);
- //We're expecting a changed service (since it was added in the
+ //We're expecting a changed service
+ logger.info("Expecting the resultList to have 1 service: " +
resultList.getServiceList().getServiceInfos().getServiceInfo().size());
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/UDDISubscriptionImpl.java
URL:
http://svn.apache.org/viewvc/juddi/trunk/juddi-core/src/main/java/org/apache/juddi/api/impl/UDDISubscriptionImpl.java?rev=1081937&r1=1081936&r2=1081937&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
Tue Mar 15 20:43:43 2011
@@ -290,7 +290,7 @@ public class UDDISubscriptionImpl extend
if (subscriptionFilter.getFindService() != null) {
//Get the current matching keys
List<?> currentMatchingKeys =
getSubscriptionMatches(subscriptionFilter, em);
- logger.info("current matching keys=" +
currentMatchingKeys);
+ if (logger.isDebugEnabled())
logger.debug("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: [email protected]
For additional commands, e-mail: [email protected]
