Author: ningjiang
Date: Tue Mar 12 08:08:04 2013
New Revision: 1455433
URL: http://svn.apache.org/r1455433
Log:
CAMEL-6155 Fixed the systemStream flag issue
Modified:
camel/branches/camel-2.10.x/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java
Modified:
camel/branches/camel-2.10.x/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java
URL:
http://svn.apache.org/viewvc/camel/branches/camel-2.10.x/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java?rev=1455433&r1=1455432&r2=1455433&view=diff
==============================================================================
---
camel/branches/camel-2.10.x/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java
(original)
+++
camel/branches/camel-2.10.x/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java
Tue Mar 12 08:08:04 2013
@@ -180,7 +180,7 @@ public class StreamProducer extends Defa
// never close a standard stream (system.out or system.err)
// always close a 'header' stream (unless it's a system stream)
- boolean systemStream = outputStream != System.out || outputStream !=
System.err;
+ boolean systemStream = outputStream == System.out || outputStream ==
System.err;
boolean headerStream = "header".equals(uri);
boolean reachedLimit = endpoint.getAutoCloseCount() > 0 &&
count.decrementAndGet() <= 0;
boolean expiredStream = force || headerStream || reachedLimit; //
evaluation order is important!
