You are viewing a plain text version of this content. The canonical link for it is here.
Posted to cvs@avalon.apache.org by bl...@apache.org on 2002/09/27 21:45:42 UTC
cvs commit: jakarta-avalon-excalibur/event/src/java/org/apache/excalibur/mpool DefaultPoolManager.java
bloritsch 2002/09/27 12:45:42
Modified: event/src/java/org/apache/excalibur/mpool
DefaultPoolManager.java
Log:
Change DefaultPoolManager to use Sink instead of a whole Queue
Revision Changes Path
1.3 +5 -5 jakarta-avalon-excalibur/event/src/java/org/apache/excalibur/mpool/DefaultPoolManager.java
Index: DefaultPoolManager.java
===================================================================
RCS file: /home/cvs/jakarta-avalon-excalibur/event/src/java/org/apache/excalibur/mpool/DefaultPoolManager.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- DefaultPoolManager.java 13 Aug 2002 08:15:20 -0000 1.2
+++ DefaultPoolManager.java 27 Sep 2002 19:45:42 -0000 1.3
@@ -52,7 +52,7 @@
import java.util.Iterator;
import java.util.Random;
import org.apache.avalon.excalibur.collections.BucketMap;
-import org.apache.excalibur.event.Queue;
+import org.apache.excalibur.event.Sink;
import org.apache.excalibur.event.command.RepeatedCommand;
/**
@@ -76,16 +76,16 @@
this( null );
}
- public DefaultPoolManager( final Queue commandQueue )
+ public DefaultPoolManager( final Sink commandSink )
{
m_keyGenerator = new Random();
m_managerKey = m_keyGenerator.nextLong();
- if( null != commandQueue )
+ if( null != commandSink )
{
try
{
- commandQueue.enqueue( new PoolManagerCommand( m_keyMap ) );
+ commandSink.enqueue( new PoolManagerCommand( m_keyMap ) );
}
catch( Exception e )
{
--
To unsubscribe, e-mail: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>