Package org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl

Class Message

java.lang.Object

org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message

public class Message
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	Message.Command

Field Summary

Fields

Modifier and Type	Field	Description
private static final String	CHARSET
private String	command
private byte[]	content
static final String	END_OF_MESSAGE
static final String	HEADER_ACCEPT
static final String	HEADER_ACK
static final String	HEADER_CONTENT_LENGTH
static final String	HEADER_CONTENT_TYPE
static final String	HEADER_CORRELATION_ID
static final String	HEADER_DESTINATION
static final String	HEADER_HEART_BEAT
static final String	HEADER_HOST
static final String	HEADER_ID
static final String	HEADER_MESSAGE
static final String	HEADER_RECEIPT
static final String	HEADER_RECEIPT_ID
static final String	HEADER_REPLY_TO
static final String	HEADER_TRANSACTION
private Map<String,String>	headers
static final byte[]	HEARTBEAT_FRAME
private static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
Message()

Method Summary

Modifier and Type	Method	Description
Message	abort()
Message	ack()
Message	begin()
byte[]	build()
Message	commit()
Message	connect()
Message	connected()
Message	disconnect()
Message	error()
String	getCommand()
byte[]	getContent()
private static byte[]	getContent(byte[] array, String[] message, int lineNumber)
int	getContentLength()
Charset	getEncoding()
Map<String,String>	getHeaders()
Message	message()
static Message	parse(byte[] array)
Message	receipt()
Message	send()
private Message	setCommand(String command)
Message	subscribe()
String	toString()
void	trimEndOfMessage()
Message	unsubscribe()
Message	withAdditionalContent(byte[] additional)
Message	withContent(byte[] content)
Message	withCorrelationId()
Message	withHeader(String key, String value)
Message	withHeaders(Map<String,String> headers)

Methods inherited from class java.lang.Object

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

Field Details

HEADER_DESTINATION

public static final String HEADER_DESTINATION

See Also:

• Constant Field Values

HEADER_REPLY_TO

public static final String HEADER_REPLY_TO

See Also:

• Constant Field Values

HEADER_ACCEPT

public static final String HEADER_ACCEPT

See Also:

• Constant Field Values

HEADER_ID

public static final String HEADER_ID

See Also:

• Constant Field Values

HEADER_MESSAGE

public static final String HEADER_MESSAGE

See Also:

• Constant Field Values

HEADER_ACK

public static final String HEADER_ACK

See Also:

• Constant Field Values

HEADER_TRANSACTION

public static final String HEADER_TRANSACTION

See Also:

• Constant Field Values

HEADER_RECEIPT

public static final String HEADER_RECEIPT

See Also:

• Constant Field Values

HEADER_RECEIPT_ID

public static final String HEADER_RECEIPT_ID

See Also:

• Constant Field Values

HEADER_CONTENT_LENGTH

public static final String HEADER_CONTENT_LENGTH

See Also:

• Constant Field Values

HEADER_CONTENT_TYPE

public static final String HEADER_CONTENT_TYPE

See Also:

• Constant Field Values

HEADER_HEART_BEAT

public static final String HEADER_HEART_BEAT

See Also:

• Constant Field Values

HEADER_HOST

public static final String HEADER_HOST

See Also:

• Constant Field Values

HEADER_CORRELATION_ID

public static final String HEADER_CORRELATION_ID

See Also:

• Constant Field Values

END_OF_MESSAGE

public static final String END_OF_MESSAGE

See Also:

• Constant Field Values

HEARTBEAT_FRAME

public static final byte[] HEARTBEAT_FRAME

CHARSET

private static final String CHARSET

See Also:

• Constant Field Values

LOG

private static final org.slf4j.Logger LOG

command

private String command

headers

private Map<String,String> headers

content

private byte[] content

Constructor Details

Message

public Message()

Method Details

withHeader

public Message withHeader(String key,
 String value)

withHeaders

public Message withHeaders(Map<String,String> headers)

withContent

public Message withContent(byte[] content)

withCorrelationId

public Message withCorrelationId()

withAdditionalContent

public Message withAdditionalContent(byte[] additional)

send

public Message send()

ack

public Message ack()

subscribe

public Message subscribe()

unsubscribe

public Message unsubscribe()

begin

public Message begin()

commit

public Message commit()

abort

public Message abort()

disconnect

public Message disconnect()

connect

public Message connect()

receipt

public Message receipt()

connected

public Message connected()

error

public Message error()

message

public Message message()

setCommand

private Message setCommand(String command)

build

public byte[] build()

getCommand

public String getCommand()

getHeaders

public Map<String,String> getHeaders()

getContent

public byte[] getContent()

parse

public static Message parse(byte[] array)
                     throws ClientConnectionException

Throws:

ClientConnectionException

getContent

private static byte[] getContent(byte[] array,
 String[] message,
 int lineNumber)

getEncoding

public Charset getEncoding()

getContentLength

public int getContentLength()

trimEndOfMessage

public void trimEndOfMessage()

toString

public String toString()

Overrides:

toString in class Object