directory-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akaras...@apache.org
Subject svn commit: rev 1371 - incubator/directory/ldap/trunk/eve/frontend/event/impl/src/java/org/apache/eve/event
Date Sat, 06 Dec 2003 20:21:54 GMT
Author: akarasulu
Date: Sat Dec  6 12:21:53 2003
New Revision: 1371

Added:
   incubator/directory/ldap/trunk/eve/frontend/event/impl/src/java/org/apache/eve/event/DefaultEventRouter.java
      - copied, changed from rev 1366, incubator/directory/ldap/trunk/eve/frontend/event/impl/src/java/org/apache/eve/event/EventRouterImpl.java
   incubator/directory/ldap/trunk/eve/frontend/event/impl/src/java/org/apache/eve/event/MerlinEventRouter.java
   incubator/directory/ldap/trunk/eve/frontend/event/impl/src/java/org/apache/eve/event/NullEventRouterMonitor.java
Removed:
   incubator/directory/ldap/trunk/eve/frontend/event/impl/src/java/org/apache/eve/event/EventRouterImpl.java
Log:
Completed Merlin service implementation.


Copied: incubator/directory/ldap/trunk/eve/frontend/event/impl/src/java/org/apache/eve/event/DefaultEventRouter.java
(from rev 1366, incubator/directory/ldap/trunk/eve/frontend/event/impl/src/java/org/apache/eve/event/EventRouterImpl.java)
==============================================================================
--- incubator/directory/ldap/trunk/eve/frontend/event/impl/src/java/org/apache/eve/event/EventRouterImpl.java
(original)
+++ incubator/directory/ldap/trunk/eve/frontend/event/impl/src/java/org/apache/eve/event/DefaultEventRouter.java
Sat Dec  6 12:21:53 2003
@@ -63,10 +63,12 @@
  * @author $Author$
  * @version $Revision$
  */
-public class EventRouterImpl implements EventRouter
+public class DefaultEventRouter implements EventRouter
 {
     /** the set of subscriptions made with this router */
     private Set m_subscriptions = new HashSet() ;
+    /** the monitor - initially set to the null monitor */
+    private EventRouterMonitor m_monitor = new NullEventRouterMonitor() ;
     
     
     /**
@@ -91,6 +93,8 @@
 		    {
 		        m_subscriptions.add( l_subscription ) ;
 		    }
+		    
+			m_monitor.addedSubscription( l_subscription ) ;
 		}
     }
 
@@ -111,6 +115,7 @@
 	            if ( a_subscriber == l_subscription.getSubscriber() )
 	            {
 	                l_list.remove() ;
+	                m_monitor.removedSubscription( l_subscription ) ;
 	            }
 	        }
 		}
@@ -135,6 +140,7 @@
 				  && a_type.equals( l_subscription.getType() ) )
 				{
 					l_list.remove() ;
+					m_monitor.removedSubscription( l_subscription ) ;
 				}
 			}
 		}
@@ -195,5 +201,27 @@
 				l_subscriptions[ii].getSubscriber().inform( a_event ) ;
 			}
         }
+    }
+    
+    
+	/**
+	 * Sets the event router's monitor.
+	 * 
+	 * @param a_monitor the monitor
+	 */
+    public void setMonitor( EventRouterMonitor a_monitor )
+    {
+        m_monitor = a_monitor ;
+    }
+    
+    
+    /**
+     * Gets the event router's monitor.
+     * 
+     * @return the monitor
+     */
+    public EventRouterMonitor getMonitor()
+    {
+        return m_monitor ;
     }
 }

Added: incubator/directory/ldap/trunk/eve/frontend/event/impl/src/java/org/apache/eve/event/MerlinEventRouter.java
==============================================================================
--- (empty file)
+++ incubator/directory/ldap/trunk/eve/frontend/event/impl/src/java/org/apache/eve/event/MerlinEventRouter.java
Sat Dec  6 12:21:53 2003
@@ -0,0 +1,185 @@
+/*
+
+ ============================================================================
+                   The Apache Software License, Version 1.1
+ ============================================================================
+
+ Copyright (C) 1999-2002 The Apache Software Foundation. All rights reserved.
+
+ Redistribution and use in source and binary forms, with or without modifica-
+ tion, are permitted provided that the following conditions are met:
+
+ 1. Redistributions of  source code must  retain the above copyright  notice,
+    this list of conditions and the following disclaimer.
+
+ 2. Redistributions in binary form must reproduce the above copyright notice,
+    this list of conditions and the following disclaimer in the documentation
+    and/or other materials provided with the distribution.
+
+ 3. The end-user documentation included with the redistribution, if any, must
+    include  the following  acknowledgment:  "This product includes  software
+    developed  by the  Apache Software Foundation  (http://www.apache.org/)."
+    Alternately, this  acknowledgment may  appear in the software itself,  if
+    and wherever such third-party acknowledgments normally appear.
+
+ 4. The names "Eve Directory Server", "Apache Directory Project", "Apache Eve" 
+	and "Apache Software Foundation"  must not be used to endorse or promote
+    products derived  from this  software without  prior written
+    permission. For written permission, please contact apache@apache.org.
+
+ 5. Products  derived from this software may not  be called "Apache", nor may
+    "Apache" appear  in their name,  without prior written permission  of the
+    Apache Software Foundation.
+
+ THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED WARRANTIES,
+ INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
+ FITNESS  FOR A PARTICULAR  PURPOSE ARE  DISCLAIMED.  IN NO  EVENT SHALL  THE
+ APACHE SOFTWARE  FOUNDATION  OR ITS CONTRIBUTORS  BE LIABLE FOR  ANY DIRECT,
+ INDIRECT, INCIDENTAL, SPECIAL,  EXEMPLARY, OR CONSEQUENTIAL  DAMAGES (INCLU-
+ DING, BUT NOT LIMITED TO, PROCUREMENT  OF SUBSTITUTE GOODS OR SERVICES; LOSS
+ OF USE, DATA, OR  PROFITS; OR BUSINESS  INTERRUPTION)  HOWEVER CAUSED AND ON
+ ANY  THEORY OF LIABILITY,  WHETHER  IN CONTRACT,  STRICT LIABILITY,  OR TORT
+ (INCLUDING  NEGLIGENCE OR  OTHERWISE) ARISING IN  ANY WAY OUT OF THE  USE OF
+ THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+ This software  consists of voluntary contributions made  by many individuals
+ on  behalf of the Apache Software  Foundation. For more  information on the
+ Apache Software Foundation, please see <http://www.apache.org/>.
+
+*/
+package org.apache.eve.event ;
+
+
+import java.util.EventObject ;
+
+import org.apache.avalon.framework.activity.Initializable ;
+import org.apache.avalon.framework.logger.AbstractLogEnabled ;
+
+
+/**
+ * A Merlin and Avalon specific event router wrapping the the default 
+ * implementation.
+ * 
+ * @avalon.component name="event-router" lifestyle="singleton"
+ * @avalon.service type="org.apache.eve.EventRouter" version="1.0"
+ * 
+ * @author <a href="mailto:aok123@bellsouth.net">Alex Karasulu</a>
+ * @author $Author$
+ * @version $Revision$
+ */
+public class MerlinEventRouter extends AbstractLogEnabled 
+	implements 
+    EventRouter,
+	Initializable
+{
+    /** the default EventRouter implementation we wrap */ 
+    private DefaultEventRouter m_router ;
+    
+    
+	// ------------------------------------------------------------------------
+    // EventRouter Methods
+	// ------------------------------------------------------------------------
+    
+    
+    /* (non-Javadoc)
+     * @see org.apache.eve.event.EventRouter#subscribe(java.lang.Class, 
+     * org.apache.eve.event.Filter, org.apache.eve.event.Subscriber)
+     */
+    public void subscribe(
+        Class a_type,
+        Filter a_filter,
+        Subscriber a_subscriber )
+    {
+        m_router.subscribe( a_type, a_filter, a_subscriber ) ;
+    }
+    
+
+    /* (non-Javadoc)
+     * @see org.apache.eve.event.EventRouter#unsubscribe(
+     * org.apache.eve.event.Subscriber)
+     */
+    public void unsubscribe( Subscriber a_subscriber )
+    {
+        m_router.unsubscribe( a_subscriber ) ;
+    }
+    
+
+    /* (non-Javadoc)
+     * @see org.apache.eve.event.EventRouter#unsubscribe(java.lang.Class, 
+     * org.apache.eve.event.Subscriber)
+     */
+    public void unsubscribe( Class a_type, Subscriber a_subscriber )
+    {
+        m_router.unsubscribe( a_type, a_subscriber ) ;
+    }
+
+    
+    /* (non-Javadoc)
+     * @see org.apache.eve.event.EventRouter#publish(java.util.EventObject)
+     */
+    public void publish( EventObject a_event )
+    {
+        m_router.publish( a_event ) ;
+    }
+
+    
+	// ------------------------------------------------------------------------
+	// Avalon Life Cycle Methods
+	// ------------------------------------------------------------------------
+
+    
+    /*
+     *  (non-Javadoc)
+     * @see org.apache.avalon.framework.activity.Initializable#initialize()
+     */
+    public void initialize()
+    {
+        m_router = new DefaultEventRouter() ;
+        m_router.setMonitor( new Monitor() ) ;
+    }
+    
+    
+	// ------------------------------------------------------------------------
+	// Avalon specific EventRouterMonitor
+	// ------------------------------------------------------------------------
+
+    
+    /**
+     * EventRouterMonitor that uses this module's logger.
+     *
+     * @author <a href="mailto:aok123@bellsouth.net">Alex Karasulu</a>
+     * @author $Author$
+     * @version $Revision$
+     */
+    class Monitor implements EventRouterMonitor
+    {
+		/* (non-Javadoc)
+		 * @see org.apache.eve.event.EventRouterMonitor#eventPublished(
+		 * java.util.EventObject)
+		 */
+		public void eventPublished( EventObject a_event )
+		{
+			getLogger().debug( "published event: " + a_event ) ;
+		}
+
+    
+		/* (non-Javadoc)
+		 * @see org.apache.eve.event.EventRouterMonitor#addedSubscription(
+		 * org.apache.eve.event.Subscription)
+		 */
+		public void addedSubscription( Subscription a_subscription )
+		{
+			getLogger().debug( "added subscription: " + a_subscription ) ;
+		}
+
+    
+		/* (non-Javadoc)
+		 * @see org.apache.eve.event.EventRouterMonitor#removedSubscription(
+		 * org.apache.eve.event.Subscription)
+		 */
+		public void removedSubscription( Subscription a_subscription )
+		{
+			getLogger().debug( "removed subscription: " + a_subscription ) ;
+		}
+    }
+}

Added: incubator/directory/ldap/trunk/eve/frontend/event/impl/src/java/org/apache/eve/event/NullEventRouterMonitor.java
==============================================================================
--- (empty file)
+++ incubator/directory/ldap/trunk/eve/frontend/event/impl/src/java/org/apache/eve/event/NullEventRouterMonitor.java
Sat Dec  6 12:21:53 2003
@@ -0,0 +1,85 @@
+/*
+
+ ============================================================================
+                   The Apache Software License, Version 1.1
+ ============================================================================
+
+ Copyright (C) 1999-2002 The Apache Software Foundation. All rights reserved.
+
+ Redistribution and use in source and binary forms, with or without modifica-
+ tion, are permitted provided that the following conditions are met:
+
+ 1. Redistributions of  source code must  retain the above copyright  notice,
+    this list of conditions and the following disclaimer.
+
+ 2. Redistributions in binary form must reproduce the above copyright notice,
+    this list of conditions and the following disclaimer in the documentation
+    and/or other materials provided with the distribution.
+
+ 3. The end-user documentation included with the redistribution, if any, must
+    include  the following  acknowledgment:  "This product includes  software
+    developed  by the  Apache Software Foundation  (http://www.apache.org/)."
+    Alternately, this  acknowledgment may  appear in the software itself,  if
+    and wherever such third-party acknowledgments normally appear.
+
+ 4. The names "Eve Directory Server", "Apache Directory Project", "Apache Eve" 
+	and "Apache Software Foundation"  must not be used to endorse or promote
+    products derived  from this  software without  prior written
+    permission. For written permission, please contact apache@apache.org.
+
+ 5. Products  derived from this software may not  be called "Apache", nor may
+    "Apache" appear  in their name,  without prior written permission  of the
+    Apache Software Foundation.
+
+ THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED WARRANTIES,
+ INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
+ FITNESS  FOR A PARTICULAR  PURPOSE ARE  DISCLAIMED.  IN NO  EVENT SHALL  THE
+ APACHE SOFTWARE  FOUNDATION  OR ITS CONTRIBUTORS  BE LIABLE FOR  ANY DIRECT,
+ INDIRECT, INCIDENTAL, SPECIAL,  EXEMPLARY, OR CONSEQUENTIAL  DAMAGES (INCLU-
+ DING, BUT NOT LIMITED TO, PROCUREMENT  OF SUBSTITUTE GOODS OR SERVICES; LOSS
+ OF USE, DATA, OR  PROFITS; OR BUSINESS  INTERRUPTION)  HOWEVER CAUSED AND ON
+ ANY  THEORY OF LIABILITY,  WHETHER  IN CONTRACT,  STRICT LIABILITY,  OR TORT
+ (INCLUDING  NEGLIGENCE OR  OTHERWISE) ARISING IN  ANY WAY OUT OF THE  USE OF
+ THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+ This software  consists of voluntary contributions made  by many individuals
+ on  behalf of the Apache Software  Foundation. For more  information on the
+ Apache Software Foundation, please see <http://www.apache.org/>.
+
+*/
+package org.apache.eve.event ;
+
+
+import java.util.EventObject ;
+
+
+/**
+ * Does nothing and created by the default constructor.
+ *
+ * @author <a href="mailto:aok123@bellsouth.net">Alex Karasulu</a>
+ * @author $Author$
+ * @version $Revision$
+ */
+public class NullEventRouterMonitor implements EventRouterMonitor
+{
+    /* (non-Javadoc)
+     * @see org.apache.eve.event.EventRouterMonitor#eventPublished(java.util.EventObject)
+     */
+    public void eventPublished(EventObject a_a_event)
+    {
+    }
+
+    /* (non-Javadoc)
+     * @see org.apache.eve.event.EventRouterMonitor#addedSubscription(org.apache.eve.event.Subscription)
+     */
+    public void addedSubscription(Subscription a_a_subscription)
+    {
+    }
+
+    /* (non-Javadoc)
+     * @see org.apache.eve.event.EventRouterMonitor#removedSubscription(org.apache.eve.event.Subscription)
+     */
+    public void removedSubscription(Subscription a_a_subscription)
+    {
+    }
+}

Mime
View raw message