You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2008/05/21 10:01:38 UTC
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
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");
}
};
}