Author: trustin
Date: Mon Sep 17 03:23:56 2007
New Revision: 576347
URL: http://svn.apache.org/viewvc?rev=576347&view=rev
Log:
Fixed compiler warnings in StreamWriteFilter
Modified:
mina/trunk/core/src/main/java/org/apache/mina/filter/stream/StreamWriteFilter.java
Modified:
mina/trunk/core/src/main/java/org/apache/mina/filter/stream/StreamWriteFilter.java
URL:
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filter/stream/StreamWriteFilter.java?rev=576347&r1=576346&r2=576347&view=diff
==============================================================================
---
mina/trunk/core/src/main/java/org/apache/mina/filter/stream/StreamWriteFilter.java
(original)
+++
mina/trunk/core/src/main/java/org/apache/mina/filter/stream/StreamWriteFilter.java
Mon Sep 17 03:23:56 2007
@@ -29,7 +29,6 @@
import org.apache.mina.common.IoFilterAdapter;
import org.apache.mina.common.IoSession;
import org.apache.mina.common.WriteRequest;
-import org.apache.mina.common.IoFilter.NextFilter;
/**
* Filter implementation which makes it possible to write [EMAIL PROTECTED]
InputStream}
@@ -122,6 +121,10 @@
return (Queue<WriteRequest>) session.getAttribute(WRITE_REQUEST_QUEUE);
}
+ @SuppressWarnings("unchecked")
+ private Queue<WriteRequest> removeWriteRequestQueue(IoSession session) {
+ return (Queue<WriteRequest>)
session.removeAttribute(WRITE_REQUEST_QUEUE);
+ }
@Override
public void messageSent(NextFilter nextFilter, IoSession session,
WriteRequest writeRequest) throws Exception {
@@ -140,8 +143,7 @@
.removeAttribute(CURRENT_WRITE_REQUEST);
// Write queued WriteRequests.
- Queue<? extends WriteRequest> queue = (Queue<? extends
WriteRequest>) session
- .removeAttribute(WRITE_REQUEST_QUEUE);
+ Queue<WriteRequest> queue = removeWriteRequestQueue(session);
if (queue != null) {
WriteRequest wr = queue.poll();
while (wr != null) {
