![]() |
Diffusion .NET Classic API - Core and Common
5.9.4
|
The interface for client connections to a Diffusion server. More...
Public Member Functions | |
void | Connect (TopicSet topics) |
void | Reconnect () |
void | Disconnect (bool notify, ServerConnectionState serverState=ServerConnectionState.Closed) |
void | Close (bool notify, bool async, ServerConnectionState serverState=ServerConnectionState.Closed) |
void | FlushNetworkStream () |
void | WriteMessage (MessageBase message, bool async) |
void | SendBytes (byte[] bytes) |
void | Send (MessageBase message) |
Send a topic message. More... | |
void | AddTopicListener (ITopicListener listener, TopicSet topics) |
void | AddTopicListener (ITopicListener listener, params string[] topics) |
void | AddTopicListener (TopicListenerImpl listener) |
bool | RemoveTopicListener (ITopicListener listener) |
void | Subscribe (TopicSet topics, Action< TopicMessageImpl > messageMethod) |
void | Fetch (TopicSet topics, params string[] headers) |
void | Fetch (string topic, params string[] headers) |
void | ServerPing (ServerPingMessageImpl message) |
void | ClientPing (string timeStamp) |
void | ServerItlAck (long timeout) |
void | ServerDeltaAck (long timeout) |
bool | Acknowledge (ITopicMessage message) |
Acknowledges a message that is 'pending acknowledgement'. More... | |
![]() | |
ITopicMessage | CreateDeltaMessage (string topic) |
Create a delta topic message. More... | |
ITopicMessage | CreateDeltaMessage (string topic, int capacity) |
Create a delta message with a default capacity. More... | |
ITopicMessage | CreateLoadMessage (string topic) |
Create a topic load message. More... | |
ITopicMessage | CreateLoadMessage (string topic, int capacity) |
Create a topic load message with a default capacity. More... | |
void | Subscribe (params string[] topics) |
Subscribe to topics. More... | |
void | Subscribe (TopicSet topics) |
Subscribe to a topic given a TopicSet. More... | |
void | Unsubscribe (params string[] topics) |
Unsubscribe from topics. More... | |
void | Unsubscribe (TopicSet topics) |
Unsubscribe from topics given a TopicSet. More... | |
Properties | |
DateTime | LastInteraction [get] |
bool | IsReconnected [get] |
int | ServerProtocolVersion [get] |
TopicSet | Topics [get] |
bool | IsConnected [get] |
IServerDetails | ServerDetails [get] |
string | ClientId [get] |
int | MaxPacketSize [get] |
ClientTransportType | TransportType [get] |
bool | AutoClientAcqRequired [get] |
TopicAliasMap | TopicAliasMap [get] |
TopicListeners | TopicListeners [get] |
The interface for client connections to a Diffusion server.
bool PushTechnology.DiffusionCore.Connection.Interfaces.IDiffusionClientConnector.Acknowledge | ( | ITopicMessage | message | ) |
Acknowledges a message that is 'pending acknowledgement'.
Assuming the message is pending acknowledgement, then a message of acknowledgement is sent to the server.
message |
void PushTechnology.DiffusionCore.Connection.Interfaces.IDiffusionClientConnector.Send | ( | MessageBase | message | ) |
Send a topic message.
message | The message to send. |
Implements PushTechnology.DiffusionCore.Connection.IDiffusionMessagingConnector.