directory-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akaras...@apache.org
Subject svn commit: rev 22420 - incubator/directory/eve/branches/consolidation/frontend/src/java/org/apache/eve/decoder/impl
Date Thu, 01 Jul 2004 14:25:20 GMT
Author: akarasulu
Date: Thu Jul  1 07:25:18 2004
New Revision: 22420

Modified:
   incubator/directory/eve/branches/consolidation/frontend/src/java/org/apache/eve/decoder/impl/DefaultDecoderManager.java
Log:
some cleanup

Modified: incubator/directory/eve/branches/consolidation/frontend/src/java/org/apache/eve/decoder/impl/DefaultDecoderManager.java
==============================================================================
--- incubator/directory/eve/branches/consolidation/frontend/src/java/org/apache/eve/decoder/impl/DefaultDecoderManager.java
(original)
+++ incubator/directory/eve/branches/consolidation/frontend/src/java/org/apache/eve/decoder/impl/DefaultDecoderManager.java
Thu Jul  1 07:25:18 2004
@@ -77,7 +77,7 @@
      * Creates a instance of the default decoder manager implementation.
      * 
      * @param router the event bus or router component depended upon
-     * @param bp the buffer this decoder depends upon
+     * @param config the stage configuration for this SEDA stage
      */
     public DefaultDecoderManager( EventRouter router, StageConfig config )
     {
@@ -102,9 +102,8 @@
      * Routes the event to the appropriate typed <code>inform()</code> method.
      * 
      * @see org.apache.eve.event.Subscriber#inform(java.util.EventObject)
-     * @see org.apache.eve.event.AbstractSubscriber.inform( 
-     * org.apache.eve.event.Subscriber, java.util.EventObject, 
-     * org.apache.eve.event.SubscriberMonitor ) ;
+     * @see org.apache.eve.event.AbstractSubscriber#inform(
+     * org.apache.eve.event.Subscriber,EventObject);
      */
     public void inform( EventObject event )
     {
@@ -128,7 +127,7 @@
     public void inform( InputEvent event )
     {
         // claim interest and release after asynchronous processing of event
-        ByteBuffer buffer = event.claimInterest( this ) ;
+        event.claimInterest( this ) ;
         enqueue( event ) ;
     }
     
@@ -175,7 +174,6 @@
      */
     public void decodeOccurred( StatefulDecoder decoder, Object decoded )
     {
-        Request req = ( Request ) decoded ;
         ClientKey key = ( ( ClientDecoder ) decoder ).getClientKey() ;
         RequestEvent event = new RequestEvent( this, key, ( Request ) decoded );
         router.publish( event ) ;

Mime
View raw message