wrote
package org.openamq.framing;
import org.apache.mina.common.ByteBuffer;
/**
* This class is autogenerated, do not modify. [From ]
*/
public class extends AMQMethodBody implements EncodableAMQDataBlock
{
public static final int CLASS_ID = ;
public static final int METHOD_ID = ;
public
;
protected int getClazz()
{
return ;
}
protected int getMethod()
{
return ;
}
protected int getBodySize()
{
return
+
;
return 0;
}
protected void writeMethodPayload(ByteBuffer buffer)
{
;
EncodingUtils.writeBooleans(buffer, new boolean[]{
});
}
public void populateMethodBodyFromBuffer(ByteBuffer buffer) throws AMQFrameDecodingException
{
;
}
public String toString()
{
StringBuffer buf = new StringBuffer(super.toString());
buf.append(" : ").append();
return buf.toString();
}
public static AMQFrame createAMQFrame(int channelId, )
{
body = new ();
;
AMQFrame frame = new AMQFrame();
frame.channel = channelId;
frame.bodyFrame = body;
return frame;
}
}
Matching root for registry mode!
Wrote MethodBodyDecoderRegistry.java
package org.openamq.framing;
import java.util.Map;
import java.util.HashMap;
import org.apache.log4j.Logger;
import org.openamq.AMQException;
/**
* This class is autogenerated, do not modify.
*/
public final class MethodBodyDecoderRegistry
{
private static final Logger _log = Logger.getLogger(MethodBodyDecoderRegistry.class);
private static final Map _classMethodProductToMethodBodyMap = new HashMap();
static
{
;
}
public static AMQMethodBody get(int clazz, int method) throws AMQFrameDecodingException
{
Class bodyClass = (Class) _classMethodProductToMethodBodyMap.get(new Integer(clazz * 1000 + method));
if (bodyClass != null)
{
try
{
return (AMQMethodBody) bodyClass.newInstance();
}
catch (Exception e)
{
throw new AMQFrameDecodingException(_log, "Unable to instantiate body class for class " + clazz + " and method " + method + ": " + e, e);
}
}
else
{
throw new AMQFrameDecodingException(_log, "Unable to find a suitable decoder for class " + clazz + " and method " + method);
}
}
}
wrote
package org.openamq.framing;
import java.util.Map;
/**
* This class is autogenerated, do not modify. [From ]
*/
class
{
static void register(Map map)
{
map.put(new Integer(
* 1000 +
),
);
}
}