Author: akarasulu Date: Fri Jan 7 22:41:35 2005 New Revision: 124638 URL: http://svn.apache.org/viewcvs?view=rev&rev=124638 Log: pkg move from seda to apseda complete Added: incubator/directory/apseda/trunk/src/java/org/apache/apseda/ - copied from r124636, incubator/directory/apseda/trunk/src/java/org/apache/seda/ Removed: incubator/directory/apseda/trunk/src/java/org/apache/seda/ Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/DefaultFrontend.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/DefaultFrontendFactory.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/Frontend.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/FrontendFactory.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/HexDump.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/ResourceException.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPool.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPoolConfig.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPoolMonitor.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPoolMonitorAdapter.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/DefaultBufferPool.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/DefaultBufferPoolConfig.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/LoggingBufferMonitor.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/ClientDecoder.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecodeStageHandler.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecoderManager.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecoderManagerMonitor.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecoderManagerMonitorAdapter.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DefaultDecoderManager.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/ClientEncoder.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/DefaultEncoderManager.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncodeStageHandler.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncoderManager.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncoderManagerMonitor.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncoderManagerMonitorAdapter.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/AbstractSubscriber.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ClientEvent.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ConnectEvent.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ConnectSubscriber.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/DefaultEventRouter.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/DisconnectEvent.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/DisconnectSubscriber.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventFilter.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventRouter.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventRouterMonitor.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventRouterMonitorAdapter.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/GatheringOutputEvent.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/InputEvent.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/InputSubscriber.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/OutputEvent.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/OutputSubscriber.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/RequestEvent.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/RequestSubscriber.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ResponseEvent.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ResponseSubscriber.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/RoutingAdvice.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionCreationEvent.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionCreationSubscriber.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionDestructionEvent.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionDestructionListener.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/Subscriber.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SubscriberMonitor.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/Subscription.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/filter/ClientKeyTypeFilter.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/filter/CompositeEventFilter.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/filter/EventTypeFilter.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/InputManager.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/InputManagerMonitor.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/InputManagerMonitorAdapter.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/TCPInputManager.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/AvailablePortFinder.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ClientKey.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/KeyExpiryException.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerConfig.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerManager.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerManagerMonitor.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerManagerMonitorAdapter.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/SocketListenerConfig.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/TCPClientKey.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/TCPListenerConfig.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/TCPListenerManager.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/UDPClientKey.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/UDPListenerConfig.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/UDPListenerManager.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/LoggingOutputMonitor.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/OutputManager.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/OutputMonitor.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/OutputMonitorAdapter.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/TCPOutputManager.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/UDPOutputManager.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractManyReplyHandler.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractNoReplyHandler.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractRequestHandler.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractSingleReplyHandler.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/DefaultInetServicesDatabase.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/DefaultRequestProcessor.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/HandlerTypeEnum.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/InetServiceEntry.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/InetServicesDatabase.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/ManyReplyHandler.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/NoReplyHandler.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/ProtocolProvider.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestHandler.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestProcessor.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestProcessorMonitor.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestProcessorMonitorAdapter.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/SingleReplyHandler.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/TransportTypeEnum.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/session/ClientSession.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/DefaultStage.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/DefaultStageConfig.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/EnqueuePredicate.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/LoggingStageMonitor.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/Stage.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageConfig.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageHandler.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageMonitor.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageMonitorAdapter.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/AbstractThreadPool.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/OrderedThreadPool.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/RunnableQueue.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/SimpleThreadPool.java incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/ThreadPool.java
Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/DefaultFrontend.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/DefaultFrontend.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/DefaultFrontend.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/DefaultFrontend.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/DefaultFrontend.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/DefaultFrontend.java Fri Jan 7 22:41:35 2005 @@ -15,25 +15,35 @@ * */ -package org.apache.seda; +package org.apache.apseda; -import org.apache.seda.buffer.BufferPool; -import org.apache.seda.decoder.DecoderManager; -import org.apache.seda.decoder.DefaultDecoderManager; -import org.apache.seda.encoder.DefaultEncoderManager; -import org.apache.seda.encoder.EncoderManager; -import org.apache.seda.event.EventRouter; -import org.apache.seda.input.InputManager; -import org.apache.seda.input.TCPInputManager; -import org.apache.seda.listener.ListenerManager; -import org.apache.seda.listener.TCPListenerManager; -import org.apache.seda.listener.UDPListenerManager; -import org.apache.seda.output.OutputManager; -import org.apache.seda.output.TCPOutputManager; -import org.apache.seda.output.UDPOutputManager; -import org.apache.seda.protocol.DefaultRequestProcessor; -import org.apache.seda.protocol.InetServicesDatabase; -import org.apache.seda.protocol.RequestProcessor; +import org.apache.apseda.buffer.BufferPool; +import org.apache.apseda.decoder.DecoderManager; +import org.apache.apseda.decoder.DecoderManager; +import org.apache.apseda.decoder.DefaultDecoderManager; +import org.apache.apseda.encoder.DefaultEncoderManager; +import org.apache.apseda.encoder.EncoderManager; +import org.apache.apseda.encoder.EncoderManager; +import org.apache.apseda.event.EventRouter; +import org.apache.apseda.event.EventRouter; +import org.apache.apseda.input.InputManager; +import org.apache.apseda.input.InputManager; +import org.apache.apseda.input.TCPInputManager; +import org.apache.apseda.input.TCPInputManager; +import org.apache.apseda.listener.TCPListenerManager; +import org.apache.apseda.listener.ListenerManager; +import org.apache.apseda.listener.TCPListenerManager; +import org.apache.apseda.listener.ListenerManager; +import org.apache.apseda.listener.UDPListenerManager; +import org.apache.apseda.output.OutputManager; +import org.apache.apseda.output.TCPOutputManager; +import org.apache.apseda.output.*; +import org.apache.apseda.output.UDPOutputManager; +import org.apache.apseda.protocol.DefaultRequestProcessor; +import org.apache.apseda.protocol.InetServicesDatabase; +import org.apache.apseda.protocol.*; +import org.apache.apseda.protocol.RequestProcessor; +import org.apache.apseda.Frontend; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/DefaultFrontendFactory.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/DefaultFrontendFactory.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/DefaultFrontendFactory.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/DefaultFrontendFactory.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/DefaultFrontendFactory.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/DefaultFrontendFactory.java Fri Jan 7 22:41:35 2005 @@ -15,38 +15,51 @@ * */ -package org.apache.seda; +package org.apache.apseda; import java.io.IOException; -import org.apache.seda.buffer.BufferPool; -import org.apache.seda.buffer.DefaultBufferPool; -import org.apache.seda.buffer.DefaultBufferPoolConfig; -import org.apache.seda.buffer.LoggingBufferMonitor; -import org.apache.seda.decoder.DecodeStageHandler; -import org.apache.seda.decoder.DecoderManager; -import org.apache.seda.decoder.DefaultDecoderManager; -import org.apache.seda.encoder.DefaultEncoderManager; -import org.apache.seda.encoder.EncodeStageHandler; -import org.apache.seda.encoder.EncoderManager; -import org.apache.seda.event.DefaultEventRouter; -import org.apache.seda.event.EventRouter; -import org.apache.seda.event.EventRouterMonitorAdapter; -import org.apache.seda.input.TCPInputManager; -import org.apache.seda.listener.TCPListenerManager; -import org.apache.seda.listener.UDPListenerManager; -import org.apache.seda.output.TCPOutputManager; -import org.apache.seda.output.UDPOutputManager; -import org.apache.seda.protocol.DefaultInetServicesDatabase; -import org.apache.seda.protocol.DefaultRequestProcessor; -import org.apache.seda.protocol.InetServiceEntry; -import org.apache.seda.protocol.InetServicesDatabase; -import org.apache.seda.protocol.RequestProcessor; -import org.apache.seda.stage.DefaultStageConfig; -import org.apache.seda.thread.AbstractThreadPool; -import org.apache.seda.thread.OrderedThreadPool; -import org.apache.seda.thread.SimpleThreadPool; -import org.apache.seda.thread.ThreadPool; +import org.apache.apseda.buffer.BufferPool; +import org.apache.apseda.decoder.DecodeStageHandler; +import org.apache.apseda.decoder.DecoderManager; +import org.apache.apseda.decoder.DefaultDecoderManager; +import org.apache.apseda.encoder.DefaultEncoderManager; +import org.apache.apseda.encoder.EncoderManager; +import org.apache.apseda.encoder.EncodeStageHandler; +import org.apache.apseda.encoder.EncoderManager; +import org.apache.apseda.encoder.EncodeStageHandler; +import org.apache.apseda.event.DefaultEventRouter; +import org.apache.apseda.event.EventRouter; +import org.apache.apseda.event.EventRouterMonitorAdapter; +import org.apache.apseda.input.TCPInputManager; +import org.apache.apseda.listener.TCPListenerManager; +import org.apache.apseda.listener.UDPListenerManager; +import org.apache.apseda.output.TCPOutputManager; +import org.apache.apseda.output.UDPOutputManager; +import org.apache.apseda.protocol.DefaultInetServicesDatabase; +import org.apache.apseda.protocol.DefaultRequestProcessor; +import org.apache.apseda.protocol.DefaultRequestProcessor; +import org.apache.apseda.protocol.InetServiceEntry; +import org.apache.apseda.protocol.InetServiceEntry; +import org.apache.apseda.protocol.InetServicesDatabase; +import org.apache.apseda.protocol.RequestProcessor; +import org.apache.apseda.stage.DefaultStageConfig; +import org.apache.apseda.thread.ThreadPool; +import org.apache.apseda.buffer.LoggingBufferMonitor; +import org.apache.apseda.buffer.DefaultBufferPoolConfig; +import org.apache.apseda.buffer.*; +import org.apache.apseda.decoder.DecoderManager; +import org.apache.apseda.decoder.DefaultDecoderManager; +import org.apache.apseda.event.EventRouter; +import org.apache.apseda.input.TCPInputManager; +import org.apache.apseda.listener.TCPListenerManager; +import org.apache.apseda.listener.UDPListenerManager; +import org.apache.apseda.output.TCPOutputManager; +import org.apache.apseda.output.UDPOutputManager; +import org.apache.apseda.stage.DefaultStageConfig; +import org.apache.apseda.thread.AbstractThreadPool; +import org.apache.apseda.thread.OrderedThreadPool; +import org.apache.apseda.thread.*; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/Frontend.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/Frontend.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/Frontend.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/Frontend.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/Frontend.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/Frontend.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda; +package org.apache.apseda; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/FrontendFactory.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/FrontendFactory.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/FrontendFactory.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/FrontendFactory.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/FrontendFactory.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/FrontendFactory.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda; +package org.apache.apseda; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/HexDump.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/HexDump.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/HexDump.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/HexDump.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/HexDump.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/HexDump.java Fri Jan 7 22:41:35 2005 @@ -14,7 +14,7 @@ * limitations under the License. * */ -package org.apache.seda; +package org.apache.apseda; import java.nio.ByteBuffer; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/ResourceException.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/ResourceException.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/ResourceException.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/ResourceException.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/ResourceException.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/ResourceException.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda; +package org.apache.apseda; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPool.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPool.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/buffer/BufferPool.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPool.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/buffer/BufferPool.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPool.java Fri Jan 7 22:41:35 2005 @@ -15,11 +15,13 @@ * */ -package org.apache.seda.buffer; +package org.apache.apseda.buffer; import java.nio.ByteBuffer; -import org.apache.seda.ResourceException; +import org.apache.apseda.ResourceException; +import org.apache.apseda.buffer.BufferPoolConfig; +import org.apache.apseda.ResourceException; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPoolConfig.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPoolConfig.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/buffer/BufferPoolConfig.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPoolConfig.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/buffer/BufferPoolConfig.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPoolConfig.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.buffer; +package org.apache.apseda.buffer; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPoolMonitor.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPoolMonitor.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/buffer/BufferPoolMonitor.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPoolMonitor.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/buffer/BufferPoolMonitor.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPoolMonitor.java Fri Jan 7 22:41:35 2005 @@ -15,9 +15,11 @@ * */ -package org.apache.seda.buffer; +package org.apache.apseda.buffer; import java.nio.ByteBuffer; + +import org.apache.apseda.buffer.BufferPool; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPoolMonitorAdapter.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPoolMonitorAdapter.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/buffer/BufferPoolMonitorAdapter.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPoolMonitorAdapter.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/buffer/BufferPoolMonitorAdapter.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/BufferPoolMonitorAdapter.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.buffer; +package org.apache.apseda.buffer; import java.nio.ByteBuffer; @@ -30,24 +30,24 @@ public class BufferPoolMonitorAdapter implements BufferPoolMonitor { /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#augmented( - * org.apache.seda.buffer.BufferPool) + * @see org.apache.apseda.buffer.BufferPoolMonitor#augmented( + * org.apache.apseda.buffer.BufferPool) */ public void augmented(BufferPool bp) { } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#bufferTaken( - * org.apache.seda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#bufferTaken( + * org.apache.apseda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) */ public void bufferTaken(BufferPool bp, ByteBuffer buffer, Object taker) { } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#bufferReleased( - * org.apache.seda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#bufferReleased( + * org.apache.apseda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) */ public void bufferReleased( BufferPool bp, ByteBuffer buffer, @@ -56,8 +56,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#interestClaimed( - * org.apache.seda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#interestClaimed( + * org.apache.apseda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) */ public void interestClaimed( BufferPool bp, ByteBuffer buffer, @@ -66,8 +66,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#interestReleased( - * org.apache.seda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#interestReleased( + * org.apache.apseda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) */ public void interestReleased( BufferPool bp, ByteBuffer buffer, @@ -77,8 +77,8 @@ /* * (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#resourceUnavailable( - * org.apache.seda.buffer.BufferPool, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#resourceUnavailable( + * org.apache.apseda.buffer.BufferPool, java.lang.Object) */ public void resourceUnavailable(BufferPool bp, Object party) { @@ -86,8 +86,8 @@ /* * (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#unregisteredParty( - * org.apache.seda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#unregisteredParty( + * org.apache.apseda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) */ public void unregisteredParty( BufferPool bp, ByteBuffer buffer, @@ -97,8 +97,8 @@ /* * (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#nonPooledBuffer( - * org.apache.seda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#nonPooledBuffer( + * org.apache.apseda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) */ public void nonPooledBuffer( BufferPool bp, ByteBuffer buffer, Object party) @@ -106,8 +106,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#releaseOfUnclaimed( - * org.apache.seda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#releaseOfUnclaimed( + * org.apache.apseda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) */ public void releaseOfUnclaimed( BufferPool bp, ByteBuffer buffer, Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/DefaultBufferPool.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/DefaultBufferPool.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/buffer/DefaultBufferPool.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/DefaultBufferPool.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/buffer/DefaultBufferPool.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/DefaultBufferPool.java Fri Jan 7 22:41:35 2005 @@ -15,13 +15,15 @@ * */ -package org.apache.seda.buffer; +package org.apache.apseda.buffer; import java.nio.ByteBuffer; import java.util.ArrayList; -import org.apache.seda.ResourceException; +import org.apache.apseda.ResourceException; +import org.apache.apseda.buffer.BufferPoolMonitorAdapter; +import org.apache.apseda.buffer.BufferPoolConfig; /** @@ -71,7 +73,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPool#getBuffer(java.lang.Object) + * @see org.apache.apseda.buffer.BufferPool#getBuffer(java.lang.Object) */ public synchronized ByteBuffer getBuffer(Object party) throws ResourceException @@ -108,7 +110,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPool#claimInterest(java.nio.ByteBuffer, + * @see org.apache.apseda.buffer.BufferPool#claimInterest(java.nio.ByteBuffer, * java.lang.Object) */ public synchronized void claimInterest(ByteBuffer buffer, Object party) @@ -126,7 +128,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPool#releaseClaim(java.nio.ByteBuffer, + * @see org.apache.apseda.buffer.BufferPool#releaseClaim(java.nio.ByteBuffer, * java.lang.Object) */ public synchronized void releaseClaim(ByteBuffer buffer, Object party) @@ -159,7 +161,7 @@ /* * (non-Javadoc) - * @see org.apache.seda.buffer.BufferPool#getConfig() + * @see org.apache.apseda.buffer.BufferPool#getConfig() */ public BufferPoolConfig getConfig() { @@ -167,7 +169,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPool#size() + * @see org.apache.apseda.buffer.BufferPool#size() */ public synchronized int size() { @@ -175,7 +177,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPool#getName() + * @see org.apache.apseda.buffer.BufferPool#getName() */ public String getName() { @@ -183,7 +185,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPool#getFreeCount() + * @see org.apache.apseda.buffer.BufferPool#getFreeCount() */ public synchronized int getFreeCount() { @@ -191,7 +193,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPool#getInUseCount() + * @see org.apache.apseda.buffer.BufferPool#getInUseCount() */ public synchronized int getInUseCount() { @@ -199,7 +201,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPool#getInterestedCount( + * @see org.apache.apseda.buffer.BufferPool#getInterestedCount( * java.nio.ByteBuffer) */ public int getInterestedCount(ByteBuffer buffer) Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/DefaultBufferPoolConfig.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/DefaultBufferPoolConfig.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/buffer/DefaultBufferPoolConfig.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/DefaultBufferPoolConfig.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/buffer/DefaultBufferPoolConfig.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/DefaultBufferPoolConfig.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,10 @@ * */ -package org.apache.seda.buffer; +package org.apache.apseda.buffer; + + +import org.apache.apseda.buffer.BufferPoolConfig; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/LoggingBufferMonitor.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/LoggingBufferMonitor.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/buffer/LoggingBufferMonitor.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/LoggingBufferMonitor.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/buffer/LoggingBufferMonitor.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/buffer/LoggingBufferMonitor.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.buffer; +package org.apache.apseda.buffer; import java.nio.ByteBuffer; @@ -56,8 +56,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor# - * augmented(org.apache.seda.buffer.BufferPool) + * @see org.apache.apseda.buffer.BufferPoolMonitor# + * augmented(org.apache.apseda.buffer.BufferPool) */ public void augmented(BufferPool bp) { @@ -68,8 +68,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#bufferReleased( - * org.apache.seda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#bufferReleased( + * org.apache.apseda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) */ public void bufferReleased( BufferPool bp, ByteBuffer buffer, @@ -82,8 +82,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#bufferTaken( - * org.apache.seda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#bufferTaken( + * org.apache.apseda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) */ public void bufferTaken(BufferPool bp, ByteBuffer buffer, Object taker) { @@ -94,8 +94,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#interestClaimed( - * org.apache.seda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#interestClaimed( + * org.apache.apseda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) */ public void interestClaimed( BufferPool bp, ByteBuffer buffer, @@ -109,8 +109,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#interestReleased( - * org.apache.seda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#interestReleased( + * org.apache.apseda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) */ public void interestReleased( BufferPool bp, ByteBuffer buffer, @@ -124,8 +124,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#nonPooledBuffer( - * org.apache.seda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#nonPooledBuffer( + * org.apache.apseda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) */ public void nonPooledBuffer( BufferPool bp, ByteBuffer buffer, Object party) @@ -139,8 +139,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#resourceUnavailable( - * org.apache.seda.buffer.BufferPool, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#resourceUnavailable( + * org.apache.apseda.buffer.BufferPool, java.lang.Object) */ public void resourceUnavailable(BufferPool bp, Object party) { @@ -153,8 +153,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#unregisteredParty( - * org.apache.seda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#unregisteredParty( + * org.apache.apseda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) */ public void unregisteredParty( BufferPool bp, ByteBuffer buffer, @@ -168,8 +168,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.buffer.BufferPoolMonitor#releaseOfUnclaimed( - * org.apache.seda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) + * @see org.apache.apseda.buffer.BufferPoolMonitor#releaseOfUnclaimed( + * org.apache.apseda.buffer.BufferPool, java.nio.ByteBuffer, java.lang.Object) */ public void releaseOfUnclaimed( BufferPool bp, ByteBuffer buffer, Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/ClientDecoder.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/ClientDecoder.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/decoder/ClientDecoder.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/ClientDecoder.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/decoder/ClientDecoder.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/ClientDecoder.java Fri Jan 7 22:41:35 2005 @@ -15,15 +15,16 @@ * */ -package org.apache.seda.decoder; +package org.apache.apseda.decoder; import org.apache.asn1.codec.DecoderException; import org.apache.asn1.codec.stateful.DecoderCallback; import org.apache.asn1.codec.stateful.DecoderMonitor; import org.apache.asn1.codec.stateful.StatefulDecoder; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; import org.apache.asn1.codec.stateful.DecoderCallback; import org.apache.asn1.codec.stateful.StatefulDecoder; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecodeStageHandler.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecodeStageHandler.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/decoder/DecodeStageHandler.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecodeStageHandler.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/decoder/DecodeStageHandler.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecodeStageHandler.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.decoder; +package org.apache.apseda.decoder; import java.nio.ByteBuffer; @@ -23,10 +23,12 @@ import org.apache.asn1.codec.DecoderException; import org.apache.asn1.codec.stateful.StatefulDecoder; -import org.apache.seda.event.InputEvent; -import org.apache.seda.listener.ClientKey; -import org.apache.seda.stage.StageHandler; +import org.apache.apseda.event.InputEvent; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.stage.StageHandler; import org.apache.asn1.codec.stateful.StatefulDecoder; +import org.apache.apseda.event.InputEvent; +import org.apache.apseda.listener.ClientKey; /** @@ -56,7 +58,7 @@ * stateful decoder. The decoder's decodeNonBlocking method is called and * control is returned. Error handling is left upto the decoder's monitor. * - * @see org.apache.seda.stage.StageHandler#handleEvent(java.util.EventObject) + * @see org.apache.apseda.stage.StageHandler#handleEvent(java.util.EventObject) */ public void handleEvent(EventObject event) { Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecoderManager.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecoderManager.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/decoder/DecoderManager.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecoderManager.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/decoder/DecoderManager.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecoderManager.java Fri Jan 7 22:41:35 2005 @@ -15,13 +15,14 @@ * */ -package org.apache.seda.decoder; +package org.apache.apseda.decoder; import java.nio.ByteBuffer; import org.apache.asn1.codec.DecoderException; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; import org.apache.asn1.codec.DecoderException; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecoderManagerMonitor.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecoderManagerMonitor.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/decoder/DecoderManagerMonitor.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecoderManagerMonitor.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/decoder/DecoderManagerMonitor.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecoderManagerMonitor.java Fri Jan 7 22:41:35 2005 @@ -15,11 +15,12 @@ * */ -package org.apache.seda.decoder; +package org.apache.apseda.decoder; import java.util.EventObject; -import org.apache.seda.event.Subscriber; +import org.apache.apseda.event.Subscriber; +import org.apache.apseda.event.Subscriber; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecoderManagerMonitorAdapter.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecoderManagerMonitorAdapter.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/decoder/DecoderManagerMonitorAdapter.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecoderManagerMonitorAdapter.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/decoder/DecoderManagerMonitorAdapter.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DecoderManagerMonitorAdapter.java Fri Jan 7 22:41:35 2005 @@ -15,11 +15,12 @@ * */ -package org.apache.seda.decoder; +package org.apache.apseda.decoder; import java.util.EventObject; -import org.apache.seda.event.Subscriber; +import org.apache.apseda.event.Subscriber; +import org.apache.apseda.decoder.DecoderManagerMonitor; /** @@ -32,8 +33,8 @@ public class DecoderManagerMonitorAdapter implements DecoderManagerMonitor { /* (non-Javadoc) - * @see org.apache.seda.event.SubscriberMonitor#failedOnInform( - * org.apache.seda.event.Subscriber, + * @see org.apache.apseda.event.SubscriberMonitor#failedOnInform( + * org.apache.apseda.event.Subscriber, * java.util.EventObject, java.lang.Throwable) */ public void failedOnInform( Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DefaultDecoderManager.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DefaultDecoderManager.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/decoder/DefaultDecoderManager.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DefaultDecoderManager.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/decoder/DefaultDecoderManager.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/decoder/DefaultDecoderManager.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.decoder; +package org.apache.apseda.decoder; import java.nio.ByteBuffer; import java.util.EventObject; @@ -28,23 +28,28 @@ import org.apache.asn1.codec.stateful.StatefulDecoder; import org.apache.asn1.codec.stateful.StatefulDecoder; import org.apache.asn1.codec.DecoderException; -import org.apache.seda.event.AbstractSubscriber; -import org.apache.seda.event.DisconnectEvent; -import org.apache.seda.event.DisconnectSubscriber; -import org.apache.seda.event.EventRouter; -import org.apache.seda.event.InputEvent; -import org.apache.seda.event.InputSubscriber; -import org.apache.seda.event.RequestEvent; +import org.apache.apseda.event.AbstractSubscriber; +import org.apache.apseda.event.DisconnectEvent; +import org.apache.apseda.event.EventRouter; +import org.apache.apseda.event.DisconnectSubscriber; +import org.apache.apseda.event.InputSubscriber; +import org.apache.apseda.event.*; import org.apache.seda.event.filter.EventTypeFilter; -import org.apache.seda.listener.ClientKey; -import org.apache.seda.listener.UDPClientKey; -import org.apache.seda.protocol.InetServiceEntry; -import org.apache.seda.protocol.InetServicesDatabase; -import org.apache.seda.protocol.ProtocolProvider; -import org.apache.seda.protocol.TransportTypeEnum; -import org.apache.seda.stage.DefaultStage; -import org.apache.seda.stage.LoggingStageMonitor; -import org.apache.seda.stage.StageConfig; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.UDPClientKey; +import org.apache.apseda.protocol.TransportTypeEnum; +import org.apache.apseda.stage.StageConfig; +import org.apache.apseda.decoder.ClientDecoder; +import org.apache.apseda.decoder.DecoderManager; +import org.apache.apseda.decoder.DecoderManagerMonitor; +import org.apache.apseda.decoder.DecoderManagerMonitorAdapter; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.UDPClientKey; +import org.apache.apseda.protocol.InetServiceEntry; +import org.apache.apseda.protocol.*; +import org.apache.apseda.stage.DefaultStage; +import org.apache.apseda.stage.LoggingStageMonitor; +import org.apache.apseda.stage.*; /** @@ -54,8 +59,8 @@ * @version $Rev$ */ public class DefaultDecoderManager extends DefaultStage - implements DecoderManager, InputSubscriber, - DisconnectSubscriber + implements DecoderManager, InputSubscriber, + DisconnectSubscriber { /** event router or bus this component subscribes and publishes events on */ private final EventRouter router; @@ -97,9 +102,9 @@ /** * Routes the event to the appropriate typed <code>inform()</code> method. * - * @see org.apache.seda.event.Subscriber#inform(java.util.EventObject) - * @see org.apache.seda.event.AbstractSubscriber#inform( - * org.apache.seda.event.Subscriber, java.util.EventObject) + * @see org.apache.apseda.event.Subscriber#inform(java.util.EventObject) + * @see org.apache.apseda.event.AbstractSubscriber#inform( + * org.apache.apseda.event.Subscriber, java.util.EventObject) */ public void inform(EventObject event) { @@ -116,8 +121,8 @@ /** * Enqueues the event onto this Stages event queue for processing. * - * @see org.apache.seda.event.InputSubscriber#inform( - * org.apache.seda.event.InputEvent) + * @see org.apache.apseda.event.InputSubscriber#inform( + * org.apache.apseda.event.InputEvent) */ public void inform(InputEvent event) { @@ -129,8 +134,8 @@ /** * Removes the clients decoder from the map of decoders. * - * @see org.apache.seda.event.DisconnectSubscriber#inform( - * org.apache.seda.event.DisconnectEvent) + * @see org.apache.apseda.event.DisconnectSubscriber#inform( + * org.apache.apseda.event.DisconnectEvent) */ public void inform(DisconnectEvent event) { @@ -142,8 +147,8 @@ // ------------------------------------------------------------------------ /* (non-Javadoc) - * @see org.apache.seda.decoder.DecoderManager#decodeNonBlocking( - * org.apache.seda.listener.ClientKey, java.nio.ByteBuffer) + * @see org.apache.apseda.decoder.DecoderManager#decodeNonBlocking( + * org.apache.apseda.listener.ClientKey, java.nio.ByteBuffer) */ public void decodeNonBlocking(ClientKey key, ByteBuffer buffer) throws DecoderException @@ -153,7 +158,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.decoder.DecoderManager# + * @see org.apache.apseda.decoder.DecoderManager# * decodeNonBlocking(java.nio.ByteBuffer) */ public Object decodeBlocking(ClientKey key, ByteBuffer buffer) Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/ClientEncoder.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/ClientEncoder.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/encoder/ClientEncoder.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/ClientEncoder.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/encoder/ClientEncoder.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/ClientEncoder.java Fri Jan 7 22:41:35 2005 @@ -15,14 +15,15 @@ * */ -package org.apache.seda.encoder; +package org.apache.apseda.encoder; import org.apache.asn1.codec.EncoderException; import org.apache.asn1.codec.stateful.StatefulEncoder; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; import org.apache.asn1.codec.stateful.EncoderCallback; import org.apache.asn1.codec.stateful.EncoderMonitor; import org.apache.asn1.codec.stateful.*; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/DefaultEncoderManager.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/DefaultEncoderManager.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/encoder/DefaultEncoderManager.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/DefaultEncoderManager.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/encoder/DefaultEncoderManager.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/DefaultEncoderManager.java Fri Jan 7 22:41:35 2005 @@ -14,7 +14,7 @@ * limitations under the License. * */ -package org.apache.seda.encoder; +package org.apache.apseda.encoder; import java.nio.ByteBuffer; @@ -24,28 +24,32 @@ import org.apache.asn1.codec.EncoderException; import org.apache.asn1.codec.stateful.StatefulEncoder; -import org.apache.seda.event.AbstractSubscriber; -import org.apache.seda.event.DisconnectEvent; -import org.apache.seda.event.DisconnectSubscriber; -import org.apache.seda.event.EventRouter; -import org.apache.seda.event.GatheringOutputEvent; -import org.apache.seda.event.OutputEvent; -import org.apache.seda.event.ResponseEvent; -import org.apache.seda.event.ResponseSubscriber; +import org.apache.apseda.event.AbstractSubscriber; +import org.apache.apseda.event.DisconnectEvent; +import org.apache.apseda.event.EventRouter; +import org.apache.apseda.event.DisconnectSubscriber; +import org.apache.apseda.event.*; +import org.apache.apseda.event.ResponseEvent; +import org.apache.apseda.event.ResponseSubscriber; import org.apache.seda.event.filter.EventTypeFilter; -import org.apache.seda.listener.ClientKey; -import org.apache.seda.listener.UDPClientKey; -import org.apache.seda.protocol.InetServiceEntry; -import org.apache.seda.protocol.InetServicesDatabase; -import org.apache.seda.protocol.ProtocolProvider; -import org.apache.seda.protocol.TransportTypeEnum; -import org.apache.seda.stage.DefaultStage; -import org.apache.seda.stage.LoggingStageMonitor; -import org.apache.seda.stage.StageConfig; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.UDPClientKey; +import org.apache.apseda.protocol.ProtocolProvider; +import org.apache.apseda.protocol.TransportTypeEnum; +import org.apache.apseda.stage.DefaultStage; +import org.apache.apseda.stage.LoggingStageMonitor; +import org.apache.apseda.stage.LoggingStageMonitor; +import org.apache.apseda.stage.StageConfig; +import org.apache.apseda.stage.StageConfig; import org.apache.asn1.codec.stateful.EncoderCallback; import org.apache.asn1.codec.stateful.EncoderFactory; import org.apache.asn1.codec.stateful.*; import org.apache.asn1.codec.EncoderException; +import org.apache.apseda.encoder.ClientEncoder; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.protocol.InetServiceEntry; +import org.apache.apseda.protocol.InetServicesDatabase; +import org.apache.apseda.protocol.*; /** @@ -91,7 +95,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.event.Subscriber#inform(java.util.EventObject) + * @see org.apache.apseda.event.Subscriber#inform(java.util.EventObject) */ public void inform(EventObject event) { @@ -108,8 +112,8 @@ /** * Removes the clients encoder from the map of encoders. * - * @see org.apache.seda.event.DisconnectSubscriber#inform( - * org.apache.seda.event.DisconnectEvent) + * @see org.apache.apseda.event.DisconnectSubscriber#inform( + * org.apache.apseda.event.DisconnectEvent) */ public void inform(DisconnectEvent event) { @@ -117,8 +121,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.event.ResponseSubscriber#inform( - * org.apache.seda.event.ResponseEvent) + * @see org.apache.apseda.event.ResponseSubscriber#inform( + * org.apache.apseda.event.ResponseEvent) */ public void inform(ResponseEvent event) { @@ -244,8 +248,8 @@ * We basically create a new client encoder and put it into a map for * use later when we are processing response events from the client. * - * @see org.apache.seda.event.ConnectSubscriber#inform( - * org.apache.seda.event.ConnectEvent) + * @see org.apache.apseda.event.ConnectSubscriber#inform( + * org.apache.apseda.event.ConnectEvent) */ private StatefulEncoder createClientEncoder(ClientKey key) { Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncodeStageHandler.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncodeStageHandler.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/encoder/EncodeStageHandler.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncodeStageHandler.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/encoder/EncodeStageHandler.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncodeStageHandler.java Fri Jan 7 22:41:35 2005 @@ -15,17 +15,20 @@ * */ -package org.apache.seda.encoder; +package org.apache.apseda.encoder; import java.util.EventObject; import org.apache.asn1.codec.EncoderException; import org.apache.asn1.codec.stateful.StatefulEncoder; -import org.apache.seda.event.ResponseEvent; -import org.apache.seda.listener.ClientKey; -import org.apache.seda.stage.StageHandler; +import org.apache.apseda.event.ResponseEvent; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.stage.StageHandler; import org.apache.asn1.codec.stateful.StatefulEncoder; import org.apache.asn1.codec.EncoderException; +import org.apache.apseda.encoder.DefaultEncoderManager; +import org.apache.apseda.event.ResponseEvent; +import org.apache.apseda.stage.StageHandler; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncoderManager.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncoderManager.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/encoder/EncoderManager.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncoderManager.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/encoder/EncoderManager.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncoderManager.java Fri Jan 7 22:41:35 2005 @@ -15,12 +15,13 @@ * */ -package org.apache.seda.encoder; +package org.apache.apseda.encoder; import java.nio.ByteBuffer; import org.apache.asn1.codec.EncoderException; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncoderManagerMonitor.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncoderManagerMonitor.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/encoder/EncoderManagerMonitor.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncoderManagerMonitor.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/encoder/EncoderManagerMonitor.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncoderManagerMonitor.java Fri Jan 7 22:41:35 2005 @@ -15,11 +15,12 @@ * */ -package org.apache.seda.encoder; +package org.apache.apseda.encoder; import java.util.EventObject; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.encoder.EncoderManager; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncoderManagerMonitorAdapter.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncoderManagerMonitorAdapter.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/encoder/EncoderManagerMonitorAdapter.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncoderManagerMonitorAdapter.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/encoder/EncoderManagerMonitorAdapter.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/encoder/EncoderManagerMonitorAdapter.java Fri Jan 7 22:41:35 2005 @@ -15,11 +15,13 @@ * */ -package org.apache.seda.encoder; +package org.apache.apseda.encoder; import java.util.EventObject; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.encoder.EncoderManager; +import org.apache.apseda.encoder.EncoderManagerMonitor; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/AbstractSubscriber.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/AbstractSubscriber.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/AbstractSubscriber.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/AbstractSubscriber.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/AbstractSubscriber.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/AbstractSubscriber.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; @@ -25,6 +25,9 @@ import java.util.HashMap; import java.util.List; +import org.apache.apseda.event.SubscriberMonitor; +import org.apache.apseda.event.Subscriber; + /** * An abstract Subscriber that calls the provided type-specific inform method @@ -62,7 +65,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.event.Subscriber#inform(java.util.EventObject) + * @see org.apache.apseda.event.Subscriber#inform(java.util.EventObject) */ public void inform(EventObject event) { Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ClientEvent.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ClientEvent.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/ClientEvent.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ClientEvent.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/ClientEvent.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ClientEvent.java Fri Jan 7 22:41:35 2005 @@ -15,11 +15,11 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; import java.util.EventObject; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ConnectEvent.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ConnectEvent.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/ConnectEvent.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ConnectEvent.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/ConnectEvent.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ConnectEvent.java Fri Jan 7 22:41:35 2005 @@ -15,9 +15,9 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ConnectSubscriber.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ConnectSubscriber.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/ConnectSubscriber.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ConnectSubscriber.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/ConnectSubscriber.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ConnectSubscriber.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,10 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; + + +import org.apache.apseda.event.ConnectEvent; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/DefaultEventRouter.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/DefaultEventRouter.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/DefaultEventRouter.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/DefaultEventRouter.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/DefaultEventRouter.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/DefaultEventRouter.java Fri Jan 7 22:41:35 2005 @@ -15,13 +15,15 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; import java.util.ArrayList; import java.util.EventObject; import java.util.Iterator; import java.util.List; +import org.apache.apseda.event.*; + /** * An synchronous implementation of the event router / notification pattern. @@ -54,8 +56,8 @@ } /** - * @see org.apache.seda.event.EventRouter#unsubscribe( - * org.apache.seda.event.Subscriber) + * @see org.apache.apseda.event.EventRouter#unsubscribe( + * org.apache.apseda.event.Subscriber) */ public void unsubscribe(Subscriber subscriber) { @@ -99,7 +101,7 @@ /** * (non-Javadoc) - * @see org.apache.seda.event.EventRouter#publish(java.util.EventObject) + * @see org.apache.apseda.event.EventRouter#publish(java.util.EventObject) */ public void publish(EventObject event) { Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/DisconnectEvent.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/DisconnectEvent.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/DisconnectEvent.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/DisconnectEvent.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/DisconnectEvent.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/DisconnectEvent.java Fri Jan 7 22:41:35 2005 @@ -15,9 +15,10 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.event.ClientEvent; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/DisconnectSubscriber.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/DisconnectSubscriber.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/DisconnectSubscriber.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/DisconnectSubscriber.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/DisconnectSubscriber.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/DisconnectSubscriber.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventFilter.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventFilter.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/EventFilter.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventFilter.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/EventFilter.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventFilter.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; import java.util.EventObject; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventRouter.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventRouter.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/EventRouter.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventRouter.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/EventRouter.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventRouter.java Fri Jan 7 22:41:35 2005 @@ -15,9 +15,13 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; import java.util.EventObject; + +import org.apache.apseda.event.EventFilter; +import org.apache.apseda.event.RoutingAdvice; +import org.apache.apseda.event.Subscriber; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventRouterMonitor.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventRouterMonitor.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/EventRouterMonitor.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventRouterMonitor.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/EventRouterMonitor.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventRouterMonitor.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; import java.util.EventObject; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventRouterMonitorAdapter.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventRouterMonitorAdapter.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/EventRouterMonitorAdapter.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventRouterMonitorAdapter.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/EventRouterMonitorAdapter.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/EventRouterMonitorAdapter.java Fri Jan 7 22:41:35 2005 @@ -15,9 +15,12 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; import java.util.EventObject; + +import org.apache.apseda.event.EventRouterMonitor; +import org.apache.apseda.event.Subscription; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/GatheringOutputEvent.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/GatheringOutputEvent.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/GatheringOutputEvent.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/GatheringOutputEvent.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/GatheringOutputEvent.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/GatheringOutputEvent.java Fri Jan 7 22:41:35 2005 @@ -14,11 +14,13 @@ * limitations under the License. * */ -package org.apache.seda.event; +package org.apache.apseda.event; import java.nio.ByteBuffer; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.event.ClientEvent; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/InputEvent.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/InputEvent.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/InputEvent.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/InputEvent.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/InputEvent.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/InputEvent.java Fri Jan 7 22:41:35 2005 @@ -15,11 +15,13 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; import java.nio.ByteBuffer; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.event.ClientEvent; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/InputSubscriber.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/InputSubscriber.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/InputSubscriber.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/InputSubscriber.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/InputSubscriber.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/InputSubscriber.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,11 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; + + +import org.apache.apseda.event.InputEvent; +import org.apache.apseda.event.Subscriber; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/OutputEvent.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/OutputEvent.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/OutputEvent.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/OutputEvent.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/OutputEvent.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/OutputEvent.java Fri Jan 7 22:41:35 2005 @@ -15,11 +15,12 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; import java.nio.ByteBuffer; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.event.ClientEvent; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/OutputSubscriber.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/OutputSubscriber.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/OutputSubscriber.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/OutputSubscriber.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/OutputSubscriber.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/OutputSubscriber.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,10 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; + + +import org.apache.apseda.event.OutputEvent; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/RequestEvent.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/RequestEvent.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/RequestEvent.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/RequestEvent.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/RequestEvent.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/RequestEvent.java Fri Jan 7 22:41:35 2005 @@ -15,9 +15,11 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.event.ClientEvent; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/RequestSubscriber.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/RequestSubscriber.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/RequestSubscriber.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/RequestSubscriber.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/RequestSubscriber.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/RequestSubscriber.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,10 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; + + +import org.apache.apseda.event.RequestEvent; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ResponseEvent.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ResponseEvent.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/ResponseEvent.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ResponseEvent.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/ResponseEvent.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ResponseEvent.java Fri Jan 7 22:41:35 2005 @@ -15,9 +15,11 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.event.ClientEvent; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ResponseSubscriber.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ResponseSubscriber.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/ResponseSubscriber.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ResponseSubscriber.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/ResponseSubscriber.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/ResponseSubscriber.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,11 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; + + +import org.apache.apseda.event.Subscriber; +import org.apache.apseda.event.ResponseEvent; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/RoutingAdvice.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/RoutingAdvice.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/RoutingAdvice.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/RoutingAdvice.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/RoutingAdvice.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/RoutingAdvice.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; import java.util.EventObject; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionCreationEvent.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionCreationEvent.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/SessionCreationEvent.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionCreationEvent.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/SessionCreationEvent.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionCreationEvent.java Fri Jan 7 22:41:35 2005 @@ -15,9 +15,9 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; -import org.apache.seda.session.ClientSession; +import org.apache.apseda.session.ClientSession; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionCreationSubscriber.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionCreationSubscriber.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/SessionCreationSubscriber.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionCreationSubscriber.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/SessionCreationSubscriber.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionCreationSubscriber.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,11 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; + + +import org.apache.apseda.event.SessionCreationEvent; +import org.apache.apseda.event.Subscriber; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionDestructionEvent.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionDestructionEvent.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/SessionDestructionEvent.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionDestructionEvent.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/SessionDestructionEvent.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionDestructionEvent.java Fri Jan 7 22:41:35 2005 @@ -15,9 +15,11 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; -import org.apache.seda.session.ClientSession; +import org.apache.apseda.session.ClientSession; +import org.apache.apseda.event.ClientEvent; +import org.apache.apseda.session.ClientSession; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionDestructionListener.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionDestructionListener.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/SessionDestructionListener.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionDestructionListener.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/SessionDestructionListener.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SessionDestructionListener.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/Subscriber.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/Subscriber.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/Subscriber.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/Subscriber.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/Subscriber.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/Subscriber.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; import java.util.EventListener; import java.util.EventObject; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SubscriberMonitor.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SubscriberMonitor.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/SubscriberMonitor.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SubscriberMonitor.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/SubscriberMonitor.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/SubscriberMonitor.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; import java.util.EventObject; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/Subscription.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/Subscription.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/Subscription.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/Subscription.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/Subscription.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/Subscription.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,11 @@ * */ -package org.apache.seda.event; +package org.apache.apseda.event; + + +import org.apache.apseda.event.EventFilter; +import org.apache.apseda.event.Subscriber; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/filter/ClientKeyTypeFilter.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/filter/ClientKeyTypeFilter.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/filter/ClientKeyTypeFilter.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/filter/ClientKeyTypeFilter.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/filter/ClientKeyTypeFilter.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/filter/ClientKeyTypeFilter.java Fri Jan 7 22:41:35 2005 @@ -18,13 +18,14 @@ import java.util.EventObject; -import org.apache.seda.event.ClientEvent; -import org.apache.seda.event.EventFilter; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.event.ClientEvent; +import org.apache.apseda.event.EventFilter; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; /** * An [EMAIL PROTECTED] EventFilter} which accepts only the [EMAIL PROTECTED] ClientEvent}s - * whose [EMAIL PROTECTED] ClientKey}'s type matches. + * whose [EMAIL PROTECTED] org.apache.apseda.listener.ClientKey}'s type matches. * * @author Trustin Lee ([EMAIL PROTECTED]) * @version $Rev$, $Date: 2004-11-01 09:45:13 -0500 (Mon, 01 Nov 2004) $ Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/filter/CompositeEventFilter.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/filter/CompositeEventFilter.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/filter/CompositeEventFilter.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/filter/CompositeEventFilter.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/filter/CompositeEventFilter.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/filter/CompositeEventFilter.java Fri Jan 7 22:41:35 2005 @@ -18,7 +18,8 @@ import java.util.EventObject; -import org.apache.seda.event.EventFilter; +import org.apache.apseda.event.EventFilter; +import org.apache.apseda.event.EventFilter; /** * An [EMAIL PROTECTED] EventFilter} which performs AND/OR operations on two or more [EMAIL PROTECTED] EventFilter}s. Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/filter/EventTypeFilter.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/filter/EventTypeFilter.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/event/filter/EventTypeFilter.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/filter/EventTypeFilter.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/event/filter/EventTypeFilter.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/event/filter/EventTypeFilter.java Fri Jan 7 22:41:35 2005 @@ -18,10 +18,10 @@ import java.util.EventObject; -import org.apache.seda.event.EventFilter; +import org.apache.apseda.event.EventFilter; /** - * An [EMAIL PROTECTED] EventFilter} which accepts the only events of the specific class. + * An [EMAIL PROTECTED] org.apache.apseda.event.EventFilter} which accepts the only events of the specific class. * * @author Trustin Lee ([EMAIL PROTECTED]) * @version $Rev$, $Date: 2004-11-01 09:45:13 -0500 (Mon, 01 Nov 2004) $ Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/InputManager.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/InputManager.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/input/InputManager.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/InputManager.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/input/InputManager.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/InputManager.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.input; +package org.apache.apseda.input; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/InputManagerMonitor.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/InputManagerMonitor.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/input/InputManagerMonitor.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/InputManagerMonitor.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/input/InputManagerMonitor.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/InputManagerMonitor.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.input; +package org.apache.apseda.input; import java.io.IOException; @@ -24,10 +24,11 @@ import java.nio.channels.Selector; import java.nio.channels.SocketChannel; -import org.apache.seda.ResourceException; -import org.apache.seda.buffer.BufferPool; -import org.apache.seda.listener.ClientKey; -import org.apache.seda.listener.KeyExpiryException; +import org.apache.apseda.ResourceException; +import org.apache.apseda.buffer.BufferPool; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.KeyExpiryException; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/InputManagerMonitorAdapter.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/InputManagerMonitorAdapter.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/input/InputManagerMonitorAdapter.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/InputManagerMonitorAdapter.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/input/InputManagerMonitorAdapter.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/InputManagerMonitorAdapter.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.input; +package org.apache.apseda.input; import java.io.IOException; @@ -24,10 +24,14 @@ import java.nio.channels.Selector; import java.nio.channels.SocketChannel; -import org.apache.seda.ResourceException; -import org.apache.seda.buffer.BufferPool; -import org.apache.seda.listener.ClientKey; -import org.apache.seda.listener.KeyExpiryException; +import org.apache.apseda.ResourceException; +import org.apache.apseda.buffer.BufferPool; +import org.apache.apseda.input.InputManagerMonitor; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.KeyExpiryException; +import org.apache.apseda.listener.KeyExpiryException; +import org.apache.apseda.ResourceException; /** @@ -39,16 +43,16 @@ public class InputManagerMonitorAdapter implements InputManagerMonitor { /* (non-Javadoc) - * @see org.apache.seda.input.InputManagerMonitor# - * disconnectedClient(org.apache.seda.listener.ClientKey) + * @see org.apache.apseda.input.InputManagerMonitor# + * disconnectedClient(org.apache.apseda.listener.ClientKey) */ public void disconnectedClient(ClientKey key) { } /* (non-Javadoc) - * @see org.apache.seda.input.InputManagerMonitor# - * registeredChannel(org.apache.seda.listener.ClientKey, + * @see org.apache.apseda.input.InputManagerMonitor# + * registeredChannel(org.apache.apseda.listener.ClientKey, * java.nio.channels.Selector) */ public void registeredChannel(ClientKey key, Selector selector) @@ -56,7 +60,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.input.InputManagerMonitor# + * @see org.apache.apseda.input.InputManagerMonitor# * selectorReturned(java.nio.channels.Selector) */ public void selectorReturned(Selector selector) @@ -64,15 +68,15 @@ } /* (non-Javadoc) - * @see org.apache.seda.input.InputManagerMonitor# - * inputRecieved(org.apache.seda.listener.ClientKey) + * @see org.apache.apseda.input.InputManagerMonitor# + * inputRecieved(org.apache.apseda.listener.ClientKey) */ public void inputRecieved(ClientKey key) { } /* (non-Javadoc) - * @see org.apache.seda.input.InputManagerMonitor# + * @see org.apache.apseda.input.InputManagerMonitor# * selectFailure(java.nio.channels.Selector, java.io.IOException) */ public void selectFailure(Selector selector, IOException fault) @@ -81,9 +85,9 @@ } /* (non-Javadoc) - * @see org.apache.seda.input.InputManagerMonitor#keyExpiryFailure( - * org.apache.seda.listener.ClientKey, - * org.apache.seda.listener.KeyExpiryException) + * @see org.apache.apseda.input.InputManagerMonitor#keyExpiryFailure( + * org.apache.apseda.listener.ClientKey, + * org.apache.apseda.listener.KeyExpiryException) */ public void keyExpiryFailure(ClientKey key, KeyExpiryException fault) { @@ -91,8 +95,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.input.InputManagerMonitor# - * readFailed(org.apache.seda.listener.ClientKey, java.io.IOException) + * @see org.apache.apseda.input.InputManagerMonitor# + * readFailed(org.apache.apseda.listener.ClientKey, java.io.IOException) */ public void readFailed(ClientKey key, IOException fault) { @@ -100,9 +104,9 @@ } /* (non-Javadoc) - * @see org.apache.seda.input.InputManagerMonitor# - * bufferUnavailable(org.apache.seda.buffer.BufferPool, - * org.apache.seda.ResourceException) + * @see org.apache.apseda.input.InputManagerMonitor# + * bufferUnavailable(org.apache.apseda.buffer.BufferPool, + * org.apache.apseda.ResourceException) */ public void bufferUnavailable(BufferPool bp, ResourceException fault) { @@ -110,7 +114,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.input.InputManagerMonitor# + * @see org.apache.apseda.input.InputManagerMonitor# * channelRegistrationFailure(java.nio.channels.Selector, * java.nio.channels.SocketChannel, int, java.io.IOException) */ @@ -123,7 +127,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.input.InputManagerMonitor# + * @see org.apache.apseda.input.InputManagerMonitor# * channelCloseFailure(java.nio.channels.SocketChannel, java.io.IOException) */ public void channelCloseFailure(SocketChannel channel, IOException fault) @@ -132,7 +136,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.input.InputManagerMonitor#enteringSelect( + * @see org.apache.apseda.input.InputManagerMonitor#enteringSelect( * java.nio.channels.Selector) */ public void enteringSelect(Selector selector) @@ -140,7 +144,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.input.InputManagerMonitor#selectTimedOut( + * @see org.apache.apseda.input.InputManagerMonitor#selectTimedOut( * java.nio.channels.Selector) */ public void selectTimedOut(Selector selector) @@ -148,15 +152,15 @@ } /* (non-Javadoc) - * @see org.apache.seda.input.InputManagerMonitor#inputRecieved( - * java.nio.ByteBuffer, org.apache.seda.listener.ClientKey) + * @see org.apache.apseda.input.InputManagerMonitor#inputRecieved( + * java.nio.ByteBuffer, org.apache.apseda.listener.ClientKey) */ public void inputRecieved(ByteBuffer buffer, ClientKey key) { } /* (non-Javadoc) - * @see org.apache.seda.input.InputManagerMonitor#cleanedStaleKey( + * @see org.apache.apseda.input.InputManagerMonitor#cleanedStaleKey( * java.nio.channels.SelectionKey) */ public void cleanedStaleKey(SelectionKey key) Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/TCPInputManager.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/TCPInputManager.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/input/TCPInputManager.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/TCPInputManager.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/input/TCPInputManager.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/input/TCPInputManager.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.input; +package org.apache.apseda.input; import java.io.IOException; import java.nio.ByteBuffer; @@ -25,22 +25,26 @@ import java.util.ArrayList; import java.util.Iterator; -import org.apache.seda.ResourceException; -import org.apache.seda.buffer.BufferPool; -import org.apache.seda.event.AbstractSubscriber; -import org.apache.seda.event.ConnectEvent; -import org.apache.seda.event.ConnectSubscriber; -import org.apache.seda.event.DisconnectEvent; -import org.apache.seda.event.DisconnectSubscriber; -import org.apache.seda.event.EventFilter; -import org.apache.seda.event.EventRouter; -import org.apache.seda.event.InputEvent; +import org.apache.apseda.ResourceException; +import org.apache.apseda.buffer.BufferPool; +import org.apache.apseda.event.AbstractSubscriber; +import org.apache.apseda.event.ConnectSubscriber; +import org.apache.apseda.event.DisconnectEvent; +import org.apache.apseda.event.DisconnectSubscriber; +import org.apache.apseda.event.EventRouter; +import org.apache.apseda.event.InputEvent; +import org.apache.apseda.event.*; import org.apache.seda.event.filter.ClientKeyTypeFilter; import org.apache.seda.event.filter.CompositeEventFilter; import org.apache.seda.event.filter.EventTypeFilter; -import org.apache.seda.listener.ClientKey; -import org.apache.seda.listener.KeyExpiryException; -import org.apache.seda.listener.TCPClientKey; +import org.apache.apseda.listener.KeyExpiryException; +import org.apache.apseda.buffer.BufferPool; +import org.apache.apseda.input.InputManager; +import org.apache.apseda.input.InputManagerMonitor; +import org.apache.apseda.input.InputManagerMonitorAdapter; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.TCPClientKey; +import org.apache.apseda.listener.*; /** @@ -51,7 +55,7 @@ */ public class TCPInputManager extends AbstractSubscriber implements InputManager, ConnectSubscriber, - DisconnectSubscriber, + DisconnectSubscriber, Runnable { /** the thread driving this Runnable */ @@ -223,7 +227,7 @@ // ------------------------------------------------------------------------ /** - * @see org.apache.seda.event.ConnectSubscriber#inform(org.apache.seda.event.ConnectEvent) + * @see org.apache.apseda.event.ConnectSubscriber#inform(org.apache.apseda.event.ConnectEvent) */ public void inform(ConnectEvent an_event) { @@ -236,7 +240,7 @@ } /** - * @see org.apache.seda.event.DisconnectSubscriber#inform(org.apache.seda.event.DisconnectEvent) + * @see org.apache.apseda.event.DisconnectSubscriber#inform(org.apache.apseda.event.DisconnectEvent) */ public void inform(DisconnectEvent an_event) { @@ -453,7 +457,7 @@ * * @author <a href="mailto:[EMAIL PROTECTED]">Alex Karasulu</a> * @author $Author: trustin $ - * @version $Revision: 56106 $ + * @version $Revision$ */ class ConcreteInputEvent extends InputEvent { Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/AvailablePortFinder.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/AvailablePortFinder.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/AvailablePortFinder.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/AvailablePortFinder.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/AvailablePortFinder.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/AvailablePortFinder.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.listener; +package org.apache.apseda.listener; import java.io.IOException; import java.net.DatagramSocket; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ClientKey.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ClientKey.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/ClientKey.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ClientKey.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/ClientKey.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ClientKey.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.listener; +package org.apache.apseda.listener; import java.io.IOException; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/KeyExpiryException.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/KeyExpiryException.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/KeyExpiryException.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/KeyExpiryException.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/KeyExpiryException.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/KeyExpiryException.java Fri Jan 7 22:41:35 2005 @@ -15,9 +15,11 @@ * */ -package org.apache.seda.listener; +package org.apache.apseda.listener; import java.io.IOException; + +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerConfig.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerConfig.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/ListenerConfig.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerConfig.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/ListenerConfig.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerConfig.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.listener; +package org.apache.apseda.listener; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerManager.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerManager.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/ListenerManager.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerManager.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/ListenerManager.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerManager.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.listener; +package org.apache.apseda.listener; import java.io.IOException; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerManagerMonitor.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerManagerMonitor.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/ListenerManagerMonitor.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerManagerMonitor.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/ListenerManagerMonitor.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerManagerMonitor.java Fri Jan 7 22:41:35 2005 @@ -15,12 +15,14 @@ * */ -package org.apache.seda.listener; +package org.apache.apseda.listener; import java.io.IOException; import java.nio.channels.SelectionKey; import java.nio.channels.Selector; + +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerManagerMonitorAdapter.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerManagerMonitorAdapter.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/ListenerManagerMonitorAdapter.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerManagerMonitorAdapter.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/ListenerManagerMonitorAdapter.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/ListenerManagerMonitorAdapter.java Fri Jan 7 22:41:35 2005 @@ -15,12 +15,15 @@ * */ -package org.apache.seda.listener; +package org.apache.apseda.listener; import java.io.IOException; import java.nio.channels.SelectionKey; import java.nio.channels.Selector; + +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.ListenerManagerMonitor; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/SocketListenerConfig.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/SocketListenerConfig.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/SocketListenerConfig.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/SocketListenerConfig.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/SocketListenerConfig.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/SocketListenerConfig.java Fri Jan 7 22:41:35 2005 @@ -15,12 +15,13 @@ * */ -package org.apache.seda.listener; +package org.apache.apseda.listener; import java.net.InetAddress; import java.net.InetSocketAddress; -import org.apache.seda.protocol.InetServiceEntry; +import org.apache.apseda.protocol.InetServiceEntry; +import org.apache.apseda.protocol.InetServiceEntry; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/TCPClientKey.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/TCPClientKey.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/TCPClientKey.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/TCPClientKey.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/TCPClientKey.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/TCPClientKey.java Fri Jan 7 22:41:35 2005 @@ -15,12 +15,14 @@ * */ -package org.apache.seda.listener; +package org.apache.apseda.listener; import java.io.IOException; import java.net.InetSocketAddress; import java.net.Socket; + +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/TCPListenerConfig.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/TCPListenerConfig.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/TCPListenerConfig.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/TCPListenerConfig.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/TCPListenerConfig.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/TCPListenerConfig.java Fri Jan 7 22:41:35 2005 @@ -15,11 +15,13 @@ * */ -package org.apache.seda.listener; +package org.apache.apseda.listener; import java.net.InetAddress; -import org.apache.seda.protocol.InetServiceEntry; +import org.apache.apseda.protocol.InetServiceEntry; +import org.apache.apseda.listener.SocketListenerConfig; +import org.apache.apseda.protocol.InetServiceEntry; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/TCPListenerManager.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/TCPListenerManager.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/TCPListenerManager.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/TCPListenerManager.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/TCPListenerManager.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/TCPListenerManager.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.listener; +package org.apache.apseda.listener; import java.io.IOException; import java.net.InetSocketAddress; @@ -29,11 +29,9 @@ import java.util.Iterator; import java.util.Set; -import org.apache.seda.event.ConnectEvent; -import org.apache.seda.event.DisconnectEvent; -import org.apache.seda.event.DisconnectSubscriber; -import org.apache.seda.event.EventFilter; -import org.apache.seda.event.EventRouter; +import org.apache.apseda.event.DisconnectEvent; +import org.apache.apseda.event.*; +import org.apache.apseda.event.EventRouter; import org.apache.seda.event.filter.ClientKeyTypeFilter; import org.apache.seda.event.filter.CompositeEventFilter; import org.apache.seda.event.filter.EventTypeFilter; @@ -123,7 +121,7 @@ } /** - * @see org.apache.seda.listener.ListenerManager#bind(ListenerConfig) + * @see org.apache.apseda.listener.ListenerManager#bind(ListenerConfig) */ public void bind(ListenerConfig listener) throws IOException { @@ -138,7 +136,7 @@ } /** - * @see org.apache.seda.listener.ListenerManager#unbind(ListenerConfig) + * @see org.apache.apseda.listener.ListenerManager#unbind(ListenerConfig) */ public void unbind(ListenerConfig listener) throws IOException { @@ -275,7 +273,7 @@ /* * (non-Javadoc) - * @see org.apache.seda.event.Subscriber#inform(java.util.EventObject) + * @see org.apache.apseda.event.Subscriber#inform(java.util.EventObject) */ public void inform(EventObject event) { Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/UDPClientKey.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/UDPClientKey.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/UDPClientKey.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/UDPClientKey.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/UDPClientKey.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/UDPClientKey.java Fri Jan 7 22:41:35 2005 @@ -15,12 +15,15 @@ * */ -package org.apache.seda.listener; +package org.apache.apseda.listener; import java.io.IOException; import java.net.DatagramSocket; import java.net.InetSocketAddress; + +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.KeyExpiryException; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/UDPListenerConfig.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/UDPListenerConfig.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/UDPListenerConfig.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/UDPListenerConfig.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/UDPListenerConfig.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/UDPListenerConfig.java Fri Jan 7 22:41:35 2005 @@ -15,11 +15,12 @@ * */ -package org.apache.seda.listener; +package org.apache.apseda.listener; import java.net.InetAddress; -import org.apache.seda.protocol.InetServiceEntry; +import org.apache.apseda.protocol.InetServiceEntry; +import org.apache.apseda.protocol.InetServiceEntry; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/UDPListenerManager.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/UDPListenerManager.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/UDPListenerManager.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/UDPListenerManager.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/listener/UDPListenerManager.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/listener/UDPListenerManager.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.listener; +package org.apache.apseda.listener; import java.io.IOException; import java.net.DatagramSocket; @@ -29,12 +29,17 @@ import java.util.Iterator; import java.util.Set; -import org.apache.seda.ResourceException; -import org.apache.seda.buffer.BufferPool; -import org.apache.seda.event.DisconnectEvent; -import org.apache.seda.event.DisconnectSubscriber; -import org.apache.seda.event.EventRouter; -import org.apache.seda.event.InputEvent; +import org.apache.apseda.ResourceException; +import org.apache.apseda.buffer.BufferPool; +import org.apache.apseda.event.DisconnectEvent; +import org.apache.apseda.event.EventRouter; +import org.apache.apseda.buffer.BufferPool; +import org.apache.apseda.event.InputEvent; +import org.apache.apseda.event.DisconnectSubscriber; +import org.apache.apseda.event.*; +import org.apache.apseda.listener.UDPListenerConfig; +import org.apache.apseda.listener.ListenerManager; +import org.apache.apseda.ResourceException; /** @@ -45,7 +50,7 @@ * @version $Rev$ */ public class UDPListenerManager implements DisconnectSubscriber, - ListenerManager, Runnable + ListenerManager, Runnable { /** event manager used to decouple source to sink relationships */ private final EventRouter router; @@ -119,7 +124,7 @@ } /** - * @see org.apache.seda.listener.ListenerManager#bind(ListenerConfig) + * @see org.apache.apseda.listener.ListenerManager#bind(ListenerConfig) */ public void bind(ListenerConfig listener) throws IOException { @@ -134,7 +139,7 @@ } /** - * @see org.apache.seda.listener.ListenerManager#unbind(ListenerConfig) + * @see org.apache.apseda.listener.ListenerManager#unbind(ListenerConfig) */ public void unbind(ListenerConfig listener) throws IOException { @@ -270,7 +275,7 @@ /* * (non-Javadoc) - * @see org.apache.seda.event.Subscriber#inform(java.util.EventObject) + * @see org.apache.apseda.event.Subscriber#inform(java.util.EventObject) */ public void inform(EventObject event) { Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/LoggingOutputMonitor.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/LoggingOutputMonitor.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/output/LoggingOutputMonitor.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/LoggingOutputMonitor.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/output/LoggingOutputMonitor.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/LoggingOutputMonitor.java Fri Jan 7 22:41:35 2005 @@ -15,16 +15,17 @@ * */ -package org.apache.seda.output; +package org.apache.apseda.output; import java.util.EventObject; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import org.apache.seda.event.ConnectEvent; -import org.apache.seda.event.DisconnectEvent; -import org.apache.seda.listener.ClientKey; -import org.apache.seda.listener.KeyExpiryException; +import org.apache.apseda.event.ConnectEvent; +import org.apache.apseda.event.DisconnectEvent; +import org.apache.apseda.event.DisconnectEvent; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.KeyExpiryException; /** @@ -38,8 +39,8 @@ private final Log log = LogFactory.getLog("OutputManager"); /* (non-Javadoc) - * @see org.apache.seda.output.OutputMonitor#failedOnWrite( - * org.apache.seda.output.OutputManager, org.apache.seda.listener.ClientKey, + * @see org.apache.apseda.output.OutputMonitor#failedOnWrite( + * org.apache.apseda.output.OutputManager, org.apache.apseda.listener.ClientKey, * java.lang.Throwable) */ public void failedOnWrite( @@ -54,8 +55,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.output.OutputMonitor#writeOccurred( - * org.apache.seda.output.OutputManager, org.apache.seda.listener.ClientKey) + * @see org.apache.apseda.output.OutputMonitor#writeOccurred( + * org.apache.apseda.output.OutputManager, org.apache.apseda.listener.ClientKey) */ public void writeOccurred(OutputManager manager, ClientKey key) { @@ -66,8 +67,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.output.OutputMonitor#writeLockAcquired( - * org.apache.seda.output.OutputManager, org.apache.seda.listener.ClientKey) + * @see org.apache.apseda.output.OutputMonitor#writeLockAcquired( + * org.apache.apseda.output.OutputManager, org.apache.apseda.listener.ClientKey) */ public void writeLockAcquired(OutputManager manager, ClientKey key) { @@ -78,8 +79,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.output.OutputMonitor#channelMissing( - * org.apache.seda.output.OutputManager, org.apache.seda.listener.ClientKey) + * @see org.apache.apseda.output.OutputMonitor#channelMissing( + * org.apache.apseda.output.OutputManager, org.apache.apseda.listener.ClientKey) */ public void channelMissing(OutputManager manager, ClientKey key) { @@ -90,9 +91,9 @@ } /* (non-Javadoc) - * @see org.apache.seda.output.OutputMonitor#keyExpired( - * org.apache.seda.output.OutputManager, org.apache.seda.listener.ClientKey, - * org.apache.seda.listener.KeyExpiryException) + * @see org.apache.apseda.output.OutputMonitor#keyExpired( + * org.apache.apseda.output.OutputManager, org.apache.apseda.listener.ClientKey, + * org.apache.apseda.listener.KeyExpiryException) */ public void keyExpired( OutputManager manager, ClientKey key, @@ -105,8 +106,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.output.OutputMonitor#failedOnInform( - * org.apache.seda.output.OutputManager, java.util.EventObject, + * @see org.apache.apseda.output.OutputMonitor#failedOnInform( + * org.apache.apseda.output.OutputManager, java.util.EventObject, * java.lang.Throwable) */ public void failedOnInform( @@ -120,8 +121,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.output.OutputMonitor#addedClient( - * org.apache.seda.output.OutputManager, org.apache.seda.event.ConnectEvent) + * @see org.apache.apseda.output.OutputMonitor#addedClient( + * org.apache.apseda.output.OutputManager, org.apache.apseda.event.ConnectEvent) */ public void addedClient(OutputManager manager, ConnectEvent event) { @@ -132,9 +133,9 @@ } /* (non-Javadoc) - * @see org.apache.seda.output.OutputMonitor#removedClient( - * org.apache.seda.output.OutputManager, - * org.apache.seda.event.DisconnectEvent) + * @see org.apache.apseda.output.OutputMonitor#removedClient( + * org.apache.apseda.output.OutputManager, + * org.apache.apseda.event.DisconnectEvent) */ public void removedClient(OutputManager manager, DisconnectEvent event) { Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/OutputManager.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/OutputManager.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/output/OutputManager.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/OutputManager.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/output/OutputManager.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/OutputManager.java Fri Jan 7 22:41:35 2005 @@ -15,13 +15,14 @@ * */ -package org.apache.seda.output; +package org.apache.apseda.output; import java.io.IOException; import java.nio.ByteBuffer; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/OutputMonitor.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/OutputMonitor.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/output/OutputMonitor.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/OutputMonitor.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/output/OutputMonitor.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/OutputMonitor.java Fri Jan 7 22:41:35 2005 @@ -15,14 +15,17 @@ * */ -package org.apache.seda.output; +package org.apache.apseda.output; import java.util.EventObject; -import org.apache.seda.event.ConnectEvent; -import org.apache.seda.event.DisconnectEvent; -import org.apache.seda.listener.ClientKey; -import org.apache.seda.listener.KeyExpiryException; +import org.apache.apseda.event.ConnectEvent; +import org.apache.apseda.event.DisconnectEvent; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.KeyExpiryException; +import org.apache.apseda.listener.KeyExpiryException; +import org.apache.apseda.output.OutputManager; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/OutputMonitorAdapter.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/OutputMonitorAdapter.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/output/OutputMonitorAdapter.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/OutputMonitorAdapter.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/output/OutputMonitorAdapter.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/OutputMonitorAdapter.java Fri Jan 7 22:41:35 2005 @@ -15,14 +15,19 @@ * */ -package org.apache.seda.output; +package org.apache.apseda.output; import java.util.EventObject; -import org.apache.seda.event.ConnectEvent; -import org.apache.seda.event.DisconnectEvent; -import org.apache.seda.listener.ClientKey; -import org.apache.seda.listener.KeyExpiryException; +import org.apache.apseda.event.ConnectEvent; +import org.apache.apseda.event.DisconnectEvent; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.KeyExpiryException; +import org.apache.apseda.event.ConnectEvent; +import org.apache.apseda.event.DisconnectEvent; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.output.OutputManager; +import org.apache.apseda.output.OutputMonitor; /** @@ -35,9 +40,9 @@ public class OutputMonitorAdapter implements OutputMonitor { /* (non-Javadoc) - * @see org.apache.seda.output.OutputMonitor# - * failedOnWrite(org.apache.seda.output.OutputManager, - * org.apache.seda.listener.ClientKey, java.lang.Throwable) + * @see org.apache.apseda.output.OutputMonitor# + * failedOnWrite(org.apache.apseda.output.OutputManager, + * org.apache.apseda.listener.ClientKey, java.lang.Throwable) */ public void failedOnWrite( OutputManager manager, ClientKey key, Throwable t) @@ -46,25 +51,25 @@ } /* (non-Javadoc) - * @see org.apache.seda.output.OutputMonitor#writeOccurred( - * org.apache.seda.output.OutputManager, org.apache.seda.listener.ClientKey) + * @see org.apache.apseda.output.OutputMonitor#writeOccurred( + * org.apache.apseda.output.OutputManager, org.apache.apseda.listener.ClientKey) */ public void writeOccurred(OutputManager manager, ClientKey key) { } /* (non-Javadoc) - * @see org.apache.seda.output.OutputMonitor#channelMissing( - * org.apache.seda.output.OutputManager, org.apache.seda.listener.ClientKey) + * @see org.apache.apseda.output.OutputMonitor#channelMissing( + * org.apache.apseda.output.OutputManager, org.apache.apseda.listener.ClientKey) */ public void channelMissing(OutputManager manager, ClientKey key) { } /* (non-Javadoc) - * @see org.apache.seda.output.OutputMonitor#keyExpired( - * org.apache.seda.output.OutputManager, - * org.apache.seda.listener.KeyExpiryException) + * @see org.apache.apseda.output.OutputMonitor#keyExpired( + * org.apache.apseda.output.OutputManager, + * org.apache.apseda.listener.KeyExpiryException) */ public void keyExpired( OutputManager manager, ClientKey key, @@ -74,8 +79,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.output.OutputMonitor#failedOnInform( - * org.apache.seda.output.OutputManager, java.util.EventObject, + * @see org.apache.apseda.output.OutputMonitor#failedOnInform( + * org.apache.apseda.output.OutputManager, java.util.EventObject, * java.lang.Throwable) */ public void failedOnInform( @@ -86,17 +91,17 @@ } /* (non-Javadoc) - * @see org.apache.seda.output.OutputMonitor#addedClient( - * org.apache.seda.output.OutputManager, org.apache.seda.event.ConnectEvent) + * @see org.apache.apseda.output.OutputMonitor#addedClient( + * org.apache.apseda.output.OutputManager, org.apache.apseda.event.ConnectEvent) */ public void addedClient(OutputManager manager, ConnectEvent event) { } /* (non-Javadoc) - * @see org.apache.seda.output.OutputMonitor#removedClient( - * org.apache.seda.output.OutputManager, - * org.apache.seda.event.DisconnectEvent) + * @see org.apache.apseda.output.OutputMonitor#removedClient( + * org.apache.apseda.output.OutputManager, + * org.apache.apseda.event.DisconnectEvent) */ public void removedClient(OutputManager manager, DisconnectEvent event) { Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/TCPOutputManager.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/TCPOutputManager.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/output/TCPOutputManager.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/TCPOutputManager.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/output/TCPOutputManager.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/TCPOutputManager.java Fri Jan 7 22:41:35 2005 @@ -14,7 +14,7 @@ * limitations under the License. * */ -package org.apache.seda.output; +package org.apache.apseda.output; import java.io.IOException; @@ -25,26 +25,32 @@ import java.util.HashMap; import java.util.Map; -import org.apache.seda.event.AbstractSubscriber; -import org.apache.seda.event.ConnectEvent; -import org.apache.seda.event.ConnectSubscriber; -import org.apache.seda.event.DisconnectEvent; -import org.apache.seda.event.DisconnectSubscriber; -import org.apache.seda.event.EventFilter; -import org.apache.seda.event.EventRouter; -import org.apache.seda.event.GatheringOutputEvent; -import org.apache.seda.event.OutputEvent; -import org.apache.seda.event.OutputSubscriber; +import org.apache.apseda.event.AbstractSubscriber; +import org.apache.apseda.event.ConnectSubscriber; +import org.apache.apseda.event.DisconnectEvent; +import org.apache.apseda.event.DisconnectSubscriber; +import org.apache.apseda.event.EventRouter; +import org.apache.apseda.event.GatheringOutputEvent; +import org.apache.apseda.event.OutputSubscriber; import org.apache.seda.event.filter.ClientKeyTypeFilter; import org.apache.seda.event.filter.CompositeEventFilter; import org.apache.seda.event.filter.EventTypeFilter; -import org.apache.seda.listener.ClientKey; -import org.apache.seda.listener.KeyExpiryException; -import org.apache.seda.listener.TCPClientKey; -import org.apache.seda.stage.DefaultStage; -import org.apache.seda.stage.DefaultStageConfig; -import org.apache.seda.stage.LoggingStageMonitor; -import org.apache.seda.stage.StageHandler; +import org.apache.apseda.listener.KeyExpiryException; +import org.apache.apseda.stage.DefaultStage; +import org.apache.apseda.stage.DefaultStageConfig; +import org.apache.apseda.stage.LoggingStageMonitor; +import org.apache.apseda.stage.StageHandler; +import org.apache.apseda.event.ConnectEvent; +import org.apache.apseda.event.EventFilter; +import org.apache.apseda.event.*; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.TCPClientKey; +import org.apache.apseda.listener.*; +import org.apache.apseda.output.LoggingOutputMonitor; +import org.apache.apseda.output.OutputManager; +import org.apache.apseda.output.OutputMonitor; +import org.apache.apseda.stage.DefaultStage; +import org.apache.apseda.stage.DefaultStageConfig; /** @@ -56,7 +62,7 @@ public class TCPOutputManager extends DefaultStage implements OutputManager, OutputSubscriber, ConnectSubscriber, - DisconnectSubscriber + DisconnectSubscriber { /** the router we subscribe for OutputEvents on */ private final EventRouter router; @@ -103,7 +109,7 @@ // ------------------------------------------------------------------------ /* - * @see org.apache.seda.event.Subscriber#inform(java.util.EventObject) + * @see org.apache.apseda.event.Subscriber#inform(java.util.EventObject) */ public void inform(EventObject event) { @@ -118,8 +124,8 @@ } /* - * @see org.apache.seda.event.OutputSubscriber#inform( - * org.apache.seda.event.OutputEvent) + * @see org.apache.apseda.event.OutputSubscriber#inform( + * org.apache.apseda.event.OutputEvent) */ public void inform(OutputEvent event) { @@ -132,8 +138,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.event.ConnectSubscriber#inform( - * org.apache.seda.event.ConnectEvent) + * @see org.apache.apseda.event.ConnectSubscriber#inform( + * org.apache.apseda.event.ConnectEvent) */ public void inform(ConnectEvent event) { @@ -152,8 +158,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.event.DisconnectSubscriber#inform( - * org.apache.seda.event.DisconnectEvent) + * @see org.apache.apseda.event.DisconnectSubscriber#inform( + * org.apache.apseda.event.DisconnectEvent) */ public void inform(DisconnectEvent event) { @@ -167,8 +173,8 @@ /* * (non-Javadoc) - * @see org.apache.seda.output.OutputManager#write( - * org.apache.seda.listener.ClientKey, java.nio.ByteBuffer) + * @see org.apache.apseda.output.OutputManager#write( + * org.apache.apseda.listener.ClientKey, java.nio.ByteBuffer) */ public void write(ClientKey key, ByteBuffer buf) throws IOException Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/UDPOutputManager.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/UDPOutputManager.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/output/UDPOutputManager.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/UDPOutputManager.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/output/UDPOutputManager.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/output/UDPOutputManager.java Fri Jan 7 22:41:35 2005 @@ -14,7 +14,7 @@ * limitations under the License. * */ -package org.apache.seda.output; +package org.apache.apseda.output; import java.io.IOException; @@ -22,21 +22,26 @@ import java.util.EventObject; -import org.apache.seda.event.AbstractSubscriber; -import org.apache.seda.event.EventFilter; -import org.apache.seda.event.EventRouter; -import org.apache.seda.event.GatheringOutputEvent; -import org.apache.seda.event.OutputEvent; -import org.apache.seda.event.OutputSubscriber; +import org.apache.apseda.event.AbstractSubscriber; +import org.apache.apseda.event.EventRouter; +import org.apache.apseda.event.GatheringOutputEvent; +import org.apache.apseda.event.OutputSubscriber; import org.apache.seda.event.filter.ClientKeyTypeFilter; import org.apache.seda.event.filter.CompositeEventFilter; import org.apache.seda.event.filter.EventTypeFilter; -import org.apache.seda.listener.ClientKey; -import org.apache.seda.listener.UDPClientKey; -import org.apache.seda.stage.DefaultStage; -import org.apache.seda.stage.DefaultStageConfig; -import org.apache.seda.stage.LoggingStageMonitor; -import org.apache.seda.stage.StageHandler; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.UDPClientKey; +import org.apache.apseda.stage.DefaultStage; +import org.apache.apseda.stage.DefaultStageConfig; +import org.apache.apseda.stage.LoggingStageMonitor; +import org.apache.apseda.stage.LoggingStageMonitor; +import org.apache.apseda.stage.StageHandler; +import org.apache.apseda.event.OutputEvent; +import org.apache.apseda.event.EventFilter; +import org.apache.apseda.event.*; +import org.apache.apseda.output.LoggingOutputMonitor; +import org.apache.apseda.output.OutputManager; +import org.apache.apseda.output.OutputMonitor; /** @@ -84,7 +89,7 @@ // ------------------------------------------------------------------------ /* - * @see org.apache.seda.event.Subscriber#inform(java.util.EventObject) + * @see org.apache.apseda.event.Subscriber#inform(java.util.EventObject) */ public void inform(EventObject event) { @@ -99,8 +104,8 @@ } /* - * @see org.apache.seda.event.OutputSubscriber#inform( - * org.apache.seda.event.OutputEvent) + * @see org.apache.apseda.event.OutputSubscriber#inform( + * org.apache.apseda.event.OutputEvent) */ public void inform(OutputEvent event) { @@ -118,8 +123,8 @@ /* * (non-Javadoc) - * @see org.apache.seda.output.OutputManager#write( - * org.apache.seda.listener.ClientKey, java.nio.ByteBuffer) + * @see org.apache.apseda.output.OutputManager#write( + * org.apache.apseda.listener.ClientKey, java.nio.ByteBuffer) */ public void write(ClientKey key, ByteBuffer buf) throws IOException Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractManyReplyHandler.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractManyReplyHandler.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/AbstractManyReplyHandler.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractManyReplyHandler.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/AbstractManyReplyHandler.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractManyReplyHandler.java Fri Jan 7 22:41:35 2005 @@ -14,7 +14,7 @@ * limitations under the License. * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractNoReplyHandler.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractNoReplyHandler.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/AbstractNoReplyHandler.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractNoReplyHandler.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/AbstractNoReplyHandler.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractNoReplyHandler.java Fri Jan 7 22:41:35 2005 @@ -14,7 +14,7 @@ * limitations under the License. * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractRequestHandler.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractRequestHandler.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/AbstractRequestHandler.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractRequestHandler.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/AbstractRequestHandler.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractRequestHandler.java Fri Jan 7 22:41:35 2005 @@ -14,7 +14,7 @@ * limitations under the License. * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractSingleReplyHandler.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractSingleReplyHandler.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/AbstractSingleReplyHandler.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractSingleReplyHandler.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/AbstractSingleReplyHandler.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/AbstractSingleReplyHandler.java Fri Jan 7 22:41:35 2005 @@ -14,7 +14,10 @@ * limitations under the License. * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; + + +import org.apache.apseda.protocol.AbstractRequestHandler; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/DefaultInetServicesDatabase.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/DefaultInetServicesDatabase.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/DefaultInetServicesDatabase.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/DefaultInetServicesDatabase.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/DefaultInetServicesDatabase.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/DefaultInetServicesDatabase.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; import java.util.*; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/DefaultRequestProcessor.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/DefaultRequestProcessor.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/DefaultRequestProcessor.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/DefaultRequestProcessor.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/DefaultRequestProcessor.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/DefaultRequestProcessor.java Fri Jan 7 22:41:35 2005 @@ -15,24 +15,25 @@ * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; import java.util.EventObject; import java.util.Iterator; -import org.apache.seda.event.AbstractSubscriber; -import org.apache.seda.event.EventRouter; -import org.apache.seda.event.RequestEvent; -import org.apache.seda.event.RequestSubscriber; -import org.apache.seda.event.ResponseEvent; +import org.apache.apseda.event.AbstractSubscriber; +import org.apache.apseda.event.ResponseEvent; import org.apache.seda.event.filter.EventTypeFilter; -import org.apache.seda.listener.ClientKey; -import org.apache.seda.listener.UDPClientKey; -import org.apache.seda.stage.DefaultStage; -import org.apache.seda.stage.DefaultStageConfig; -import org.apache.seda.stage.LoggingStageMonitor; -import org.apache.seda.stage.StageConfig; -import org.apache.seda.stage.StageHandler; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.UDPClientKey; +import org.apache.apseda.stage.StageConfig; +import org.apache.apseda.stage.StageHandler; +import org.apache.apseda.event.RequestEvent; +import org.apache.apseda.event.RequestSubscriber; +import org.apache.apseda.event.*; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.UDPClientKey; +import org.apache.apseda.stage.DefaultStage; +import org.apache.apseda.stage.*; /** @@ -70,8 +71,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.event.RequestSubscriber#inform( - * org.apache.seda.event.RequestEvent) + * @see org.apache.apseda.event.RequestSubscriber#inform( + * org.apache.apseda.event.RequestEvent) */ public void inform(RequestEvent event) { @@ -79,7 +80,7 @@ } /* (non-Javadoc) - * @see org.apache.seda.event.Subscriber#inform(java.util.EventObject) + * @see org.apache.apseda.event.Subscriber#inform(java.util.EventObject) */ public void inform(EventObject event) { Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/HandlerTypeEnum.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/HandlerTypeEnum.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/HandlerTypeEnum.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/HandlerTypeEnum.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/HandlerTypeEnum.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/HandlerTypeEnum.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; import org.apache.seda.impl.util.ValuedEnum; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/InetServiceEntry.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/InetServiceEntry.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/InetServiceEntry.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/InetServiceEntry.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/InetServiceEntry.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/InetServiceEntry.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/InetServicesDatabase.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/InetServicesDatabase.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/InetServicesDatabase.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/InetServicesDatabase.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/InetServicesDatabase.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/InetServicesDatabase.java Fri Jan 7 22:41:35 2005 @@ -15,9 +15,11 @@ * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; import java.util.Iterator; + +import org.apache.apseda.protocol.InetServiceEntry; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/ManyReplyHandler.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/ManyReplyHandler.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/ManyReplyHandler.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/ManyReplyHandler.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/ManyReplyHandler.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/ManyReplyHandler.java Fri Jan 7 22:41:35 2005 @@ -15,11 +15,12 @@ * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; import java.util.Iterator; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/NoReplyHandler.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/NoReplyHandler.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/NoReplyHandler.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/NoReplyHandler.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/NoReplyHandler.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/NoReplyHandler.java Fri Jan 7 22:41:35 2005 @@ -15,10 +15,10 @@ * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/ProtocolProvider.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/ProtocolProvider.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/ProtocolProvider.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/ProtocolProvider.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/ProtocolProvider.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/ProtocolProvider.java Fri Jan 7 22:41:35 2005 @@ -14,12 +14,13 @@ * limitations under the License. * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; import org.apache.asn1.codec.stateful.DecoderFactory; import org.apache.asn1.codec.stateful.EncoderFactory; import org.apache.asn1.codec.stateful.EncoderFactory; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestHandler.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestHandler.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/RequestHandler.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestHandler.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/RequestHandler.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestHandler.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,10 @@ * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; + + +import org.apache.apseda.protocol.HandlerTypeEnum; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestProcessor.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestProcessor.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/RequestProcessor.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestProcessor.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/RequestProcessor.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestProcessor.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestProcessorMonitor.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestProcessorMonitor.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/RequestProcessorMonitor.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestProcessorMonitor.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/RequestProcessorMonitor.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestProcessorMonitor.java Fri Jan 7 22:41:35 2005 @@ -15,13 +15,15 @@ * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; import java.util.EventObject; -import org.apache.seda.event.Subscriber; -import org.apache.seda.listener.ClientKey; -import org.apache.seda.listener.KeyExpiryException; +import org.apache.apseda.event.Subscriber; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.KeyExpiryException; +import org.apache.apseda.event.Subscriber; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestProcessorMonitorAdapter.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestProcessorMonitorAdapter.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/RequestProcessorMonitorAdapter.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestProcessorMonitorAdapter.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/RequestProcessorMonitorAdapter.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/RequestProcessorMonitorAdapter.java Fri Jan 7 22:41:35 2005 @@ -15,13 +15,16 @@ * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; import java.util.EventObject; -import org.apache.seda.event.Subscriber; -import org.apache.seda.listener.ClientKey; -import org.apache.seda.listener.KeyExpiryException; +import org.apache.apseda.event.Subscriber; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.KeyExpiryException; +import org.apache.apseda.event.Subscriber; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.protocol.RequestProcessorMonitor; /** @@ -33,8 +36,8 @@ */ public class RequestProcessorMonitorAdapter implements RequestProcessorMonitor { - /* @see org.apache.seda.protocol.RequestProcessorMonitor#failedOnInform( - * org.apache.seda.event.Subscriber, java.util.EventObject, + /* @see org.apache.apseda.protocol.RequestProcessorMonitor#failedOnInform( + * org.apache.apseda.event.Subscriber, java.util.EventObject, * java.lang.Throwable) */ public void failedOnInform( @@ -48,8 +51,8 @@ } /* (non-Javadoc) - * @see org.apache.seda.protocol.RequestProcessorMonitor#failedOnSingleReply - * (org.apache.seda.listener.ClientKey, + * @see org.apache.apseda.protocol.RequestProcessorMonitor#failedOnSingleReply + * (org.apache.apseda.listener.ClientKey, * org.apache.ldap.common.message.Request, java.lang.Throwable) */ public void failedOnSingleReply( Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/SingleReplyHandler.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/SingleReplyHandler.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/SingleReplyHandler.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/SingleReplyHandler.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/SingleReplyHandler.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/SingleReplyHandler.java Fri Jan 7 22:41:35 2005 @@ -15,10 +15,12 @@ * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.protocol.RequestHandler; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/TransportTypeEnum.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/TransportTypeEnum.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/TransportTypeEnum.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/TransportTypeEnum.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/protocol/TransportTypeEnum.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/protocol/TransportTypeEnum.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.protocol; +package org.apache.apseda.protocol; import org.apache.seda.impl.util.ValuedEnum; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/session/ClientSession.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/session/ClientSession.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/session/ClientSession.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/session/ClientSession.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/session/ClientSession.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/session/ClientSession.java Fri Jan 7 22:41:35 2005 @@ -15,14 +15,15 @@ * */ -package org.apache.seda.session; +package org.apache.apseda.session; import java.security.Principal; import java.util.Iterator; import java.util.Locale; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.listener.ClientKey; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/DefaultStage.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/DefaultStage.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/DefaultStage.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/DefaultStage.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/DefaultStage.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/DefaultStage.java Fri Jan 7 22:41:35 2005 @@ -15,15 +15,16 @@ * */ -package org.apache.seda.stage; +package org.apache.apseda.stage; import java.util.EventObject; import java.util.HashSet; import java.util.LinkedList; import java.util.Set; -import org.apache.seda.event.ClientEvent; -import org.apache.seda.listener.ClientKey; +import org.apache.apseda.event.ClientEvent; +import org.apache.apseda.listener.ClientKey; +import org.apache.apseda.event.ClientEvent; /** @@ -78,8 +79,8 @@ // ------------------------------------------------------------------------ /** - * @see org.apache.seda.stage.Stage#addPredicate( - * org.apache.seda.stage.EnqueuePredicate) + * @see org.apache.apseda.stage.Stage#addPredicate( + * org.apache.apseda.stage.EnqueuePredicate) * addPredicate(org.apache.seda.seda.EnqueuePredicate) */ public void addPredicate(EnqueuePredicate predicate) @@ -89,7 +90,7 @@ } /** - * @see org.apache.seda.stage.Stage#getConfig() + * @see org.apache.apseda.stage.Stage#getConfig() */ public StageConfig getConfig() { @@ -101,7 +102,7 @@ * predicates permit the operation and the stage has started. The event * enqueue is rejected if the stage has not started. * - * @see org.apache.seda.stage.Stage#enqueue(java.util.EventObject) + * @see org.apache.apseda.stage.Stage#enqueue(java.util.EventObject) */ public void enqueue(final EventObject event) { @@ -221,7 +222,7 @@ * * @author <a href="mailto:[EMAIL PROTECTED]">Alex Karasulu</a> * @author $Author: trustin $ - * @version $Revision: 56106 $ + * @version $Revision$ */ class StageDriver implements Runnable { @@ -285,7 +286,7 @@ * * @author <a href="mailto:[EMAIL PROTECTED]">Alex Karasulu</a> * @author $Author: trustin $ - * @version $Revision: 56106 $ + * @version $Revision$ */ class ExecutableHandler implements Runnable { Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/DefaultStageConfig.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/DefaultStageConfig.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/DefaultStageConfig.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/DefaultStageConfig.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/DefaultStageConfig.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/DefaultStageConfig.java Fri Jan 7 22:41:35 2005 @@ -15,12 +15,13 @@ * */ -package org.apache.seda.stage; +package org.apache.apseda.stage; import java.util.ArrayList; import java.util.List; -import org.apache.seda.thread.ThreadPool; +import org.apache.apseda.thread.ThreadPool; +import org.apache.apseda.thread.ThreadPool; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/EnqueuePredicate.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/EnqueuePredicate.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/EnqueuePredicate.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/EnqueuePredicate.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/EnqueuePredicate.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/EnqueuePredicate.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.stage; +package org.apache.apseda.stage; import java.util.EventObject; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/LoggingStageMonitor.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/LoggingStageMonitor.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/LoggingStageMonitor.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/LoggingStageMonitor.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/LoggingStageMonitor.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/LoggingStageMonitor.java Fri Jan 7 22:41:35 2005 @@ -15,12 +15,14 @@ * */ -package org.apache.seda.stage; +package org.apache.apseda.stage; import java.util.EventObject; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; +import org.apache.apseda.stage.DefaultStage; +import org.apache.apseda.stage.EnqueuePredicate; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/Stage.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/Stage.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/Stage.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/Stage.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/Stage.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/Stage.java Fri Jan 7 22:41:35 2005 @@ -15,11 +15,11 @@ * */ -package org.apache.seda.stage; +package org.apache.apseda.stage; import java.util.EventObject; -import org.apache.seda.stage.EnqueuePredicate; +import org.apache.apseda.stage.EnqueuePredicate; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageConfig.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageConfig.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/StageConfig.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageConfig.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/StageConfig.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageConfig.java Fri Jan 7 22:41:35 2005 @@ -15,11 +15,12 @@ * */ -package org.apache.seda.stage; +package org.apache.apseda.stage; import java.util.List; -import org.apache.seda.thread.ThreadPool; +import org.apache.apseda.thread.ThreadPool; +import org.apache.apseda.thread.ThreadPool; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageHandler.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageHandler.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/StageHandler.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageHandler.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/StageHandler.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageHandler.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.stage; +package org.apache.apseda.stage; import java.util.EventListener; import java.util.EventObject; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageMonitor.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageMonitor.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/StageMonitor.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageMonitor.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/StageMonitor.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageMonitor.java Fri Jan 7 22:41:35 2005 @@ -15,9 +15,12 @@ * */ -package org.apache.seda.stage; +package org.apache.apseda.stage; import java.util.EventObject; + +import org.apache.apseda.stage.EnqueuePredicate; +import org.apache.apseda.stage.Stage; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageMonitorAdapter.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageMonitorAdapter.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/StageMonitorAdapter.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageMonitorAdapter.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/stage/StageMonitorAdapter.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/stage/StageMonitorAdapter.java Fri Jan 7 22:41:35 2005 @@ -15,9 +15,13 @@ * */ -package org.apache.seda.stage; +package org.apache.apseda.stage; import java.util.EventObject; + +import org.apache.apseda.stage.EnqueuePredicate; +import org.apache.apseda.stage.Stage; +import org.apache.apseda.stage.StageMonitor; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/AbstractThreadPool.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/AbstractThreadPool.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/thread/AbstractThreadPool.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/AbstractThreadPool.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/thread/AbstractThreadPool.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/AbstractThreadPool.java Fri Jan 7 22:41:35 2005 @@ -18,7 +18,7 @@ /* * @(#) $Id: AbstractThreadPooledEventDispatcher.java 169 2004-10-21 07:22:31Z trustin $ */ -package org.apache.seda.thread; +package org.apache.apseda.thread; import java.util.ArrayList; import java.util.Iterator; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/OrderedThreadPool.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/OrderedThreadPool.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/thread/OrderedThreadPool.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/OrderedThreadPool.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/thread/OrderedThreadPool.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/OrderedThreadPool.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,11 @@ * */ -package org.apache.seda.thread; +package org.apache.apseda.thread; + + +import org.apache.apseda.thread.AbstractThreadPool; + /** * @author Trustin Lee Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/RunnableQueue.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/RunnableQueue.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/thread/RunnableQueue.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/RunnableQueue.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/thread/RunnableQueue.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/RunnableQueue.java Fri Jan 7 22:41:35 2005 @@ -17,7 +17,7 @@ /* * @(#) $Id: EventQueue.java 169 2004-10-21 07:22:31Z trustin $ */ -package org.apache.seda.thread; +package org.apache.apseda.thread; import java.io.Serializable; import java.util.Arrays; Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/SimpleThreadPool.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/SimpleThreadPool.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/thread/SimpleThreadPool.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/SimpleThreadPool.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/thread/SimpleThreadPool.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/SimpleThreadPool.java Fri Jan 7 22:41:35 2005 @@ -4,7 +4,11 @@ * TODO To change the template for this generated file go to * Window - Preferences - Java - Code Style - Code Templates */ -package org.apache.seda.thread; +package org.apache.apseda.thread; + + +import org.apache.apseda.thread.AbstractThreadPool; +import org.apache.apseda.thread.RunnableQueue; /** Modified: incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/ThreadPool.java Url: http://svn.apache.org/viewcvs/incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/ThreadPool.java?view=diff&rev=124638&p1=incubator/directory/apseda/trunk/src/java/org/apache/seda/thread/ThreadPool.java&r1=124636&p2=incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/ThreadPool.java&r2=124638 ============================================================================== --- incubator/directory/apseda/trunk/src/java/org/apache/seda/thread/ThreadPool.java (original) +++ incubator/directory/apseda/trunk/src/java/org/apache/apseda/thread/ThreadPool.java Fri Jan 7 22:41:35 2005 @@ -15,7 +15,7 @@ * */ -package org.apache.seda.thread; +package org.apache.apseda.thread; /**
