Package org.apache.activemq.protobuf
Class DeferredDecodeMessage<T>
- java.lang.Object
-
- org.apache.activemq.protobuf.BaseMessage<T>
-
- org.apache.activemq.protobuf.DeferredDecodeMessage<T>
-
- All Implemented Interfaces:
Message<T>
- Direct Known Subclasses:
DeferredUnmarshal.Bar
,DeferredUnmarshal.Foo
public abstract class DeferredDecodeMessage<T> extends BaseMessage<T>
-
-
Field Summary
Fields Modifier and Type Field Description protected boolean
decoded
protected Buffer
encodedForm
-
Fields inherited from class org.apache.activemq.protobuf.BaseMessage
memoizedSerializedSize
-
-
Constructor Summary
Constructors Constructor Description DeferredDecodeMessage()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
clear()
boolean
isDecoded()
boolean
isEncoded()
protected void
load()
protected void
loadAndClear()
T
mergeFramed(CodedInputStream input)
T
mergeUnframed(Buffer data)
Buffer
toUnframedBuffer()
-
Methods inherited from class org.apache.activemq.protobuf.BaseMessage
addAll, assertInitialized, checktInitialized, clone, computeGroupSize, computeMessageSize, isInitialized, mergeFramed, mergeFramed, mergeFramed, mergeFrom, mergeUnframed, mergeUnframed, missingFields, prefix, readGroup, readRawByte, readRawVarint32, serializedSizeFramed, toFramedBuffer, toFramedByteArray, toUnframedByteArray, writeFramed, writeFramed, writeGroup, writeMessage, writeUnframed, writeUnframed
-
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.activemq.protobuf.Message
mergeUnframed, serializedSizeUnframed
-
-
-
-
Field Detail
-
encodedForm
protected Buffer encodedForm
-
decoded
protected boolean decoded
-
-
Method Detail
-
mergeFramed
public T mergeFramed(CodedInputStream input) throws java.io.IOException
- Specified by:
mergeFramed
in interfaceMessage<T>
- Overrides:
mergeFramed
in classBaseMessage<T>
- Throws:
java.io.IOException
-
mergeUnframed
public T mergeUnframed(Buffer data) throws InvalidProtocolBufferException
- Specified by:
mergeUnframed
in interfaceMessage<T>
- Overrides:
mergeUnframed
in classBaseMessage<T>
- Throws:
InvalidProtocolBufferException
-
toUnframedBuffer
public Buffer toUnframedBuffer()
- Specified by:
toUnframedBuffer
in interfaceMessage<T>
- Overrides:
toUnframedBuffer
in classBaseMessage<T>
-
load
protected void load()
- Overrides:
load
in classBaseMessage<T>
-
loadAndClear
protected void loadAndClear()
- Overrides:
loadAndClear
in classBaseMessage<T>
-
clear
public void clear()
-
isDecoded
public boolean isDecoded()
-
isEncoded
public boolean isEncoded()
-
-