Package | Description |
---|---|
com.pushtechnology.diffusion.api |
The Diffusion API comprises a number of packages which provide access to
different aspects of Diffusion.
|
com.pushtechnology.diffusion.api.client |
Diffusion External Client API.
|
com.pushtechnology.diffusion.api.message | |
com.pushtechnology.diffusion.api.publisher |
Diffusion Internal Publisher API.
|
com.pushtechnology.diffusion.api.topic |
Diffusion Topics API.
|
Modifier and Type | Method and Description |
---|---|
TopicMessage |
ServerConnection.createDeltaMessage(String topicName)
Deprecated.
Creates an empty delta message.
|
TopicMessage |
ServerConnection.createDeltaMessage(String topicName,
int capacity)
Deprecated.
Creates an empty delta message.
|
TopicMessage |
ServerConnection.createLoadMessage(String topicName)
Deprecated.
Creates an empty load message.
|
TopicMessage |
ServerConnection.createLoadMessage(String topicName,
int capacity)
Deprecated.
Creates an empty load message.
|
Modifier and Type | Method and Description |
---|---|
TopicMessage |
ExternalClientConnection.createDeltaMessage(String topicName)
Deprecated.
|
TopicMessage |
ExternalClientConnection.createDeltaMessage(String topicName,
int capacity)
Deprecated.
|
TopicMessage |
ExternalClientConnection.createLoadMessage(String topicName)
Deprecated.
|
TopicMessage |
ExternalClientConnection.createLoadMessage(String topicName,
int capacity)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
Record.addField(int index,
String field)
Inserts a field at a specified index within the record, moving subsequent
fields along the record.
|
void |
Record.addFields(Collection<?> fields)
Adds one or more fields to the end of the record.
|
void |
Record.addFields(String... fields)
Adds one or more fields to the end of the record.
|
int |
Record.appendToField(String name,
Collection<?> values)
Appends one or more values to a repeating field.
|
int |
Record.appendToField(String name,
Object... values)
Appends one or more values to a repeating field.
|
ByteBuffer |
DataMessage.asByteBuffer()
Returns the whole message data content as a newly allocated ByteBuffer.
|
byte[] |
DataMessage.asBytes()
Returns the whole message as a new byte array.
|
List<String> |
DataMessage.asFields()
Returns the whole message body as fields.
|
List<Record> |
DataMessage.asRecords()
Returns the whole message body as records.
|
List<Record> |
DataMessage.asRecords(MRecord metadata)
Returns the whole message body as
records . |
String |
DataMessage.asString()
Returns the whole message body as a String.
|
int |
DataMessage.available()
Indicates the free space available for writing to in bytes.
|
static Record |
Record.createWithMetadata(MRecord metadata,
String emptyFieldValue,
String... fields)
This special factory method allows a Record with metadata to be created.
|
TopicMessage |
TopicMessage.duplicate()
Creates an exact duplicate of the message.
|
String |
Record.getField(int index)
Returns a specific field value within the record.
|
String |
Record.getField(String name)
Gets a field value by name.
|
String |
Record.getField(String name,
int index)
Get the value of a specified occurrence of a repeating field.
|
List<String> |
Record.getFieldValues(String name)
Gets a list of field values.
|
Object |
Record.getMappedField(String name)
Gets a field value as an object.
|
MessageReader |
DataMessage.getReader()
This returns a reader which may be used to perform relative read
operations on a message without affecting the pointers of the original
message.
|
boolean |
DataMessage.hasRemaining()
Indicates whether the message has any remaining data to read.
|
int |
DataMessage.length()
Returns the length of the data within the message in bytes.
|
byte |
MessageReader.nextByte()
Returns the next byte of data from the message.
|
byte |
DataMessage.nextByte()
Returns the next byte of data from the message.
|
void |
MessageReader.nextBytes(byte[] destination)
Returns data from the message as bytes from the current position.
|
void |
DataMessage.nextBytes(byte[] destination)
Returns data from the message as bytes from the current position.
|
String |
MessageReader.nextField()
Returns a field of string data from the current message position.
|
String |
DataMessage.nextField()
Returns a field of string data from the current message position.
|
Object |
DataMessage.nextObject()
Uses Java object serialization to read the content of the message into an
object.
|
Record |
MessageReader.nextRecord()
Returns a record of string data from the current message position.
|
Record |
DataMessage.nextRecord()
Returns a record of string data from the current message position.
|
Record |
MessageReader.nextRecord(MRecord metadata)
Returns a record of string data from the current message position using
a Metadata definition.
|
Record |
DataMessage.nextRecord(MRecord metadata)
Returns a record of string data from the current message position using a
metadata definition.
|
void |
DataMessage.put(byte data)
Relative put of a single byte of data.
|
void |
DataMessage.put(byte[] data)
Relative put of a byte array of data.
|
void |
DataMessage.put(ByteBuffer buffer)
Relative put of data from a ByteBuffer.
|
void |
DataMessage.put(DataMessage message)
Puts the entire content of another message into this message.
|
void |
DataMessage.put(String... data)
Relative put of String data.
|
void |
DataMessage.putFields(byte[]... fields)
Relative put of one or more byte array fields.
|
void |
DataMessage.putFields(Collection<?> fields)
Relative put of one or more fields.
|
void |
DataMessage.putFields(String... fields)
Relative put of one or more String fields.
|
void |
DataMessage.putObject(Object object)
Writes an object to the message using Java object serialization.
|
void |
DataMessage.putRecord(byte[]... fields)
Relative put of a set of byte array fields as a record.
|
void |
DataMessage.putRecord(Collection<?> fields)
Relative put of a collection of fields as a record.
|
void |
DataMessage.putRecord(String... fields)
Relative put of a set of String fields as a record.
|
void |
DataMessage.putRecords(Collection<Record> records)
Relative put of one or more Records from a
Collection . |
void |
DataMessage.putRecords(Record... records)
Relative put of one or more records.
|
int |
DataMessage.remaining()
Indicates the number of unread data bytes remaining within the message.
|
String |
Record.removeField(int index)
Removes a specified field from the record.
|
void |
DataMessage.rewind()
Resets the data pointer to the start of the data in preparation for
relative read ('next...') operations.
|
String |
TopicMessage.setAckRequired()
Sets the 'ACK Required' flag on the message.
|
void |
DataMessage.setCharset(String charset)
Sets the character set to be used by the message for byte/character
conversions.
|
void |
DataMessage.setEncoding(Encoding encoding)
Sets the byte encoding for the message.
|
void |
Record.setField(int index,
String field)
Replaces a field at a specified index within the record.
|
void |
Record.setField(String name,
int index,
Object value)
Sets a field value by name and index.
|
void |
Record.setField(String name,
Object... values)
Set field value(s) by name.
|
void |
Record.setFieldValues(String name,
Collection<?> values)
As
Record.setField(String, Object...) but allowing a collection of
values to be supplied. |
void |
Message.setHeaders(List<String> headers)
Sets user defined headers.
|
void |
Message.setHeaders(String... headers)
Sets user defined headers.
|
Constructor and Description |
---|
Record(MRecord metadata,
String... fields)
Create a Record with specified record metadata.
|
Modifier and Type | Method and Description |
---|---|
static TopicMessage |
Publishers.createDeltaMessage(String topicName)
Creates an empty delta message.
|
TopicMessage |
Publisher.createDeltaMessage(String topicName) |
static TopicMessage |
Publishers.createDeltaMessage(String topicName,
int capacity)
Creates an empty delta message.
|
TopicMessage |
Publisher.createDeltaMessage(String topicName,
int capacity) |
static AttachableTopicMessage |
Publishers.createDeltaMessage(String topicName,
int capacity,
Object attachment)
Creates an empty delta message.
|
static AttachableTopicMessage |
Publishers.createDeltaMessage(String topicName,
Object attachment)
Creates an empty delta message with an attachment.
|
static TopicMessage |
Publishers.createLoadMessage(String topicName)
Creates an empty Topic Load message.
|
TopicMessage |
Publisher.createLoadMessage(String topicName) |
static TopicMessage |
Publishers.createLoadMessage(String topicName,
int capacity)
Creates an empty Topic Load message.
|
TopicMessage |
Publisher.createLoadMessage(String topicName,
int capacity) |
void |
Client.setQueueNotificationThresholds(int lower,
int upper)
Sets queue notification thresholds.
|
Modifier and Type | Method and Description |
---|---|
TopicMessage |
Topic.createDeltaMessage()
Creates an empty delta message for the Topic.
|
TopicMessage |
Topic.createDeltaMessage(int capacity)
Creates an empty delta message for the Topic.
|
AttachableTopicMessage |
Topic.createDeltaMessage(int capacity,
Object attachment)
Creates an empty delta message for the Topic with an attachment.
|
AttachableTopicMessage |
Topic.createDeltaMessage(Object attachment)
Creates an empty delta message for the Topic with an attachment.
|
TopicMessage |
TopicProvider.createDeltaMessage(String topicName)
Creates an empty delta message.
|
TopicMessage |
TopicProvider.createDeltaMessage(String topicName,
int capacity)
Creates an empty delta message.
|
TopicMessage |
Topic.createLoadMessage()
Creates an empty Topic Load message for the Topic
|
TopicMessage |
Topic.createLoadMessage(int capacity)
Creates an empty Topic Load message for the Topic.
|
TopicMessage |
TopicProvider.createLoadMessage(String topicName)
Creates an empty Topic Load message.
|
TopicMessage |
TopicProvider.createLoadMessage(String topicName,
int capacity)
Creates an empty Topic Load message.
|
Copyright © 2016 Push Technology Ltd. All Rights Reserved.