AckId | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
AckRequired | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
AckTimeout | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
AddFixedHeader(string header) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | virtual |
ApplyFixedHeaders(List< string > headers, IMessageHeaderTransformer headerTransformer) | PushTechnology.DiffusionCore.Messaging.CommandMessage | protectedvirtual |
PushTechnology::DiffusionCore::Messaging::DeltaMessage.ApplyFixedHeaders(System.Collections.Generic.List< string > headers, IMessageHeaderTransformer headerTransformer) | PushTechnology.DiffusionCore.Messaging.DeltaMessage | protected |
AsByteBuffer() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
AsBytes() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
AsFields() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
AsRecords() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
AsRecords(IMRecord metadata) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
AsString() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
Available() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
BufferPosition() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
BufferPosition(int position) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
Capacity() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | virtual |
Charset | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
CheckHeaders(int length, params string[] headers) | PushTechnology.DiffusionCore.Messaging.MessageImpl | protectedstatic |
Command | PushTechnology.DiffusionCore.Messaging.CommandMessage | |
CommandMessage(ByteBuffer buffer, TopicAliasMap aliasMap) | PushTechnology.DiffusionCore.Messaging.CommandMessage | |
CommandMessage(IExternalMessage message) | PushTechnology.DiffusionCore.Messaging.CommandMessage | |
CommandMessage(string topic, string command, TopicAliasMap topicAliasMap, int capacity) | PushTechnology.DiffusionCore.Messaging.CommandMessage | |
CompareTo(IMessage message) | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | virtual |
PushTechnology::DiffusionCore::Messaging::DataMessageImpl.CompareTo(IMessage message, MessageComparator comparator) | PushTechnology.DiffusionCore.Messaging.MessageImpl | virtual |
CreateDuplicateMessage(TopicAliasMap topicAliasMap) | PushTechnology.DiffusionCore.Messaging.CommandMessage | virtual |
DataMessageImpl(byte type, long initialSize) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
DataMessageImpl(IExternalMessage message) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
DataMessageImpl(byte type, int capacity) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | protected |
DataMessageImpl(byte type, int capacity, MessageEncodingType?encoding) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | protected |
DataMessageImpl(byte type) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
DataMessageImpl(byte type, ByteBuffer buffer, IMessageHeaderTransformer headerTransformer) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
DataPosition | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
Decode(bool keepEncoded) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
DeltaMessage(string topic, int capacity) | PushTechnology.DiffusionCore.Messaging.DeltaMessage | |
DeltaMessage(ByteBuffer buffer, TopicAliasMap topicAliasMap) | PushTechnology.DiffusionCore.Messaging.DeltaMessage | |
DeltaMessage(string topic, int capacity, TopicAliasMap topicAliasMap, bool setLengthOnWrite=true) | PushTechnology.DiffusionCore.Messaging.DeltaMessage | |
DeltaMessage(string topic, DataMessageImpl message) | PushTechnology.DiffusionCore.Messaging.DeltaMessage | |
DeltaMessage(string topic) | PushTechnology.DiffusionCore.Messaging.DeltaMessage | |
DeltaMessage(IExternalMessage message) | PushTechnology.DiffusionCore.Messaging.DeltaMessage | |
DeltaMessage(byte type, int capacity, TopicAliasMap topicAliasMap, params string[] headers) | PushTechnology.DiffusionCore.Messaging.DeltaMessage | |
Dispose() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
Duplicate() | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
EMPTY_FIELD_CHAR | PushTechnology.DiffusionCore.Messaging.MessageBase | static |
EMPTY_FIELD_STRING | PushTechnology.DiffusionCore.Messaging.MessageBase | static |
Encode() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
Equals(object obj) (defined in PushTechnology.DiffusionCore.Messaging.MessageImpl) | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
FIELD_DELIMITER | PushTechnology.DiffusionCore.Messaging.MessageBase | static |
FIELD_DELIMITER_CHAR | PushTechnology.DiffusionCore.Messaging.MessageBase | static |
FixedHeaders | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
GetAckId() | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | protectedvirtual |
GetAllHeaders() | PushTechnology.DiffusionCore.Messaging.MessageImpl | protected |
GetBufferForReading() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
GetBufferForWriting(ConnectionCapabilities capabilities) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | virtual |
GetHashCode() | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
GetHeader(int index) | PushTechnology.DiffusionCore.Messaging.MessageImpl | virtual |
GetHeaders() | PushTechnology.DiffusionCore.Messaging.MessageImpl | virtual |
GetMessageLength() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | virtual |
GetNumberOfFixedHeaders() | PushTechnology.DiffusionCore.Messaging.CommandMessage | protectedvirtual |
HasHeaders | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
HasRemaining | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
HasUserHeaders | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
HeaderLength | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
InputStream | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
InternalBuffer | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
IsAckPending | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
IsAckRequired() | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | virtual |
IsControlMessage() | PushTechnology.DiffusionCore.Messaging.MessageImpl | virtual |
IsDataMessage() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | virtual |
IsDelta | PushTechnology.DiffusionCore.Messaging.DeltaMessage | |
IsExpedited | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
IsFetchReply | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
IsFor(string topicPattern) | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
IsForTopic(string topicName) | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
IsLocked | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
IsPagedLoad | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
IsServiceLoad | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
IsTopicLoad | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
IsTopicMessage() | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | virtual |
IsTopicNotifyLoad | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
Length | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
LIST_DELIMITER | PushTechnology.DiffusionCore.Messaging.MessageBase | static |
LIST_DELIMITER_CHAR | PushTechnology.DiffusionCore.Messaging.MessageBase | static |
LIST_DELIMITER_STRING | PushTechnology.DiffusionCore.Messaging.MessageBase | static |
MESSAGE_DELIMITER | PushTechnology.DiffusionCore.Messaging.MessageBase | static |
MESSAGE_DELIMITER_CHAR | PushTechnology.DiffusionCore.Messaging.MessageBase | static |
MESSAGE_SEPARATOR | PushTechnology.DiffusionCore.Messaging.MessageBase | static |
MESSAGE_SEPARATOR_CHAR | PushTechnology.DiffusionCore.Messaging.MessageBase | static |
MessageDetails() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
MessageImpl(IExternalMessage message) | PushTechnology.DiffusionCore.Messaging.MessageImpl | protected |
MessageImpl(byte type) | PushTechnology.DiffusionCore.Messaging.MessageImpl | protected |
MessageImpl(byte type, ByteBuffer buffer, IMessageHeaderTransformer headerTransformer) | PushTechnology.DiffusionCore.Messaging.MessageImpl | protected |
MessageType | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
NextByte() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
NextByte(ByteBuffer buffer) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
NextBytes(byte[] destination) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
NextBytes(ByteBuffer buffer, byte[] destination) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
NextField(ByteBuffer buffer) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
NextField() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
NextRecord() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
NextRecord(IMRecord metadata) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
NextRecord(ByteBuffer buffer, IMRecord metadata) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
OutputStream | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
PendingAckId | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
Priority | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
Put(ByteBuffer buffer) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
Put(byte data) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
Put(byte[] data) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
Put(params string[] data) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
Put(IDataMessage message) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
PutFields(string[] fields) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
PutFields(params byte[] fields) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
PutObject(object obj) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
PutRecord(params string[] fields) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
PutRecord(params byte[] fields) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
PutRecords(params Record[] records) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
PutRecords(List< Record > records) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
Reader | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
RECORD_DELIMITER | PushTechnology.DiffusionCore.Messaging.MessageBase | static |
RECORD_DELIMITER_CHAR | PushTechnology.DiffusionCore.Messaging.MessageBase | static |
Remaining | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
Rewind() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
SetAckRequired() | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
SetBodyFromMessage(DataMessageImpl message) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
SetEncoding(byte encoding) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
SetFixedHeaders(TopicAliasMap topicAliasMap, params string[] headers) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | protected |
SetFixedHeaders(params string[] headers) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | protectedvirtual |
SetHeaderLength() | PushTechnology.DiffusionCore.Messaging.MessageImpl | protected |
SetHeaders(List< string > headers) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | virtual |
SetHeaders(params string[] headers) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | virtual |
SetMessageLengthOnWrite | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
SetTopicHeader(string topic, TopicAliasMap topicAliasMap) | PushTechnology.DiffusionCore.Messaging.DeltaMessage | protectedvirtual |
SetTopicName(string topicName) | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | protected |
Size() | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | virtual |
TheEncoding | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
theUserHeaders | PushTechnology.DiffusionCore.Messaging.MessageImpl | protected |
Timestamp | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
TopicMessageImpl(IExternalMessage message) | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | protected |
TopicMessageImpl(byte type, TopicMessageImpl message, List< string > additionalHeaders) | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | protected |
TopicMessageImpl(byte type, int capacity, TopicAliasMap topicAliasMap, params string[] headers) | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | protected |
TopicMessageImpl(byte type, string topic, int capacity, TopicAliasMap topicAliasMap) | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | protected |
TopicMessageImpl(byte type, string topic, TopicAliasMap topicAliasMap) | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | protected |
TopicMessageImpl(byte type, ByteBuffer buffer, IMessageHeaderTransformer topicAliasMap) | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | protected |
TopicMessageImpl(byte type, string topic, DataMessageImpl message) | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | protected |
TopicName | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
TopicNumber | PushTechnology.DiffusionCore.Messaging.Topic.TopicMessageImpl | |
ToString() (defined in PushTechnology.DiffusionCore.Messaging.DataMessageImpl) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |
Write(ByteBuffer buffer, ConnectionCapabilities capabilities) | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
Write(SslStream stream) | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
Write(ClientSocket socket) | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
Write(SslStream stream, ConnectionCapabilities capabilities, bool async) | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
Write(ClientSocket socket, ConnectionCapabilities capabilities) | PushTechnology.DiffusionCore.Messaging.MessageImpl | |
WriteToHttpBuffer(ByteBuffer buffer) | PushTechnology.DiffusionCore.Messaging.DataMessageImpl | |