svn commit: r658580 - in /activemq/camel/trunk/components/camel-mina/src: main/java/org/apache/camel/component/mina/MinaComponent.java main/java/org/apache/camel/component/mina/MinaConverter.java test/java/org/apache/camel/component/mina/MinaUdpTest.java

[ningjiang]

Author: ningjiang
Date: Wed May 21 01:01:37 2008
New Revision: 658580

URL: http://svn.apache.org/viewvc?rev=658580&view=rev
Log:
CAMEL-534 Fixed the camel mina udp throws exception [Already released buffer]

Modified:
    
activemq/camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java
    
activemq/camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaConverter.java
    
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpTest.java

Modified: 
activemq/camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java
URL: 
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java?rev=658580&r1=658579&r2=658580&view=diff
==============================================================================
--- 
activemq/camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java
 (original)
+++ 
activemq/camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java
 Wed May 21 01:01:37 2008
@@ -248,6 +248,7 @@
                         }
 
                         public void dispose(IoSession session) throws 
Exception {
+
                         }
                     };
                 }

Modified: 
activemq/camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaConverter.java
URL: 
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaConverter.java?rev=658580&r1=658579&r2=658580&view=diff
==============================================================================
--- 
activemq/camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaConverter.java
 (original)
+++ 
activemq/camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaConverter.java
 Wed May 21 01:01:37 2008
@@ -38,6 +38,8 @@
     public static byte[] toByteArray(ByteBuffer buffer) {
         byte[] answer = new byte[buffer.remaining()];
         buffer.get(answer);
+        // must acquire the Byte buffer to avoid release if more than twice
+        buffer.acquire();
         return answer;
     }
 

Modified: 
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpTest.java
URL: 
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpTest.java?rev=658580&r1=658579&r2=658580&view=diff
==============================================================================
--- 
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpTest.java
 (original)
+++ 
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpTest.java
 Wed May 21 01:01:37 2008
@@ -60,11 +60,8 @@
     protected RouteBuilder createRouteBuilder() {
         return new RouteBuilder() {
             public void configure() {
-                from("mina:udp://127.0.0.1:" + port).process(new Processor() {
-                    public void process(Exchange exchange) throws Exception {
-                        System.out.println("get a message");
-                    }
-                }).to("mock:result");
+                from("mina:udp://127.0.0.1:" + 
port).to("mina:udp://127.0.0.1:9000");
+                from("mina:udp://127.0.0.1:9000").to("mock:result");
             }
         };
     }