public interface InternalTopicMessage extends TopicMessage, com.pushtechnology.diffusion.message.InternalMessage
This extends the TopicMessage, and so instances are mutable. It would be better for the multiplexer to use an immutable message without the guff required to support the classic API, but that requires an changes to the TopicData and conflation APIs. We'll probably remove the publisher API before we can fix this.
EMPTY_FIELD, EMPTY_FIELD_CHAR, EMPTY_FIELD_STRING, FIELD_DELIMITER, FIELD_DELIMITER_CHAR, FIELD_DELIMITER_STRING, FIELD_MU, LIST_DELIMITER, LIST_DELIMITER_CHAR, LIST_DELIMITER_STRING, MESSAGE_SEPARATOR, MESSAGE_SEPARATOR_CHAR, RECORD_DELIMITER, RECORD_DELIMITER_CHAR, RECORD_DELIMITER_STRING, RECORD_MU
Modifier and Type | Method and Description |
---|---|
com.pushtechnology.diffusion.io.bytes.IBytes |
getBody() |
int |
getTopicId() |
String |
getTopicPath() |
InternalTopicMessage |
internalDuplicate()
Clone this message.
|
InternalTopicMessage |
internalDuplicate(String path,
int topicId)
Copy this message to one of the same type but for a different topic.
|
duplicate, getAckId, getAckTimeout, getTopicName, isAckPending, isAckRequired, isDelta, isFetchReply, isFor, isForTopic, isPagedLoad, isServiceLoad, isTopicLoad, isTopicNotifyLoad, setAckRequired, setAckTimeout
asByteBuffer, asBytes, asFields, asRecords, asRecords, asString, available, getCharset, getEncoding, getInputStream, getOutputStream, getReader, hasRemaining, length, nextByte, nextBytes, nextField, nextObject, nextRecord, nextRecord, put, put, put, put, put, putFields, putFields, putFields, putObject, putRecord, putRecord, putRecord, putRecords, putRecords, remaining, rewind, setCharset, setEncoding
getHeader, getHeaders, isTopicMessage, setHeaders, setHeaders, size, toMessage, toString
int getTopicId()
String getTopicPath()
InternalTopicMessage internalDuplicate()
Unlike the TopicMessage#duplicate()
method, the result shares
the body buffer with this instance.
InternalTopicMessage internalDuplicate(String path, int topicId)
Unlike the TopicMessage#duplicate()
method, the result shares
the body buffer with this instance.
com.pushtechnology.diffusion.io.bytes.IBytes getBody()
Copyright © 2016 Push Technology Ltd. All Rights Reserved.