summaryrefslogtreecommitdiff
path: root/qpid/java/common/templates/method/version
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2011-09-09 17:47:22 +0000
committerRobert Godfrey <rgodfrey@apache.org>2011-09-09 17:47:22 +0000
commit12be577752c99481d0bab5ab607f81fd5416a24e (patch)
treec4d29302e6ca7d87cd55473bdd6cc47d4cc1015d /qpid/java/common/templates/method/version
parent62f9583c410b84e354880dd08e4b6862fdfd35b3 (diff)
downloadqpid-python-12be577752c99481d0bab5ab607f81fd5416a24e.tar.gz
QPID-2627 : Remove dependency on MINA
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1167311 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common/templates/method/version')
-rw-r--r--qpid/java/common/templates/method/version/MethodBodyClass.vm10
1 files changed, 6 insertions, 4 deletions
diff --git a/qpid/java/common/templates/method/version/MethodBodyClass.vm b/qpid/java/common/templates/method/version/MethodBodyClass.vm
index a739110d70..ce8a453eeb 100644
--- a/qpid/java/common/templates/method/version/MethodBodyClass.vm
+++ b/qpid/java/common/templates/method/version/MethodBodyClass.vm
@@ -46,9 +46,11 @@
package org.apache.qpid.framing.amqp_$version.getMajor()_$version.getMinor();
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
import java.util.HashMap;
-import org.apache.mina.common.ByteBuffer;
import org.apache.qpid.framing.*;
import org.apache.qpid.AMQException;
@@ -56,7 +58,7 @@ public class ${javaClassName} extends AMQMethodBody_$version.getMajor()_$version
{
private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
{
- public AMQMethodBody newInstance(ByteBuffer in, long size) throws AMQFrameDecodingException
+ public AMQMethodBody newInstance(DataInputStream in, long size) throws AMQFrameDecodingException, IOException
{
return new ${javaClassName}(in);
}
@@ -84,7 +86,7 @@ public class ${javaClassName} extends AMQMethodBody_$version.getMajor()_$version
// Constructor
- public ${javaClassName}(ByteBuffer buffer) throws AMQFrameDecodingException
+ public ${javaClassName}(DataInputStream buffer) throws AMQFrameDecodingException, IOException
{
#foreach( $field in $method.ConsolidatedFields )
_$field.Name = read$field.getEncodingType()( buffer );
@@ -169,7 +171,7 @@ public class ${javaClassName} extends AMQMethodBody_$version.getMajor()_$version
return size;
}
- public void writeMethodPayload(ByteBuffer buffer)
+ public void writeMethodPayload(DataOutputStream buffer) throws IOException
{
#foreach( $field in $method.ConsolidatedFields )
write$field.getEncodingType()( buffer, _$field.Name );