svn commit: r925989 - in /camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina: MinaComponent.java MinaProducer.java

[davsclaus]

Author: davsclaus
Date: Mon Mar 22 07:58:28 2010
New Revision: 925989

URL: http://svn.apache.org/viewvc?rev=925989&view=rev
Log:
Polished code a bit

Modified:
    
camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java
    
camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaProducer.java

Modified: 
camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java?rev=925989&r1=925988&r2=925989&view=diff
==============================================================================
--- 
camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java
 (original)
+++ 
camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java
 Mon Mar 22 07:58:28 2010
@@ -242,7 +242,7 @@ public class MinaComponent extends Defau
                         + charset + " line delimiter: " + 
configuration.getTextlineDelimiter()
                         + "(" + delimiter + ")");
                 LOG.debug("Encoder maximum line length: " + 
codecFactory.getEncoderMaxLineLength()
-                        + "Decoder maximum line length: " + 
codecFactory.getDecoderMaxLineLength());
+                        + ". Decoder maximum line length: " + 
codecFactory.getDecoderMaxLineLength());
             }
         } else {
             ObjectSerializationCodecFactory codecFactory = new 
ObjectSerializationCodecFactory();

Modified: 
camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaProducer.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaProducer.java?rev=925989&r1=925988&r2=925989&view=diff
==============================================================================
--- 
camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaProducer.java
 (original)
+++ 
camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaProducer.java
 Mon Mar 22 07:58:28 2010
@@ -108,8 +108,8 @@ public class MinaProducer extends Defaul
         if (sync) {
             // wait for response, consider timeout
             LOG.debug("Waiting for response");
-            latch.await(timeout, TimeUnit.MILLISECONDS);
-            if (latch.getCount() == 1) {
+            boolean done = latch.await(timeout, TimeUnit.MILLISECONDS);
+            if (!done) {
                 throw new ExchangeTimedOutException(exchange, timeout);
             }