svn commit: r1060810 - /axis/axis2/java/transports/trunk/modules/base/src/main/java/org/apache/axis2/transport/base/threads/watermark/DefaultWaterMarkQueue.java

[supun]

Author: supun
Date: Wed Jan 19 13:40:18 2011
New Revision: 1060810

URL: http://svn.apache.org/viewvc?rev=1060810&view=rev
Log:
fixing an issue with using a LinkedBlockingDequeu

Modified:
    
axis/axis2/java/transports/trunk/modules/base/src/main/java/org/apache/axis2/transport/base/threads/watermark/DefaultWaterMarkQueue.java

Modified: 
axis/axis2/java/transports/trunk/modules/base/src/main/java/org/apache/axis2/transport/base/threads/watermark/DefaultWaterMarkQueue.java
URL: 
http://svn.apache.org/viewvc/axis/axis2/java/transports/trunk/modules/base/src/main/java/org/apache/axis2/transport/base/threads/watermark/DefaultWaterMarkQueue.java?rev=1060810&r1=1060809&r2=1060810&view=diff
==============================================================================
--- 
axis/axis2/java/transports/trunk/modules/base/src/main/java/org/apache/axis2/transport/base/threads/watermark/DefaultWaterMarkQueue.java
 (original)
+++ 
axis/axis2/java/transports/trunk/modules/base/src/main/java/org/apache/axis2/transport/base/threads/watermark/DefaultWaterMarkQueue.java
 Wed Jan 19 13:40:18 2011
@@ -50,7 +50,7 @@ public class DefaultWaterMarkQueue<T> im
      * @param waterMark the waterMark of the queue
      */
     public DefaultWaterMarkQueue(int waterMark) {
-        afterWaterMarkQueue = new LinkedBlockingDeque<T>();
+        afterWaterMarkQueue = new LinkedBlockingQueue<T>();
 
         waterMarkQueue = new ArrayBlockingQueue<T>(waterMark);
     }