You are viewing a plain text version of this content. The canonical link for it is here.
Posted to cvs@avalon.apache.org by ra...@apache.org on 2002/04/26 16:32:20 UTC
cvs commit: jakarta-avalon-apps/ftpserver/src/java/org/apache/avalon/ftpserver/util AsyncMessageQueue.java
rana_b 02/04/26 07:32:20
Modified: ftpserver/src/java/org/apache/avalon/ftpserver/util
AsyncMessageQueue.java
Log:
queue max limit added
Revision Changes Path
1.4 +24 -2 jakarta-avalon-apps/ftpserver/src/java/org/apache/avalon/ftpserver/util/AsyncMessageQueue.java
Index: AsyncMessageQueue.java
===================================================================
RCS file: /home/cvs/jakarta-avalon-apps/ftpserver/src/java/org/apache/avalon/ftpserver/util/AsyncMessageQueue.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- AsyncMessageQueue.java 6 Mar 2002 13:42:57 -0000 1.3
+++ AsyncMessageQueue.java 26 Apr 2002 14:32:20 -0000 1.4
@@ -1,3 +1,4 @@
+// $Id: AsyncMessageQueue.java,v 1.4 2002/04/26 14:32:20 rana_b Exp $
/*
* Copyright (C) The Apache Software Foundation. All rights reserved.
*
@@ -41,6 +42,27 @@
}
/**
+ * Get the number of elements in the queue.
+ */
+ public int size() {
+ return mMsgQueue.size();
+ }
+
+ /**
+ * Get max size
+ */
+ public int getMaxSize() {
+ return mMsgQueue.getMaxSize();
+ }
+
+ /**
+ * Set max size
+ */
+ public void setMaxSize(int maxSize) {
+ mMsgQueue.setMaxSize(maxSize);
+ }
+
+ /**
* Thread starting point - get message ant execute.
*/
public void run() {
@@ -72,8 +94,8 @@
/**
* Check whether the message queue is active or not.
*/
- public boolean isStopped() {
+ public boolean isDisposed() {
return mbStopRequest;
}
-}
\ No newline at end of file
+}
--
To unsubscribe, e-mail: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>