org.apache.activemq.command
Class WireFormatInfo
java.lang.Object
org.apache.activemq.command.WireFormatInfo
- All Implemented Interfaces:
- Command, DataStructure, MarshallAware
public class WireFormatInfo
- extends java.lang.Object
- implements Command, MarshallAware
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
DATA_STRUCTURE_TYPE
public static final byte DATA_STRUCTURE_TYPE
- See Also:
- Constant Field Values
magic
protected byte[] magic
version
protected int version
marshalledProperties
protected ByteSequence marshalledProperties
properties
protected transient java.util.Map<java.lang.String,java.lang.Object> properties
WireFormatInfo
public WireFormatInfo()
getDataStructureType
public byte getDataStructureType()
- Specified by:
getDataStructureType
in interface DataStructure
- Returns:
- The type of the data structure
isWireFormatInfo
public boolean isWireFormatInfo()
- Specified by:
isWireFormatInfo
in interface Command
isMarshallAware
public boolean isMarshallAware()
- Specified by:
isMarshallAware
in interface DataStructure
getMagic
public byte[] getMagic()
setMagic
public void setMagic(byte[] magic)
getVersion
public int getVersion()
setVersion
public void setVersion(int version)
getMarshalledProperties
public ByteSequence getMarshalledProperties()
setMarshalledProperties
public void setMarshalledProperties(ByteSequence marshalledProperties)
getFrom
public Endpoint getFrom()
- The endpoint within the transport where this message came from.
- Specified by:
getFrom
in interface Command
setFrom
public void setFrom(Endpoint from)
- Specified by:
setFrom
in interface Command
getTo
public Endpoint getTo()
- The endpoint within the transport where this message is going to - null
means all endpoints.
- Specified by:
getTo
in interface Command
setTo
public void setTo(Endpoint to)
- Specified by:
setTo
in interface Command
getProperty
public java.lang.Object getProperty(java.lang.String name)
throws java.io.IOException
- Throws:
java.io.IOException
getProperties
public java.util.Map<java.lang.String,java.lang.Object> getProperties()
throws java.io.IOException
- Throws:
java.io.IOException
clearProperties
public void clearProperties()
setProperty
public void setProperty(java.lang.String name,
java.lang.Object value)
throws java.io.IOException
- Throws:
java.io.IOException
lazyCreateProperties
protected void lazyCreateProperties()
throws java.io.IOException
- Throws:
java.io.IOException
beforeMarshall
public void beforeMarshall(WireFormat wireFormat)
throws java.io.IOException
- Specified by:
beforeMarshall
in interface MarshallAware
- Throws:
java.io.IOException
afterMarshall
public void afterMarshall(WireFormat wireFormat)
throws java.io.IOException
- Specified by:
afterMarshall
in interface MarshallAware
- Throws:
java.io.IOException
beforeUnmarshall
public void beforeUnmarshall(WireFormat wireFormat)
throws java.io.IOException
- Specified by:
beforeUnmarshall
in interface MarshallAware
- Throws:
java.io.IOException
afterUnmarshall
public void afterUnmarshall(WireFormat wireFormat)
throws java.io.IOException
- Specified by:
afterUnmarshall
in interface MarshallAware
- Throws:
java.io.IOException
isValid
public boolean isValid()
setResponseRequired
public void setResponseRequired(boolean responseRequired)
- Specified by:
setResponseRequired
in interface Command
isCacheEnabled
public boolean isCacheEnabled()
throws java.io.IOException
- Throws:
java.io.IOException
setCacheEnabled
public void setCacheEnabled(boolean cacheEnabled)
throws java.io.IOException
- Throws:
java.io.IOException
isStackTraceEnabled
public boolean isStackTraceEnabled()
throws java.io.IOException
- Throws:
java.io.IOException
setStackTraceEnabled
public void setStackTraceEnabled(boolean stackTraceEnabled)
throws java.io.IOException
- Throws:
java.io.IOException
isTcpNoDelayEnabled
public boolean isTcpNoDelayEnabled()
throws java.io.IOException
- Throws:
java.io.IOException
setTcpNoDelayEnabled
public void setTcpNoDelayEnabled(boolean tcpNoDelayEnabled)
throws java.io.IOException
- Throws:
java.io.IOException
isSizePrefixDisabled
public boolean isSizePrefixDisabled()
throws java.io.IOException
- Throws:
java.io.IOException
setSizePrefixDisabled
public void setSizePrefixDisabled(boolean prefixPacketSize)
throws java.io.IOException
- Throws:
java.io.IOException
isTightEncodingEnabled
public boolean isTightEncodingEnabled()
throws java.io.IOException
- Throws:
java.io.IOException
setTightEncodingEnabled
public void setTightEncodingEnabled(boolean tightEncodingEnabled)
throws java.io.IOException
- Throws:
java.io.IOException
getMaxInactivityDuration
public long getMaxInactivityDuration()
throws java.io.IOException
- Throws:
java.io.IOException
setMaxInactivityDuration
public void setMaxInactivityDuration(long maxInactivityDuration)
throws java.io.IOException
- Throws:
java.io.IOException
getMaxInactivityDurationInitalDelay
public long getMaxInactivityDurationInitalDelay()
throws java.io.IOException
- Throws:
java.io.IOException
setMaxInactivityDurationInitalDelay
public void setMaxInactivityDurationInitalDelay(long maxInactivityDurationInitalDelay)
throws java.io.IOException
- Throws:
java.io.IOException
getMaxFrameSize
public long getMaxFrameSize()
throws java.io.IOException
- Throws:
java.io.IOException
setMaxFrameSize
public void setMaxFrameSize(long maxFrameSize)
throws java.io.IOException
- Throws:
java.io.IOException
getCacheSize
public int getCacheSize()
throws java.io.IOException
- Throws:
java.io.IOException
setCacheSize
public void setCacheSize(int cacheSize)
throws java.io.IOException
- Throws:
java.io.IOException
visit
public Response visit(CommandVisitor visitor)
throws java.lang.Exception
- Specified by:
visit
in interface Command
- Throws:
java.lang.Exception
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
setCommandId
public void setCommandId(int value)
- Specified by:
setCommandId
in interface Command
getCommandId
public int getCommandId()
- Specified by:
getCommandId
in interface Command
- Returns:
- the unique ID of this request used to map responses to requests
isResponseRequired
public boolean isResponseRequired()
- Specified by:
isResponseRequired
in interface Command
isResponse
public boolean isResponse()
- Specified by:
isResponse
in interface Command
isBrokerInfo
public boolean isBrokerInfo()
- Specified by:
isBrokerInfo
in interface Command
isMessageDispatch
public boolean isMessageDispatch()
- Specified by:
isMessageDispatch
in interface Command
isMessage
public boolean isMessage()
- Specified by:
isMessage
in interface Command
isMessageAck
public boolean isMessageAck()
- Specified by:
isMessageAck
in interface Command
isMessageDispatchNotification
public boolean isMessageDispatchNotification()
- Specified by:
isMessageDispatchNotification
in interface Command
isShutdownInfo
public boolean isShutdownInfo()
- Specified by:
isShutdownInfo
in interface Command
isConnectionControl
public boolean isConnectionControl()
- Specified by:
isConnectionControl
in interface Command
setCachedMarshalledForm
public void setCachedMarshalledForm(WireFormat wireFormat,
ByteSequence data)
getCachedMarshalledForm
public ByteSequence getCachedMarshalledForm(WireFormat wireFormat)
Copyright © 2005-2012. All Rights Reserved.