Return-Path: Delivered-To: apmail-jakarta-avalon-cvs-archive@apache.org Received: (qmail 17918 invoked from network); 26 Apr 2002 14:32:23 -0000 Received: from unknown (HELO nagoya.betaversion.org) (192.18.49.131) by daedalus.apache.org with SMTP; 26 Apr 2002 14:32:23 -0000 Received: (qmail 4607 invoked by uid 97); 26 Apr 2002 14:32:24 -0000 Delivered-To: qmlist-jakarta-archive-avalon-cvs@jakarta.apache.org Received: (qmail 4585 invoked by uid 97); 26 Apr 2002 14:32:24 -0000 Mailing-List: contact avalon-cvs-help@jakarta.apache.org; run by ezmlm Precedence: bulk List-Unsubscribe: List-Subscribe: List-Help: List-Post: List-Id: "Avalon CVS List" Reply-To: "Avalon Developers List" Delivered-To: mailing list avalon-cvs@jakarta.apache.org Received: (qmail 4569 invoked by uid 97); 26 Apr 2002 14:32:23 -0000 Date: 26 Apr 2002 14:32:20 -0000 Message-ID: <20020426143220.4957.qmail@icarus.apache.org> From: rana_b@apache.org To: jakarta-avalon-apps-cvs@apache.org Subject: cvs commit: jakarta-avalon-apps/ftpserver/src/java/org/apache/avalon/ftpserver/util AsyncMessageQueue.java X-Spam-Rating: daedalus.apache.org 1.6.2 0/1000/N X-Spam-Rating: daedalus.apache.org 1.6.2 0/1000/N 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: For additional commands, e-mail: