![]() |
Diffusion .NET Classic API - Core and Common
5.9.4
|
Represents a diffusion client TCP connection. More...
Additional Inherited Members | |
![]() | |
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... | |
![]() | |
void | CreateDiffusionConnection (string data, bool async) |
void | HandleBufferMessage (Byte[] message) |
void | WriteBufferToChannel (ByteBuffer buffer) |
void | WriteBytesToChannel (byte[] bytes) |
![]() | |
void | RaiseServerPingReceivedEvent (MessageImpl message, IDiffusionClientConnector connector) |
Raise the 'server ping received' message event. More... | |
void | RaisePingResponseReceivedEvent (MessageImpl message, IDiffusionClientConnector connector) |
Raise the ping response received message event. More... | |
void | RaiseCredentialsRejectedEvent (MessageImpl message, IDiffusionClientConnector connector) |
Raise the credentials rejected message event. More... | |
void | RaiseTopicMessageReceivedEvent (TopicMessageImpl message, IDiffusionClientConnector connector) |
Raise the topic message received event. More... | |
void | RaiseTopicStatusChangedEvent (TopicStatusMessage message, IDiffusionClientConnector connector) |
Raise the topic status changed event. More... | |
void | RaiseServerConnectedEvent (IDiffusionClientConnector connector) |
Raise the server connected event. More... | |
void | RaiseServerConnectionAttemptFailedEvent (ServerClosedEventArgs args, IDiffusionClientConnector connector) |
Raise the server connection failure event. More... | |
void | RaiseServerDisconnectedEvent (ServerClosedEventArgs args, IDiffusionClientConnector connector) |
Raise the server disconnected event. More... | |
void | RaiseServerRejectedCredentialsEvent (V4Credentials credentials, IDiffusionClientConnector connector) |
Raise the server rejected credentials event. More... | |
void | RaiseMessageAcknowledgedEvent (TopicMessageImpl message, IDiffusionClientConnector connector) |
Raise the message acknowledged event. More... | |
void | RaiseMessageNotAcknowledgedEvent (TopicMessageImpl message, IDiffusionClientConnector connector) |
Raise the message not acknowledged event. More... | |
![]() | |
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] |
![]() | |
IServerDetails | ServerDetails [get] |
Returns the server details. More... | |
V4Credentials | Credentials [get, set] |
Get/set the credentials. More... | |
List< IServerConnectionListener > | ServerConnectionListeners [get, set] |
Get/set the default message listeners. More... | |
IServerPingResponseListener | PingListener [get, set] |
Get/set the ping message listener. More... | |
IServerAckListener | AckListener [get, set] |
Get/set the acknowledgement message listener. More... | |
ConcurrentBag< TopicListenerImpl > | ActionListeners [get, set] |
Get/set the array of action listeners. More... | |
long | AckTimeout [get, set] |
Get/set the acknowledgement timeout. More... | |
bool | HasDefaultListener [get] |
Indicates whether the client connection has a default message listener. More... | |
bool | HasTopicListeners [get] |
Indicates whether the client connection has message listeners. More... | |
bool | CascadeTransports [get] |
![]() | |
EventHandler< MessageEventArgs < TopicMessageImpl > > | TopicMessageReceived |
The event raised when a topic message is received from the Diffusion server. More... | |
EventHandler< MessageEventArgs < TopicStatusMessage > > | TopicStatusChanged |
The event raised when the status of a topic is changed. More... | |
EventHandler< MessageEventArgs < ClientPingMessageImpl > > | ServerPingReceived |
The event raised when a ping is received from the server. More... | |
EventHandler< MessageEventArgs < ServerPingMessageImpl > > | PingResponseReceived |
The event raised when a ping message is received from the Diffusion server. More... | |
EventHandler< MessageEventArgs < CredentialsRejectedMessage > > | CredentialsRejectedReceived |
The event raised when credentials are rejected by the Diffusion server. More... | |
EventHandler < ServerClosedEventArgs > | DiffusionServerConnectionAttemptFailed |
The event raised when connection to the Diffusion server fails. More... | |
EventHandler< MessageEventArgs < TopicMessageImpl > > | DiffusionServerConnected |
The event raised when connection has been established to the Diffusion server. More... | |
EventHandler < ServerClosedEventArgs > | DiffusionServerDisconnected |
The event raised when connection is lost to the Diffusion server. More... | |
EventHandler < ServerRejectedCredentialsEventArgs > | DiffusionServerCredentialsRejected |
The event raised when credentials are rejected by the Diffusion server. More... | |
EventHandler< MessageEventArgs < TopicMessageImpl > > | MessageAcknowledged |
The event raised when a message has been acknowledged by the Diffusion server. More... | |
EventHandler< MessageEventArgs < TopicMessageImpl > > | MessageNotAcknowledged |
The event raised when a message has not been acknowledged by the Diffusion server. More... | |
Represents a diffusion client TCP connection.