defaultserviceregistry.java

来自「Xfire文件 用于开发web service 的一个开源工具 很好用的」· Java 代码 · 共 129 行

package org.codehaus.xfire.service;

import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import javax.xml.namespace.QName;

import org.codehaus.xfire.service.event.RegistrationEvent;
import org.codehaus.xfire.service.event.RegistrationEventListener;

/**
 * @author <a href="mailto:[e-mail]">Arjen Poutsma</a>
 */
public class DefaultServiceRegistry
        implements ServiceRegistry
{
    // maps string names to service endpoints
    private Map name2service = new HashMap();
    private Map qname2service = new HashMap();
    private List eventListeners = new ArrayList();

    /**
     * Returns the <code>ServiceEndpoint</code> with the given qualified name, if found. Returns <code>null</code> if
     * not found.
     *
     * @param name the service name.
     * @return the service endpoint, or <code>null</code> if not found.
     */
    public Service getService(String name)
    {
        return (Service) name2service.get(name);
    }

    public Service getService(QName name)
    {
        return (Service) qname2service.get(name);
    }
    
    /**
     * Registers a given <code>ServiceEndpoint</code> with this registry.
     *
     * @param endpoint the endpoint.
     */
    public void register(Service endpoint)
    {
        name2service.put(endpoint.getSimpleName(), endpoint);
        qname2service.put(endpoint.getName(), endpoint);

        for (Iterator iterator = eventListeners.iterator(); iterator.hasNext();)
        {
            RegistrationEventListener listener = (RegistrationEventListener) iterator.next();
            RegistrationEvent event = new RegistrationEvent(this, endpoint);
            listener.endpointRegistered(event);
        }
    }

    /**
     * Unregisters the service with the given qualified name, if found.
     *
     * @param name the service name.
     */
    public void unregister(Service endpoint)
    {
        for (Iterator iterator = eventListeners.iterator(); iterator.hasNext();)
        {
            RegistrationEventListener listener = (RegistrationEventListener) iterator.next();
            RegistrationEvent event = new RegistrationEvent(this, endpoint);
            listener.endpointUnregistered(event);
        }

        if (name2service.containsValue(endpoint))
            name2service.remove(endpoint.getSimpleName());
        
        if (qname2service.containsValue(endpoint))
            qname2service.remove(endpoint.getName());
    }

    /**
     * Indicates whether this registry has a service with the given name.
     *
     * @param name the service name.
     * @return <code>true</code> if this registry has a service with the given name; <code>false</code> otherwise.
     */
    public boolean hasService(String name)
    {
        return name2service.containsKey(name);
    }

    public boolean hasService(QName name)
    {
        return qname2service.containsKey(name);
    }
    
    /**
     * Returns all <code>ServiceEndpoint</code> registered to this registry.
     *
     * @return all service endpoints.
     */
    public Collection getServices()
    {
        return Collections.unmodifiableCollection(qname2service.values());
    }

    /**
     * Add a listener for registration events.
     *
     * @param listener the listener.
     */
    public void addRegistrationEventListener(RegistrationEventListener listener)
    {
        eventListeners.add(listener);
    }

    /**
     * Remove a listener for registration events.
     *
     * @param listener the listener.
     */
    public void removeRegistrationEventListener(RegistrationEventListener listener)
    {
        eventListeners.remove(listener);
    }
}