public class Message extends Object
Modifier and Type | Class and Description |
---|---|
static class |
Message.Command |
Modifier and Type | Field and Description |
---|---|
static String |
END_OF_MESSAGE |
static String |
HEADER_ACCEPT |
static String |
HEADER_ACK |
static String |
HEADER_CONTENT_LENGTH |
static String |
HEADER_CONTENT_TYPE |
static String |
HEADER_DESTINATION |
static String |
HEADER_HEART_BEAT |
static String |
HEADER_HOST |
static String |
HEADER_ID |
static String |
HEADER_MESSAGE |
static String |
HEADER_RECEIPT |
static String |
HEADER_RECEIPT_ID |
static String |
HEADER_REPLY_TO |
static String |
HEADER_TRANSACTION |
static byte[] |
HEARTBEAT_FRAME |
Constructor and Description |
---|
Message() |
Modifier and Type | Method and Description |
---|---|
Message |
abort() |
Message |
ack() |
Message |
begin() |
byte[] |
build() |
Message |
commit() |
Message |
connect() |
Message |
connected() |
Message |
disconnect() |
Message |
error() |
String |
getCommand() |
byte[] |
getContent() |
int |
getContentLength() |
Charset |
getEncoding() |
Map<String,String> |
getHeaders() |
Message |
message() |
static Message |
parse(byte[] array) |
Message |
receipt() |
Message |
send() |
Message |
subscribe() |
String |
toString() |
void |
trimEndOfMessage() |
Message |
unsubscribe() |
Message |
withAdditionalContent(byte[] additional) |
Message |
withContent(byte[] content) |
Message |
withHeader(String key,
String value) |
Message |
withHeaders(Map<String,String> headers) |
public static final String HEADER_DESTINATION
public static final String HEADER_REPLY_TO
public static final String HEADER_ACCEPT
public static final String HEADER_ID
public static final String HEADER_MESSAGE
public static final String HEADER_ACK
public static final String HEADER_TRANSACTION
public static final String HEADER_RECEIPT
public static final String HEADER_RECEIPT_ID
public static final String HEADER_CONTENT_LENGTH
public static final String HEADER_CONTENT_TYPE
public static final String HEADER_HEART_BEAT
public static final String HEADER_HOST
public static final String END_OF_MESSAGE
public static final byte[] HEARTBEAT_FRAME
public Message withContent(byte[] content)
public Message withAdditionalContent(byte[] additional)
public Message send()
public Message ack()
public Message subscribe()
public Message unsubscribe()
public Message begin()
public Message commit()
public Message abort()
public Message disconnect()
public Message connect()
public Message receipt()
public Message connected()
public Message error()
public Message message()
public byte[] build()
public String getCommand()
public byte[] getContent()
public static Message parse(byte[] array) throws ClientConnectionException
ClientConnectionException
public Charset getEncoding()
public int getContentLength()
public void trimEndOfMessage()
Copyright © 2016. All rights reserved.