org.apache.juddi.v3.client.mapping

Class UDDIServiceCache

java.lang.Object

org.apache.juddi.v3.client.mapping.UDDIServiceCache

All Implemented Interfaces:

UDDIServiceCacheMBean

public class UDDIServiceCache
extends Object
implements UDDIServiceCacheMBean

The UDDIServiceCache maintains a cache of the service bindingTemplates of all service the lookupService method is called for. To prevent the cache from going stale it registers an Subscription with the UDDI server. The subscription matches any update on any service. When the subscription is matched, the UDDI server will callback to the UDDIClientSubscriptionListenerService which is a WebService Endpoint brought up by this cache. The Cache also registers an MBean which allows for managing and monitoring via JMX.

Author:

Kurt T Stam

See Also:

UDDIClientSubscriptionListenerImpl, UDDIServiceCacheMBean, UDDISubscriptionListenerPortType, ServiceLocator

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_SUBSCRIPTION_LISTENER_URL
static String	SUBSCRIPTION_LISTENER_PORT_NAME
static QName	SUBSCRIPTION_LISTENER_SERVICE_NAME
static String	UDDI_CLIENT_SUBSCRIPTION_LISTENER
static String	UDDI_ORG_NS

Constructor Summary

Constructors

Constructor and Description
UDDIServiceCache()
UDDIServiceCache(UDDIClerk clerk)
UDDIServiceCache(UDDIClerk clerk, URL callbackBaseUrl)
UDDIServiceCache(UDDIClerk clerk, URLLocalizer urlLocalizer, Properties properties)

Method Summary

Modifier and Type	Method and Description
void	addService(String serviceKey, Topology topology) Adds or updates epr information for the given serviceKey.
Set<String>	getCacheEntries() Method callable from the mbean
UDDIClerk	getClerk()
Map<String,Topology>	getServiceCacheMap()
int	getServiceCacheSize() Method callable from the mbean
boolean	hasListener()
Topology	lookupService(String serviceKey)
void	publishAndRegisterHttpCallbackEndpoint()
void	registerAsMBean()
void	registerSubscription(String bindingKey) Create a subscription for changes in any Service in the Registry
void	removeAll()
void	removeService(String serviceKey)
void	resetCache() Method callable from the mbean
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

UDDI_ORG_NS

public static final String UDDI_ORG_NS

See Also:

Constant Field Values

UDDI_CLIENT_SUBSCRIPTION_LISTENER

public static final String UDDI_CLIENT_SUBSCRIPTION_LISTENER

See Also:

Constant Field Values

SUBSCRIPTION_LISTENER_SERVICE_NAME

public static final QName SUBSCRIPTION_LISTENER_SERVICE_NAME

SUBSCRIPTION_LISTENER_PORT_NAME

public static final String SUBSCRIPTION_LISTENER_PORT_NAME

See Also:

Constant Field Values

DEFAULT_SUBSCRIPTION_LISTENER_URL

public static final String DEFAULT_SUBSCRIPTION_LISTENER_URL

See Also:

Constant Field Values

Constructor Detail

UDDIServiceCache

public UDDIServiceCache()

UDDIServiceCache

public UDDIServiceCache(UDDIClerk clerk)
                 throws MalformedURLException

Throws:

MalformedURLException

UDDIServiceCache

public UDDIServiceCache(UDDIClerk clerk,
                        URL callbackBaseUrl)

UDDIServiceCache

public UDDIServiceCache(UDDIClerk clerk,
                        URLLocalizer urlLocalizer,
                        Properties properties)
                 throws DatatypeConfigurationException,
                        MalformedURLException,
                        RemoteException,
                        org.apache.commons.configuration.ConfigurationException,
                        javax.wsdl.WSDLException,
                        TransportException,
                        Exception

Throws:

DatatypeConfigurationException

MalformedURLException

RemoteException

org.apache.commons.configuration.ConfigurationException

javax.wsdl.WSDLException

TransportException

Exception

Method Detail

getClerk

public UDDIClerk getClerk()

publishAndRegisterHttpCallbackEndpoint

public void publishAndRegisterHttpCallbackEndpoint()
                                            throws BindException

Throws:

BindException

hasListener

public boolean hasListener()

registerAsMBean

public void registerAsMBean()

shutdown

public void shutdown()

removeAll

public void removeAll()

addService

public void addService(String serviceKey,
                       Topology topology)

Adds or updates epr information for the given serviceKey.

Parameters:

serviceKey -

topology -

lookupService

public Topology lookupService(String serviceKey)

removeService

public void removeService(String serviceKey)

registerSubscription

public void registerSubscription(String bindingKey)
                          throws DatatypeConfigurationException

Create a subscription for changes in any Service in the Registry

Parameters:

bindingKey - the binding key

Throws:

DatatypeConfigurationException

getServiceCacheMap

public Map<String,Topology> getServiceCacheMap()

getServiceCacheSize

public int getServiceCacheSize()

Method callable from the mbean

Specified by:

getServiceCacheSize in interface UDDIServiceCacheMBean

getCacheEntries

public Set<String> getCacheEntries()

Method callable from the mbean

Specified by:

getCacheEntries in interface UDDIServiceCacheMBean

resetCache

public void resetCache()

Method callable from the mbean

Specified by:

resetCache in interface UDDIServiceCacheMBean