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 2001/12/14 14:50:49 UTC
cvs commit: jakarta-avalon-excalibur/src/scratchpad/org/apache/avalon/excalibur/event BlockingSink.java SourceClosedException.java SourceException.java SourceFullException.java TransactionalSource.java
bloritsch 01/12/14 05:50:49
Modified: src/scratchpad/org/apache/avalon/excalibur/event
BlockingSink.java SourceClosedException.java
SourceException.java SourceFullException.java
TransactionalSource.java
Log:
fix compile errors in CVS
Revision Changes Path
1.2 +3 -3 jakarta-avalon-excalibur/src/scratchpad/org/apache/avalon/excalibur/event/BlockingSink.java
Index: BlockingSink.java
===================================================================
RCS file: /home/cvs/jakarta-avalon-excalibur/src/scratchpad/org/apache/avalon/excalibur/event/BlockingSink.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- BlockingSink.java 2001/12/14 03:30:47 1.1
+++ BlockingSink.java 2001/12/14 13:50:49 1.2
@@ -21,7 +21,7 @@
*
* @return the next <code>QueueElement</code> on the queue
*/
- public QueueElement dequeue(int millis);
+ public QueueElement dequeue(long millis);
/**
* Dequeues all available elements, or returns <code>null</code> if there is
@@ -29,7 +29,7 @@
*
* @return all pending <code>QueueElement</code>s on the queue
*/
- public QueueElement[] dequeueAll(int millis);
+ public QueueElement[] dequeueAll(long millis);
/**
* Dequeues at most <code>num</code> available elements, or returns
@@ -37,6 +37,6 @@
*
* @return At most <code>num</code> <code>QueueElement</code>s on the queue
*/
- public QueueElement[] dequeue(int num, int millis);
+ public QueueElement[] dequeue(int num, long millis);
}
1.2 +9 -0 jakarta-avalon-excalibur/src/scratchpad/org/apache/avalon/excalibur/event/SourceClosedException.java
Index: SourceClosedException.java
===================================================================
RCS file: /home/cvs/jakarta-avalon-excalibur/src/scratchpad/org/apache/avalon/excalibur/event/SourceClosedException.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- SourceClosedException.java 2001/12/14 03:30:47 1.1
+++ SourceClosedException.java 2001/12/14 13:50:49 1.2
@@ -16,4 +16,13 @@
*/
public class SourceClosedException extends SourceException
{
+ public SourceClosedException( String message )
+ {
+ super( message );
+ }
+
+ public SourceClosedException( String message, Throwable e )
+ {
+ super( message, e );
+ }
}
1.2 +9 -0 jakarta-avalon-excalibur/src/scratchpad/org/apache/avalon/excalibur/event/SourceException.java
Index: SourceException.java
===================================================================
RCS file: /home/cvs/jakarta-avalon-excalibur/src/scratchpad/org/apache/avalon/excalibur/event/SourceException.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- SourceException.java 2001/12/14 03:30:47 1.1
+++ SourceException.java 2001/12/14 13:50:49 1.2
@@ -16,4 +16,13 @@
*/
public class SourceException extends CascadingException
{
+ public SourceException( String message )
+ {
+ super( message );
+ }
+
+ public SourceException( String message, Throwable e )
+ {
+ super( message, e );
+ }
}
1.2 +9 -0 jakarta-avalon-excalibur/src/scratchpad/org/apache/avalon/excalibur/event/SourceFullException.java
Index: SourceFullException.java
===================================================================
RCS file: /home/cvs/jakarta-avalon-excalibur/src/scratchpad/org/apache/avalon/excalibur/event/SourceFullException.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- SourceFullException.java 2001/12/14 03:30:47 1.1
+++ SourceFullException.java 2001/12/14 13:50:49 1.2
@@ -16,4 +16,13 @@
*/
public class SourceFullException extends SourceException
{
+ public SourceFullException( String message )
+ {
+ super( message );
+ }
+
+ public SourceFullException( String message, Throwable e )
+ {
+ super( message, e );
+ }
}
1.2 +6 -6 jakarta-avalon-excalibur/src/scratchpad/org/apache/avalon/excalibur/event/TransactionalSource.java
Index: TransactionalSource.java
===================================================================
RCS file: /home/cvs/jakarta-avalon-excalibur/src/scratchpad/org/apache/avalon/excalibur/event/TransactionalSource.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- TransactionalSource.java 2001/12/14 03:30:48 1.1
+++ TransactionalSource.java 2001/12/14 13:50:49 1.2
@@ -20,11 +20,11 @@
/**
* Support for transactional enqueue.
*
- * <p>This method allows a client to provisionally enqueue a number
+ * <p>This method allows a client to provisionally enqueue a number
* of elements onto the queue, and then later commit the enqueue (with
- * a <pre>commitEnqueue</code> call), or abort (with an
- * <code>abortEnqueue</code> call). This mechanism can be used to
- * perform "split-phase" enqueues, where a client first enqueues a
+ * a <pre>commitEnqueue</code> call), or abort (with an
+ * <code>abortEnqueue</code> call). This mechanism can be used to
+ * perform "split-phase" enqueues, where a client first enqueues a
* set of elements on the queue and then performs some work to "fill in"
* those elements before performing a commit. This can also be used
* to perform multi-queue transactional enqueue operations, with an
@@ -52,12 +52,12 @@
* @exception SourceFullException Indicates that the sink is temporarily full
* and that the requested elements could not be provisionally
* enqueued.
- * @exception SourceClosedException Indicates that the sink is
+ * @exception SourceClosedException Indicates that the sink is
* no longer being serviced.
*
* @see PreparedEnqueue
*/
- public PreparedEnqueue prepareEnqueue(QueueElementIF[] elements)
+ public PreparedEnqueue prepareEnqueue(QueueElement[] elements)
throws SourceException;
}
--
To unsubscribe, e-mail: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>