svn commit: r746323 - in /activemq/sandbox/activemq-flow: pom.xml src/main/java/org/apache/activemq/dispatch/PriorityDispatcher.java

[chirino]

Author: chirino
Date: Fri Feb 20 18:26:23 2009
New Revision: 746323

URL: http://svn.apache.org/viewvc?rev=746323&view=rev
Log:
making more extensible

Modified:
    activemq/sandbox/activemq-flow/pom.xml
    
activemq/sandbox/activemq-flow/src/main/java/org/apache/activemq/dispatch/PriorityDispatcher.java

Modified: activemq/sandbox/activemq-flow/pom.xml
URL: 
http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/pom.xml?rev=746323&r1=746322&r2=746323&view=diff
==============================================================================
--- activemq/sandbox/activemq-flow/pom.xml (original)
+++ activemq/sandbox/activemq-flow/pom.xml Fri Feb 20 18:26:23 2009
@@ -43,12 +43,27 @@
       <artifactId>junit</artifactId>
       <scope>test</scope>
     </dependency>
+    
     <dependency>
       <groupId>log4j</groupId>
       <artifactId>log4j</artifactId>
       <scope>test</scope>
     </dependency>
     
+    <dependency>
+      <groupId>org.apache.mina</groupId>
+      <artifactId>mina-core</artifactId>
+      <version>2.0.0-M4</version>
+    </dependency>
+    <dependency>
+      <groupId>org.slf4j</groupId>
+      <artifactId>slf4j-api</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.slf4j</groupId>
+      <artifactId>slf4j-jcl</artifactId>
+    </dependency>
+    
   </dependencies>
 
   <build>

Modified: 
activemq/sandbox/activemq-flow/src/main/java/org/apache/activemq/dispatch/PriorityDispatcher.java
URL: 
http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/src/main/java/org/apache/activemq/dispatch/PriorityDispatcher.java?rev=746323&r1=746322&r2=746323&view=diff
==============================================================================
--- 
activemq/sandbox/activemq-flow/src/main/java/org/apache/activemq/dispatch/PriorityDispatcher.java
 (original)
+++ 
activemq/sandbox/activemq-flow/src/main/java/org/apache/activemq/dispatch/PriorityDispatcher.java
 Fri Feb 20 18:26:23 2009
@@ -33,7 +33,7 @@
     private Thread thread;
     protected boolean running = false;
     private boolean threaded = false;
-    private final int MAX_USER_PRIORITY;
+    protected final int MAX_USER_PRIORITY;
 
     // Set if this dispatcher is part of a dispatch pool:
     protected final PooledDispatcher<D> pooledDispatcher;
@@ -49,7 +49,7 @@
     // Timed Execution List
     protected final TimerHeap timerHeap = new TimerHeap();
 
-    private final String name;
+    protected final String name;
     private final AtomicBoolean foreignAvailable = new AtomicBoolean(false);
     private final Semaphore foreignPermits = new Semaphore(0);
 
@@ -156,14 +156,12 @@
      * 
      * @see org.apache.activemq.dispatch.IDispatcher#shutdown()
      */
-    public synchronized final void shutdown() throws InterruptedException {
+    public synchronized void shutdown() throws InterruptedException {
         if (thread != null) {
             dispatch(new RunnableAdapter(new Runnable() {
-
                 public void run() {
                     running = false;
                 }
-
             }), MAX_USER_PRIORITY + 1);
             // thread.interrupt();
             thread.join();