org.apache.juddi.subscription
Class SubscriptionNotifier

java.lang.Object
  java.util.TimerTask
      org.apache.juddi.subscription.SubscriptionNotifier

All Implemented Interfaces:

Runnable

public class SubscriptionNotifier
extends TimerTask

Author:

Kurt T Stam

Constructor Summary

SubscriptionNotifier()

Method Summary

protected GetSubscriptionResults	buildGetSubscriptionResults(Subscription subscription, Date endPoint)
boolean	cancel()
protected void	deleteSubscription(Subscription subscription) Deletes the subscription.
protected Collection<Subscription>	getAllAsyncSubscriptions() Obtains all subscriptions in the system.
protected UDDISubscriptionImpl	getSubscriptionImpl()
protected void	notify(GetSubscriptionResults getSubscriptionResults, SubscriptionResultsList resultList, Date notificationDate) Sends out the notifications.
protected boolean	registryMayContainUpdates() If the CRUD methods on the publication API where not called, this registry node does not contain changes.
protected boolean	resultListContainsChanges(SubscriptionResultsList resultList)
void	run()

Methods inherited from class java.util.TimerTask

scheduledExecutionTime

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SubscriptionNotifier

public SubscriptionNotifier()
                     throws org.apache.commons.configuration.ConfigurationException

Throws:

org.apache.commons.configuration.ConfigurationException

Method Detail

cancel

public boolean cancel()

Overrides:

cancel in class TimerTask

registryMayContainUpdates

protected boolean registryMayContainUpdates()

If the CRUD methods on the publication API where not called, this registry node does not contain changes. If the registry database is shared with other registry nodes and one of those registries pushed in a change, then that registry node will take care of sending out notifications.

Returns:

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class TimerTask

buildGetSubscriptionResults

protected GetSubscriptionResults buildGetSubscriptionResults(Subscription subscription,
                                                             Date endPoint)
                                                      throws DispositionReportFaultMessage,
                                                             DatatypeConfigurationException

Throws:

DispositionReportFaultMessage

DatatypeConfigurationException

resultListContainsChanges

protected boolean resultListContainsChanges(SubscriptionResultsList resultList)

getAllAsyncSubscriptions

protected Collection<Subscription> getAllAsyncSubscriptions()

Obtains all subscriptions in the system.

Returns:

Collection of All Subscriptions in the system.

deleteSubscription

protected void deleteSubscription(Subscription subscription)

Deletes the subscription. i.e. when it is expired.

Parameters:

subscription -

notify

protected void notify(GetSubscriptionResults getSubscriptionResults,
                      SubscriptionResultsList resultList,
                      Date notificationDate)

Sends out the notifications.

Parameters:

resultList -

Throws:

MalformedURLException

DispositionReportFaultMessage

getSubscriptionImpl

protected UDDISubscriptionImpl getSubscriptionImpl()