public class org.apache.activemq.console.command.store.proto.QueueEntryPB extends java.lang.Object implements org.fusesource.hawtbuf.proto.PBMessageFactory
{
public static final org.apache.activemq.console.command.store.proto.QueueEntryPB FACTORY;
public static final org.fusesource.hawtbuf.proto.PBMessageFramedCodec FRAMED_CODEC;
public static final org.fusesource.hawtbuf.proto.PBMessageUnframedCodec UNFRAMED_CODEC;
public void <init>()
{
org.apache.activemq.console.command.store.proto.QueueEntryPB v;
v := @this: org.apache.activemq.console.command.store.proto.QueueEntryPB;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean create()
{
org.apache.activemq.console.command.store.proto.QueueEntryPB v;
org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean v;
v := @this: org.apache.activemq.console.command.store.proto.QueueEntryPB;
v = new org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean;
specialinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean: void <init>()>();
return v;
}
public org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean parseUnframed(org.fusesource.hawtbuf.proto.CodedInputStream) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException
{
org.apache.activemq.console.command.store.proto.QueueEntryPB v;
org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean v, v;
org.fusesource.hawtbuf.proto.CodedInputStream v;
v := @this: org.apache.activemq.console.command.store.proto.QueueEntryPB;
v := @parameter: org.fusesource.hawtbuf.proto.CodedInputStream;
v = new org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean;
specialinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean: org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean mergeUnframed(org.fusesource.hawtbuf.proto.CodedInputStream)>(v);
return v;
}
public org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean parseUnframed(java.io.InputStream) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException
{
org.apache.activemq.console.command.store.proto.QueueEntryPB v;
java.io.InputStream v;
org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean v;
org.fusesource.hawtbuf.proto.CodedInputStream v;
v := @this: org.apache.activemq.console.command.store.proto.QueueEntryPB;
v := @parameter: java.io.InputStream;
v = new org.fusesource.hawtbuf.proto.CodedInputStream;
specialinvoke v.<org.fusesource.hawtbuf.proto.CodedInputStream: void <init>(java.io.InputStream)>(v);
v = virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB: org.apache.activemq.console.command.store.proto.QueueEntryPB$Bean parseUnframed(org.fusesource.hawtbuf.proto.CodedInputStream)>(v);
return v;
}
public org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer parseUnframed(org.fusesource.hawtbuf.Buffer) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException
{
org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.console.command.store.proto.QueueEntryPB v;
v := @this: org.apache.activemq.console.command.store.proto.QueueEntryPB;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = new org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer;
specialinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer: void <init>(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
public org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer parseUnframed(byte[]) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException
{
byte[] v;
org.apache.activemq.console.command.store.proto.QueueEntryPB v;
org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer v;
org.fusesource.hawtbuf.Buffer v;
v := @this: org.apache.activemq.console.command.store.proto.QueueEntryPB;
v := @parameter: byte[];
v = new org.fusesource.hawtbuf.Buffer;
specialinvoke v.<org.fusesource.hawtbuf.Buffer: void <init>(byte[])>(v);
v = virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB: org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer parseUnframed(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
public org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer parseFramed(org.fusesource.hawtbuf.proto.CodedInputStream) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException
{
org.apache.activemq.console.command.store.proto.QueueEntryPB v;
int v, v;
org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer v;
org.fusesource.hawtbuf.Buffer v;
org.fusesource.hawtbuf.proto.CodedInputStream v;
v := @this: org.apache.activemq.console.command.store.proto.QueueEntryPB;
v := @parameter: org.fusesource.hawtbuf.proto.CodedInputStream;
v = virtualinvoke v.<org.fusesource.hawtbuf.proto.CodedInputStream: int readRawVarint32()>();
v = virtualinvoke v.<org.fusesource.hawtbuf.proto.CodedInputStream: int pushLimit(int)>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.proto.CodedInputStream: org.fusesource.hawtbuf.Buffer readRawBytes(int)>(v);
v = virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB: org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer parseUnframed(org.fusesource.hawtbuf.Buffer)>(v);
virtualinvoke v.<org.fusesource.hawtbuf.proto.CodedInputStream: void popLimit(int)>(v);
return v;
}
public org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer parseFramed(org.fusesource.hawtbuf.Buffer) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException
{
org.fusesource.hawtbuf.proto.InvalidProtocolBufferException v;
org.apache.activemq.console.command.store.proto.QueueEntryPB v;
java.io.IOException v;
org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer v;
java.lang.RuntimeException v;
org.fusesource.hawtbuf.Buffer v;
org.fusesource.hawtbuf.proto.CodedInputStream v;
v := @this: org.apache.activemq.console.command.store.proto.QueueEntryPB;
v := @parameter: org.fusesource.hawtbuf.Buffer;
label:
v = new org.fusesource.hawtbuf.proto.CodedInputStream;
specialinvoke v.<org.fusesource.hawtbuf.proto.CodedInputStream: void <init>(org.fusesource.hawtbuf.Buffer)>(v);
v = virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB: org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer parseFramed(org.fusesource.hawtbuf.proto.CodedInputStream)>(v);
virtualinvoke v.<org.fusesource.hawtbuf.proto.CodedInputStream: void checkLastTagWas(int)>(0);
label:
return v;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>("An IOException was thrown (should never happen in this method).", v);
throw v;
catch org.fusesource.hawtbuf.proto.InvalidProtocolBufferException from label to label with label;
catch java.io.IOException from label to label with label;
}
public org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer parseFramed(byte[]) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException
{
byte[] v;
org.apache.activemq.console.command.store.proto.QueueEntryPB v;
org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer v;
org.fusesource.hawtbuf.Buffer v;
v := @this: org.apache.activemq.console.command.store.proto.QueueEntryPB;
v := @parameter: byte[];
v = new org.fusesource.hawtbuf.Buffer;
specialinvoke v.<org.fusesource.hawtbuf.Buffer: void <init>(byte[])>(v);
v = virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB: org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer parseFramed(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
public org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer parseFramed(java.io.InputStream) throws org.fusesource.hawtbuf.proto.InvalidProtocolBufferException, java.io.IOException
{
org.apache.activemq.console.command.store.proto.QueueEntryPB v;
org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer v;
org.fusesource.hawtbuf.Buffer v;
java.io.InputStream v;
v := @this: org.apache.activemq.console.command.store.proto.QueueEntryPB;
v := @parameter: java.io.InputStream;
v = staticinvoke <org.fusesource.hawtbuf.proto.MessageBufferSupport: org.fusesource.hawtbuf.Buffer readFrame(java.io.InputStream)>(v);
v = virtualinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB: org.apache.activemq.console.command.store.proto.QueueEntryPB$Buffer parseUnframed(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
static void <clinit>()
{
org.fusesource.hawtbuf.proto.PBMessageUnframedCodec v;
org.apache.activemq.console.command.store.proto.QueueEntryPB v, v, v;
org.fusesource.hawtbuf.proto.PBMessageFramedCodec v;
v = new org.apache.activemq.console.command.store.proto.QueueEntryPB;
specialinvoke v.<org.apache.activemq.console.command.store.proto.QueueEntryPB: void <init>()>();
<org.apache.activemq.console.command.store.proto.QueueEntryPB: org.apache.activemq.console.command.store.proto.QueueEntryPB FACTORY> = v;
v = new org.fusesource.hawtbuf.proto.PBMessageFramedCodec;
v = <org.apache.activemq.console.command.store.proto.QueueEntryPB: org.apache.activemq.console.command.store.proto.QueueEntryPB FACTORY>;
specialinvoke v.<org.fusesource.hawtbuf.proto.PBMessageFramedCodec: void <init>(org.fusesource.hawtbuf.proto.PBMessageFactory)>(v);
<org.apache.activemq.console.command.store.proto.QueueEntryPB: org.fusesource.hawtbuf.proto.PBMessageFramedCodec FRAMED_CODEC> = v;
v = new org.fusesource.hawtbuf.proto.PBMessageUnframedCodec;
v = <org.apache.activemq.console.command.store.proto.QueueEntryPB: org.apache.activemq.console.command.store.proto.QueueEntryPB FACTORY>;
specialinvoke v.<org.fusesource.hawtbuf.proto.PBMessageUnframedCodec: void <init>(org.fusesource.hawtbuf.proto.PBMessageFactory)>(v);
<org.apache.activemq.console.command.store.proto.QueueEntryPB: org.fusesource.hawtbuf.proto.PBMessageUnframedCodec UNFRAMED_CODEC> = v;
return;
}
}