org.hornetq.core.protocol.stomp

Class StompFrame

java.lang.Object

org.hornetq.core.protocol.stomp.StompFrame

Direct Known Subclasses:

StompFrameV10, StompFrameV11, StompFrameV12

public class StompFrame
extends Object

Represents all the data in a STOMP frame.

Author:

chirino, Tim Fox

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	StompFrame.Header

Field Summary

Fields

Modifier and Type	Field and Description
protected HornetQBuffer	buffer
protected byte[]	bytesBody
protected String	command
protected Map<String,String>	headers
protected int	size

Constructor Summary

Constructors

Constructor and Description
StompFrame(String command)
StompFrame(String command, boolean disconnect)
StompFrame(String command, Map<String,String> headers, byte[] content)

Method Summary

Methods

Modifier and Type	Method and Description
void	addHeader(String key, String val)
String	escape(String str)
String	getBody()
byte[]	getBodyAsBytes()
String	getCommand()
int	getEncodedSize()
String	getHeader(String key)
Map<String,String>	getHeadersMap()
boolean	hasHeader(String key)
boolean	isPing()
boolean	needsDisconnect()
void	setBody(String body)
void	setByteBody(byte[] content)
void	setNeedsDisconnect(boolean b)
void	setPing(boolean ping)
HornetQBuffer	toHornetQBuffer()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

command

protected final String command

headers

protected final Map<String,String> headers

bytesBody

protected byte[] bytesBody

buffer

protected HornetQBuffer buffer

size

protected int size

Constructor Detail

StompFrame

public StompFrame(String command)

StompFrame

public StompFrame(String command,
          boolean disconnect)

StompFrame

public StompFrame(String command,
          Map<String,String> headers,
          byte[] content)

Method Detail

getCommand

public String getCommand()

getEncodedSize

public int getEncodedSize()
                   throws Exception

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object

isPing

public boolean isPing()

setPing

public void setPing(boolean ping)

toHornetQBuffer

public HornetQBuffer toHornetQBuffer()
                              throws Exception

Throws:

Exception

getHeader

public String getHeader(String key)

addHeader

public void addHeader(String key,
             String val)

getHeadersMap

public Map<String,String> getHeadersMap()

escape

public String escape(String str)

setBody

public void setBody(String body)
             throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

hasHeader

public boolean hasHeader(String key)

getBody

public String getBody()
               throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

getBodyAsBytes

public byte[] getBodyAsBytes()
                      throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

needsDisconnect

public boolean needsDisconnect()

setByteBody

public void setByteBody(byte[] content)

setNeedsDisconnect

public void setNeedsDisconnect(boolean b)