Class Message
- java.lang.Object
-
- org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
-
public class Message extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Message.Command
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
END_OF_MESSAGE
static java.lang.String
HEADER_ACCEPT
static java.lang.String
HEADER_ACK
static java.lang.String
HEADER_CONTENT_LENGTH
static java.lang.String
HEADER_CONTENT_TYPE
static java.lang.String
HEADER_CORRELATION_ID
static java.lang.String
HEADER_DESTINATION
static java.lang.String
HEADER_HEART_BEAT
static java.lang.String
HEADER_HOST
static java.lang.String
HEADER_ID
static java.lang.String
HEADER_MESSAGE
static java.lang.String
HEADER_RECEIPT
static java.lang.String
HEADER_RECEIPT_ID
static java.lang.String
HEADER_REPLY_TO
static java.lang.String
HEADER_TRANSACTION
static byte[]
HEARTBEAT_FRAME
-
Constructor Summary
Constructors Constructor Description Message()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Message
abort()
Message
ack()
Message
begin()
byte[]
build()
Message
commit()
Message
connect()
Message
connected()
Message
disconnect()
Message
error()
java.lang.String
getCommand()
byte[]
getContent()
int
getContentLength()
java.nio.charset.Charset
getEncoding()
java.util.Map<java.lang.String,java.lang.String>
getHeaders()
Message
message()
static Message
parse(byte[] array)
Message
receipt()
Message
send()
Message
subscribe()
java.lang.String
toString()
void
trimEndOfMessage()
Message
unsubscribe()
Message
withAdditionalContent(byte[] additional)
Message
withContent(byte[] content)
Message
withCorrelationId()
Message
withHeader(java.lang.String key, java.lang.String value)
Message
withHeaders(java.util.Map<java.lang.String,java.lang.String> headers)
-
-
-
Field Detail
-
HEADER_DESTINATION
public static final java.lang.String HEADER_DESTINATION
- See Also:
- Constant Field Values
-
HEADER_REPLY_TO
public static final java.lang.String HEADER_REPLY_TO
- See Also:
- Constant Field Values
-
HEADER_ACCEPT
public static final java.lang.String HEADER_ACCEPT
- See Also:
- Constant Field Values
-
HEADER_ID
public static final java.lang.String HEADER_ID
- See Also:
- Constant Field Values
-
HEADER_MESSAGE
public static final java.lang.String HEADER_MESSAGE
- See Also:
- Constant Field Values
-
HEADER_ACK
public static final java.lang.String HEADER_ACK
- See Also:
- Constant Field Values
-
HEADER_TRANSACTION
public static final java.lang.String HEADER_TRANSACTION
- See Also:
- Constant Field Values
-
HEADER_RECEIPT
public static final java.lang.String HEADER_RECEIPT
- See Also:
- Constant Field Values
-
HEADER_RECEIPT_ID
public static final java.lang.String HEADER_RECEIPT_ID
- See Also:
- Constant Field Values
-
HEADER_CONTENT_LENGTH
public static final java.lang.String HEADER_CONTENT_LENGTH
- See Also:
- Constant Field Values
-
HEADER_CONTENT_TYPE
public static final java.lang.String HEADER_CONTENT_TYPE
- See Also:
- Constant Field Values
-
HEADER_HEART_BEAT
public static final java.lang.String HEADER_HEART_BEAT
- See Also:
- Constant Field Values
-
HEADER_HOST
public static final java.lang.String HEADER_HOST
- See Also:
- Constant Field Values
-
HEADER_CORRELATION_ID
public static final java.lang.String HEADER_CORRELATION_ID
- See Also:
- Constant Field Values
-
END_OF_MESSAGE
public static final java.lang.String END_OF_MESSAGE
- See Also:
- Constant Field Values
-
HEARTBEAT_FRAME
public static final byte[] HEARTBEAT_FRAME
-
-
Method Detail
-
withHeader
public Message withHeader(java.lang.String key, java.lang.String value)
-
withHeaders
public Message withHeaders(java.util.Map<java.lang.String,java.lang.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()
-
build
public byte[] build()
-
getCommand
public java.lang.String getCommand()
-
getHeaders
public java.util.Map<java.lang.String,java.lang.String> getHeaders()
-
getContent
public byte[] getContent()
-
parse
public static Message parse(byte[] array) throws ClientConnectionException
- Throws:
ClientConnectionException
-
getEncoding
public java.nio.charset.Charset getEncoding()
-
getContentLength
public int getContentLength()
-
trimEndOfMessage
public void trimEndOfMessage()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-