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() {
