svn commit: r660494 - /incubator/qpid/branches/broker-queue-refactor/java/common/src/main/java/org/apache/qpid/pool/Job.java

[rg...@apache.org]

Author: rgodfrey
Date: Tue May 27 05:48:01 2008
New Revision: 660494

URL: http://svn.apache.org/viewvc?rev=660494&view=rev
Log:
Missed one...

Modified:
    incubator/qpid/branches/broker-queue-refactor/java/common/src/main/java/org/apache/qpid/pool/Job.java

Modified: incubator/qpid/branches/broker-queue-refactor/java/common/src/main/java/org/apache/qpid/pool/Job.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/broker-queue-refactor/java/common/src/main/java/org/apache/qpid/pool/Job.java?rev=660494&r1=660493&r2=660494&view=diff
==============================================================================
--- incubator/qpid/branches/broker-queue-refactor/java/common/src/main/java/org/apache/qpid/pool/Job.java (original)
+++ incubator/qpid/branches/broker-queue-refactor/java/common/src/main/java/org/apache/qpid/pool/Job.java Tue May 27 05:48:01 2008
@@ -50,7 +50,7 @@
  *
  * @todo For better re-usability could make the completion handler optional. Only run it when one is set.
  */
-public class Job implements Runnable
+public class Job implements ReadWriteRunnable
 {
     /** The maximum number of events to process per run of the job. More events than this may be queued in the job. */
     private final int _maxEvents;
@@ -166,6 +166,17 @@
         return _readJob;
     }
 
+    public boolean isRead()
+    {
+        return _readJob;
+    }
+
+    public boolean isWrite()
+    {
+        return !_readJob;
+    }
+
+
     /**
      * Another interface for a continuation.
      *