public class WireFormatInfo extends java.lang.Object implements Command, MarshallAware
Modifier and Type | Field and Description |
---|---|
static byte |
DATA_STRUCTURE_TYPE |
protected byte[] |
magic |
protected ByteSequence |
marshalledProperties |
protected java.util.Map<java.lang.String,java.lang.Object> |
properties |
protected int |
version |
Constructor and Description |
---|
WireFormatInfo() |
Modifier and Type | Method and Description |
---|---|
void |
afterMarshall(WireFormat wireFormat) |
void |
afterUnmarshall(WireFormat wireFormat) |
void |
beforeMarshall(WireFormat wireFormat) |
void |
beforeUnmarshall(WireFormat wireFormat) |
void |
clearProperties() |
ByteSequence |
getCachedMarshalledForm(WireFormat wireFormat) |
int |
getCacheSize() |
int |
getCommandId() |
byte |
getDataStructureType() |
Endpoint |
getFrom()
The endpoint within the transport where this message came from.
|
byte[] |
getMagic() |
ByteSequence |
getMarshalledProperties() |
long |
getMaxFrameSize() |
long |
getMaxInactivityDuration() |
long |
getMaxInactivityDurationInitalDelay() |
java.util.Map<java.lang.String,java.lang.Object> |
getProperties() |
java.lang.Object |
getProperty(java.lang.String name) |
Endpoint |
getTo()
The endpoint within the transport where this message is going to - null
means all endpoints.
|
int |
getVersion() |
boolean |
isBrokerInfo() |
boolean |
isCacheEnabled() |
boolean |
isConnectionControl() |
boolean |
isMarshallAware() |
boolean |
isMessage() |
boolean |
isMessageAck() |
boolean |
isMessageDispatch() |
boolean |
isMessageDispatchNotification() |
boolean |
isResponse() |
boolean |
isResponseRequired() |
boolean |
isShutdownInfo() |
boolean |
isSizePrefixDisabled() |
boolean |
isStackTraceEnabled() |
boolean |
isTcpNoDelayEnabled() |
boolean |
isTightEncodingEnabled() |
boolean |
isValid() |
boolean |
isWireFormatInfo() |
protected void |
lazyCreateProperties() |
void |
setCachedMarshalledForm(WireFormat wireFormat,
ByteSequence data) |
void |
setCacheEnabled(boolean cacheEnabled) |
void |
setCacheSize(int cacheSize) |
void |
setCommandId(int value) |
void |
setFrom(Endpoint from) |
void |
setMagic(byte[] magic) |
void |
setMarshalledProperties(ByteSequence marshalledProperties) |
void |
setMaxFrameSize(long maxFrameSize) |
void |
setMaxInactivityDuration(long maxInactivityDuration) |
void |
setMaxInactivityDurationInitalDelay(long maxInactivityDurationInitalDelay) |
void |
setProperty(java.lang.String name,
java.lang.Object value) |
void |
setResponseRequired(boolean responseRequired) |
void |
setSizePrefixDisabled(boolean prefixPacketSize) |
void |
setStackTraceEnabled(boolean stackTraceEnabled) |
void |
setTcpNoDelayEnabled(boolean tcpNoDelayEnabled) |
void |
setTightEncodingEnabled(boolean tightEncodingEnabled) |
void |
setTo(Endpoint to) |
void |
setVersion(int version) |
java.lang.String |
toString() |
Response |
visit(CommandVisitor visitor) |
public static final byte DATA_STRUCTURE_TYPE
protected byte[] magic
protected int version
protected ByteSequence marshalledProperties
protected transient java.util.Map<java.lang.String,java.lang.Object> properties
public WireFormatInfo()
public byte getDataStructureType()
getDataStructureType
in interface DataStructure
public boolean isWireFormatInfo()
isWireFormatInfo
in interface Command
public boolean isMarshallAware()
isMarshallAware
in interface DataStructure
public byte[] getMagic()
public void setMagic(byte[] magic)
public int getVersion()
public void setVersion(int version)
public ByteSequence getMarshalledProperties()
public void setMarshalledProperties(ByteSequence marshalledProperties)
public Endpoint getTo()
public java.lang.Object getProperty(java.lang.String name) throws java.io.IOException
java.io.IOException
public java.util.Map<java.lang.String,java.lang.Object> getProperties() throws java.io.IOException
java.io.IOException
public void clearProperties()
public void setProperty(java.lang.String name, java.lang.Object value) throws java.io.IOException
java.io.IOException
protected void lazyCreateProperties() throws java.io.IOException
java.io.IOException
public void beforeMarshall(WireFormat wireFormat) throws java.io.IOException
beforeMarshall
in interface MarshallAware
java.io.IOException
public void afterMarshall(WireFormat wireFormat) throws java.io.IOException
afterMarshall
in interface MarshallAware
java.io.IOException
public void beforeUnmarshall(WireFormat wireFormat) throws java.io.IOException
beforeUnmarshall
in interface MarshallAware
java.io.IOException
public void afterUnmarshall(WireFormat wireFormat) throws java.io.IOException
afterUnmarshall
in interface MarshallAware
java.io.IOException
public boolean isValid()
public void setResponseRequired(boolean responseRequired)
setResponseRequired
in interface Command
public boolean isCacheEnabled() throws java.io.IOException
java.io.IOException
public void setCacheEnabled(boolean cacheEnabled) throws java.io.IOException
java.io.IOException
public boolean isStackTraceEnabled() throws java.io.IOException
java.io.IOException
public void setStackTraceEnabled(boolean stackTraceEnabled) throws java.io.IOException
java.io.IOException
public boolean isTcpNoDelayEnabled() throws java.io.IOException
java.io.IOException
public void setTcpNoDelayEnabled(boolean tcpNoDelayEnabled) throws java.io.IOException
java.io.IOException
public boolean isSizePrefixDisabled() throws java.io.IOException
java.io.IOException
public void setSizePrefixDisabled(boolean prefixPacketSize) throws java.io.IOException
java.io.IOException
public boolean isTightEncodingEnabled() throws java.io.IOException
java.io.IOException
public void setTightEncodingEnabled(boolean tightEncodingEnabled) throws java.io.IOException
java.io.IOException
public long getMaxInactivityDuration() throws java.io.IOException
java.io.IOException
public void setMaxInactivityDuration(long maxInactivityDuration) throws java.io.IOException
java.io.IOException
public long getMaxInactivityDurationInitalDelay() throws java.io.IOException
java.io.IOException
public void setMaxInactivityDurationInitalDelay(long maxInactivityDurationInitalDelay) throws java.io.IOException
java.io.IOException
public long getMaxFrameSize() throws java.io.IOException
java.io.IOException
public void setMaxFrameSize(long maxFrameSize) throws java.io.IOException
java.io.IOException
public int getCacheSize() throws java.io.IOException
java.io.IOException
public void setCacheSize(int cacheSize) throws java.io.IOException
java.io.IOException
public Response visit(CommandVisitor visitor) throws java.lang.Exception
public java.lang.String toString()
toString
in class java.lang.Object
public void setCommandId(int value)
setCommandId
in interface Command
public int getCommandId()
getCommandId
in interface Command
public boolean isResponseRequired()
isResponseRequired
in interface Command
public boolean isResponse()
isResponse
in interface Command
public boolean isBrokerInfo()
isBrokerInfo
in interface Command
public boolean isMessageDispatch()
isMessageDispatch
in interface Command
public boolean isMessageAck()
isMessageAck
in interface Command
public boolean isMessageDispatchNotification()
isMessageDispatchNotification
in interface Command
public boolean isShutdownInfo()
isShutdownInfo
in interface Command
public boolean isConnectionControl()
isConnectionControl
in interface Command
public void setCachedMarshalledForm(WireFormat wireFormat, ByteSequence data)
public ByteSequence getCachedMarshalledForm(WireFormat wireFormat)
Copyright © 2005-2017. All Rights Reserved.