public class StompFrame extends Object implements org.apache.activemq.command.Command
Modifier and Type | Field and Description |
---|---|
static byte[] |
NO_DATA |
Constructor and Description |
---|
StompFrame() |
StompFrame(String command) |
StompFrame(String command,
Map<String,String> headers) |
StompFrame(String command,
Map<String,String> headers,
byte[] data) |
Modifier and Type | Method and Description |
---|---|
String |
format() |
String |
format(boolean forLogging) |
String |
getAction() |
String |
getBody() |
int |
getCommandId() |
byte[] |
getContent() |
byte |
getDataStructureType() |
org.apache.activemq.command.Endpoint |
getFrom() |
Map<String,String> |
getHeaders() |
org.apache.activemq.command.Endpoint |
getTo() |
Object |
getTransportContext()
Transports may wish to associate additional data with the connection.
|
boolean |
isBrokerInfo() |
boolean |
isConnectionControl() |
boolean |
isConsumerControl() |
boolean |
isMarshallAware() |
boolean |
isMessage() |
boolean |
isMessageAck() |
boolean |
isMessageDispatch() |
boolean |
isMessageDispatchNotification() |
boolean |
isResponse() |
boolean |
isResponseRequired() |
boolean |
isShutdownInfo() |
boolean |
isWireFormatInfo() |
void |
setAction(String command) |
void |
setCommandId(int value) |
void |
setContent(byte[] data) |
void |
setFrom(org.apache.activemq.command.Endpoint from) |
void |
setHeaders(Map<String,String> headers) |
void |
setResponseRequired(boolean responseRequired) |
void |
setTo(org.apache.activemq.command.Endpoint to) |
void |
setTransportContext(Object transportContext)
Transports may wish to associate additional data with the connection.
|
String |
toString() |
org.apache.activemq.command.Response |
visit(org.apache.activemq.state.CommandVisitor visitor) |
public static final byte[] NO_DATA
public StompFrame(String command)
public StompFrame(String command, Map<String,String> headers)
public StompFrame(String command, Map<String,String> headers, byte[] data)
public StompFrame()
public byte[] getContent()
public void setContent(byte[] data)
public Map<String,String> getHeaders()
public void setHeaders(Map<String,String> headers)
public int getCommandId()
getCommandId
in interface org.apache.activemq.command.Command
public org.apache.activemq.command.Endpoint getFrom()
getFrom
in interface org.apache.activemq.command.Command
public org.apache.activemq.command.Endpoint getTo()
getTo
in interface org.apache.activemq.command.Command
public boolean isBrokerInfo()
isBrokerInfo
in interface org.apache.activemq.command.Command
public boolean isMessage()
isMessage
in interface org.apache.activemq.command.Command
public boolean isMessageAck()
isMessageAck
in interface org.apache.activemq.command.Command
public boolean isMessageDispatch()
isMessageDispatch
in interface org.apache.activemq.command.Command
public boolean isMessageDispatchNotification()
isMessageDispatchNotification
in interface org.apache.activemq.command.Command
public boolean isResponse()
isResponse
in interface org.apache.activemq.command.Command
public boolean isResponseRequired()
isResponseRequired
in interface org.apache.activemq.command.Command
public boolean isShutdownInfo()
isShutdownInfo
in interface org.apache.activemq.command.Command
public boolean isConnectionControl()
isConnectionControl
in interface org.apache.activemq.command.Command
public boolean isConsumerControl()
isConsumerControl
in interface org.apache.activemq.command.Command
public boolean isWireFormatInfo()
isWireFormatInfo
in interface org.apache.activemq.command.Command
public void setCommandId(int value)
setCommandId
in interface org.apache.activemq.command.Command
public void setFrom(org.apache.activemq.command.Endpoint from)
setFrom
in interface org.apache.activemq.command.Command
public void setResponseRequired(boolean responseRequired)
setResponseRequired
in interface org.apache.activemq.command.Command
public void setTo(org.apache.activemq.command.Endpoint to)
setTo
in interface org.apache.activemq.command.Command
public org.apache.activemq.command.Response visit(org.apache.activemq.state.CommandVisitor visitor) throws Exception
visit
in interface org.apache.activemq.command.Command
Exception
public byte getDataStructureType()
getDataStructureType
in interface org.apache.activemq.command.DataStructure
public boolean isMarshallAware()
isMarshallAware
in interface org.apache.activemq.command.DataStructure
public Object getTransportContext()
public void setTransportContext(Object transportContext)
transportContext
- value used to set the transport contextCopyright © 2005–2019 FuseSource, Corp.. All rights reserved.