avalon-cvs mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dona...@apache.org
Subject cvs commit: jakarta-avalon-phoenix/src/java/org/apache/avalon/phoenix/components/application ListenerSupport.java AppLifecycleHelper.java ApplicationListenerSupport.java
Date Sun, 19 May 2002 02:46:43 GMT
donaldp     02/05/18 19:46:43

  Modified:    src/conf kernel.xml
               src/java/org/apache/avalon/phoenix/components/application
                        AppLifecycleHelper.java
  Added:       src/java/org/apache/avalon/phoenix/components/application
                        ListenerSupport.java
  Removed:     src/java/org/apache/avalon/phoenix/components/application
                        ApplicationListenerSupport.java
  Log:
  Rename ApplicationListenerSupport to ListenerSupport.
  
  Revision  Changes    Path
  1.6       +6 -0      jakarta-avalon-phoenix/src/conf/kernel.xml
  
  Index: kernel.xml
  ===================================================================
  RCS file: /home/cvs/jakarta-avalon-phoenix/src/conf/kernel.xml,v
  retrieving revision 1.5
  retrieving revision 1.6
  diff -u -r1.5 -r1.6
  --- kernel.xml	10 May 2002 14:16:53 -0000	1.5
  +++ kernel.xml	19 May 2002 02:46:43 -0000	1.6
  @@ -16,10 +16,16 @@
               class="org.apache.avalon.phoenix.components.kernel.DefaultKernel"
               logger="kernel"/>
   
  +<!--
           <component role="org.apache.avalon.phoenix.interfaces.SystemManager"
               class="org.apache.avalon.phoenix.components.manager.NoopSystemManager"
               logger="manager"></component>
  +-->
   
  +        <component role="org.apache.avalon.phoenix.interfaces.SystemManager"
  +            class="org.apache.avalon.phoenix.components.manager.DefaultManager"
  +            logger="manager" >
  +        </component>
           <!-- use this one if you need the DefaultManager
           <component role="org.apache.avalon.phoenix.interfaces.SystemManager"
               class="org.apache.avalon.phoenix.components.manager.DefaultManager"
  
  
  
  1.4       +3 -3      jakarta-avalon-phoenix/src/java/org/apache/avalon/phoenix/components/application/AppLifecycleHelper.java
  
  Index: AppLifecycleHelper.java
  ===================================================================
  RCS file: /home/cvs/jakarta-avalon-phoenix/src/java/org/apache/avalon/phoenix/components/application/AppLifecycleHelper.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -r1.3 -r1.4
  --- AppLifecycleHelper.java	19 May 2002 02:44:33 -0000	1.3
  +++ AppLifecycleHelper.java	19 May 2002 02:46:43 -0000	1.4
  @@ -43,8 +43,8 @@
       /**
        * Object to support notification of ApplicationListeners.
        */
  -    private ApplicationListenerSupport m_listenerSupport =
  -        new ApplicationListenerSupport();
  +    private ListenerSupport m_listenerSupport =
  +        new ListenerSupport();
   
       private final LifecycleHelper m_lifecycleHelper = new LifecycleHelper();
       private final ExportHelper m_exportHelper = new ExportHelper();
  @@ -128,7 +128,7 @@
           }
       }
   
  -    ApplicationListenerSupport getAppListenerSupport()
  +    ListenerSupport getAppListenerSupport()
       {
           return m_listenerSupport;
       }
  
  
  
  1.1                  jakarta-avalon-phoenix/src/java/org/apache/avalon/phoenix/components/application/ListenerSupport.java
  
  Index: ListenerSupport.java
  ===================================================================
  /*
   * Copyright (C) The Apache Software Foundation. All rights reserved.
   *
   * This software is published under the terms of the Apache Software License
   * version 1.1, a copy of which has been included  with this distribution in
   * the LICENSE.txt file.
   */
  package org.apache.avalon.phoenix.components.application;
  
  import org.apache.avalon.phoenix.ApplicationEvent;
  import org.apache.avalon.phoenix.ApplicationListener;
  import org.apache.avalon.phoenix.BlockEvent;
  import org.apache.avalon.phoenix.BlockListener;
  import org.apache.avalon.phoenix.metadata.SarMetaData;
  import org.apache.avalon.phoenix.metadata.BlockMetaData;
  
  /**
   * Manage a set of <code>ApplicationListener</code> objects and propogate
   * <code>ApplicationEvent</code> notifications to these listeners.  Not all
   * events pass an Applicationevent parameter.
   *
   * @author <a href="mailto:peter@apache.org">Peter Donald</a>
   * @author <a href="mailto:Paul_Hammant@yahoo.com">Paul Hammant</a>
   */
  final class ListenerSupport
  {
      //Set of block listeners. Must be accessed from synchronized code
      private BlockListener[] m_blockListeners = new BlockListener[ 0 ];
  
      //Set of listeners. Must be accessed from synchronized code
      private ApplicationListener[] m_listeners = new ApplicationListener[ 0 ];
  
      /**
       * fire Event indicating that the Application represented
       * by specified metaData is starting.
       *
       * @param metaData the metaData
       */
      void fireApplicationStartingEvent( final SarMetaData metaData )
          throws Exception
      {
          final ApplicationEvent event =
              new ApplicationEvent( metaData.getName(), metaData );
          applicationStarting( event );
      }
  
      /**
       * fire Event indicating that Block represented by
       * specific entry has been added.
       *
       * @param entry the entry
       */
      void fireBlockAddedEvent( final BlockEntry entry )
      {
          blockAdded( createEvent( entry ) );
      }
  
      /**
       * fire Event indicating that Block represented by
       * specific entry is being removed.
       *
       * @param entry the entry
       */
      void fireBlockRemovedEvent( final BlockEntry entry )
      {
          blockRemoved( createEvent( entry ) );
      }
  
      /**
       * Utility method to create an event for a
       * specific entry.
       *
       * @param entry the entry
       * @return the new event
       */
      private BlockEvent createEvent( final BlockEntry entry )
      {
          final BlockMetaData metaData = entry.getMetaData();
          final BlockEvent event =
              new BlockEvent( metaData.getName(),
                              entry.getProxy(),
                              metaData.getBlockInfo() );
          return event;
      }
  
      /**
       * Add a ApplicationListener to those requiring notification of
       * <code>ApplicationEvent</code>s.
       *
       * @param listener the ApplicationListener
       */
      public synchronized void addApplicationListener( final ApplicationListener listener
)
      {
          final ApplicationListener[] listeners = new ApplicationListener[ 1 + m_listeners.length
];
          System.arraycopy( m_listeners, 0, listeners, 0, m_listeners.length );
          listeners[ m_listeners.length ] = listener;
          m_listeners = listeners;
      }
  
      /**
       * Remove a ApplicationListener from those requiring notification of
       * <code>ApplicationEvent</code>s.
       *
       * @param listener the ApplicationListener
       */
      public synchronized void removeApplicationListener( final ApplicationListener listener
)
      {
          int index = 0;
          while( index < m_listeners.length )
          {
              if( m_listeners[ index ] == listener ) break;
              index++;
          }
  
          if( m_listeners.length != index )
          {
              final ApplicationListener[] listeners = new ApplicationListener[ m_listeners.length
- 1 ];
              System.arraycopy( m_listeners, 0, listeners, 0, index );
              final int length = m_listeners.length - index - 1;
              System.arraycopy( m_listeners, index + 1, listeners, index, length );
          }
      }
  
  
      /**
       * Add a BlockListener to those requiring notification of
       * <code>BlockEvent</code>s.
       *
       * @param listener the BlockListener
       */
      public synchronized void addBlockListener( final BlockListener listener )
      {
          final BlockListener[] listeners = new BlockListener[ 1 + m_blockListeners.length
];
          System.arraycopy( m_blockListeners, 0, listeners, 0, m_blockListeners.length );
          listeners[ m_listeners.length ] = listener;
          m_blockListeners = listeners;
      }
  
      /**
       * Remove a BlockListener from those requiring notification of
       * <code>BlockEvent</code>s.
       *
       * @param listener the BlockListener
       */
      public synchronized void removeBlockListener( final BlockListener listener )
      {
          int index = 0;
          while( index < m_blockListeners.length )
          {
              if( m_blockListeners[ index ] == listener ) break;
              index++;
          }
  
          if( m_blockListeners.length != index )
          {
              final BlockListener[] listeners = new BlockListener[ m_blockListeners.length
- 1 ];
              System.arraycopy( m_blockListeners, 0, listeners, 0, index );
              final int length = m_blockListeners.length - index - 1;
              System.arraycopy( m_blockListeners, index + 1, listeners, index, length );
          }
      }
  
  
      /**
       * Notification that the application is starting
       *
       * @param event the ApplicationEvent
       */
      public synchronized void applicationStarting( final ApplicationEvent event )
          throws Exception
      {
          for( int i = 0; i < m_listeners.length; i++ )
          {
              m_listeners[ i ].applicationStarting( event );
          }
      }
  
      /**
       * Notification that the application has started.
       *
       */
      public synchronized void applicationStarted()
      {
          for( int i = 0; i < m_listeners.length; i++ )
          {
              m_listeners[ i ].applicationStarted();
          }
      }
  
      /**
       * Notification that the application is stopping
       *
       */
      public synchronized void applicationStopping()
      {
          for( int i = 0; i < m_listeners.length; i++ )
          {
              m_listeners[ i ].applicationStopping();
          }
      }
  
      /**
       * Notification that the application has stopped
       *
       */
      public synchronized void applicationStopped()
      {
          for( int i = 0; i < m_listeners.length; i++ )
          {
              m_listeners[ i ].applicationStopped();
          }
      }
  
      /**
       * Notification that the application has failed
       *
       */
      public synchronized void applicationFailure( Exception causeOfFailure )
      {
          for( int i = 0; i < m_listeners.length; i++ )
          {
              m_listeners[ i ].applicationFailure( causeOfFailure );
          }
      }
  
      /**
       * Notification that a block has just been added
       * to Server Application.
       *
       * @param event the BlockEvent
       */
      public synchronized void blockAdded( final BlockEvent event )
      {
          for( int i = 0; i < m_listeners.length; i++ )
          {
              m_listeners[ i ].blockAdded( event );
          }
  
          //Now notify the plain BlockListeners
          for( int i = 0; i < m_blockListeners.length; i++ )
          {
              m_blockListeners[ i ].blockAdded( event );
          }
      }
  
      /**
       * Notification that a block is just about to be
       * removed from Server Application.
       *
       * @param event the BlockEvent
       */
      public synchronized void blockRemoved( final BlockEvent event )
      {
          for( int i = 0; i < m_listeners.length; i++ )
          {
              m_listeners[ i ].blockRemoved( event );
          }
  
          //Now notify the plain BlockListeners
          for( int i = 0; i < m_blockListeners.length; i++ )
          {
              m_blockListeners[ i ].blockRemoved( event );
          }
      }
  }
  
  
  

--
To unsubscribe, e-mail:   <mailto:avalon-cvs-unsubscribe@jakarta.apache.org>
For additional commands, e-mail: <mailto:avalon-cvs-help@jakarta.apache.org>


Mime
View raw message