Author: elecharny Date: Tue Mar 17 10:22:02 2009 New Revision: 755181 URL: http://svn.apache.org/viewvc?rev=755181&view=rev Log: Replaced the not thread safe CircularQueue by a ConcurentLinkedQueue. This solves DIRMINA-675.
Modified: mina/trunk/core/src/main/java/org/apache/mina/filter/codec/AbstractProtocolEncoderOutput.java Modified: mina/trunk/core/src/main/java/org/apache/mina/filter/codec/AbstractProtocolEncoderOutput.java URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filter/codec/AbstractProtocolEncoderOutput.java?rev=755181&r1=755180&r2=755181&view=diff ============================================================================== --- mina/trunk/core/src/main/java/org/apache/mina/filter/codec/AbstractProtocolEncoderOutput.java (original) +++ mina/trunk/core/src/main/java/org/apache/mina/filter/codec/AbstractProtocolEncoderOutput.java Tue Mar 17 10:22:02 2009 @@ -20,9 +20,9 @@ package org.apache.mina.filter.codec; import java.util.Queue; +import java.util.concurrent.ConcurrentLinkedQueue; import org.apache.mina.core.buffer.IoBuffer; -import org.apache.mina.util.CircularQueue; /** * A {...@link ProtocolEncoderOutput} based on queue. @@ -32,7 +32,8 @@ */ public abstract class AbstractProtocolEncoderOutput implements ProtocolEncoderOutput { - private final Queue<Object> messageQueue = new CircularQueue<Object>(); + private final Queue<Object> messageQueue = new ConcurrentLinkedQueue<Object>(); + private boolean buffersOnly = true; public AbstractProtocolEncoderOutput() {