Diffusion .NET Classic API - Core and Common  5.9.4
 All Classes Namespaces Functions Variables Enumerations Enumerator Properties Events
PushTechnology.DiffusionCore.Connection.Connectors.IDiffusionClientTcpConnection Interface Reference

Represents a diffusion client TCP connection. More...

Inheritance diagram for PushTechnology.DiffusionCore.Connection.Connectors.IDiffusionClientTcpConnection:
PushTechnology.DiffusionCore.Connection.Interfaces.IDiffusionClientConnector PushTechnology.DiffusionCore.Connection.Connectors.IClientConnectionHandler PushTechnology.DiffusionCore.Connection.Interfaces.ISyncMessageHandler PushTechnology.DiffusionCore.Connection.Interfaces.IDiffusionClientEvents PushTechnology.DiffusionCore.Connection.Interfaces.IDiffusionClientEventMethods PushTechnology.DiffusionCore.Connection.IDiffusionMessagingConnector PushTechnology.DiffusionCore.Connection.Connectors.IConnectionHandler PushTechnology.DiffusionCore.Messaging.IMessageSource PushTechnology.DiffusionCore.Connection.Connectors.IDiffusionBufferMessageHandler

Additional Inherited Members

- Public Member Functions inherited from PushTechnology.DiffusionCore.Connection.Interfaces.IDiffusionClientConnector
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...
 
- Public Member Functions inherited from PushTechnology.DiffusionCore.Connection.IDiffusionMessagingConnector
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...
 
- Public Member Functions inherited from PushTechnology.DiffusionCore.Connection.Connectors.IClientConnectionHandler
void CreateDiffusionConnection (string data, bool async)
 
void HandleBufferMessage (Byte[] message)
 
void WriteBufferToChannel (ByteBuffer buffer)
 
void WriteBytesToChannel (byte[] bytes)
 
- Public Member Functions inherited from PushTechnology.DiffusionCore.Connection.Connectors.IDiffusionBufferMessageHandler
MessageImpl HandleBufferMessage (ByteBuffer buffer, TopicAliasMap topicAliasMap)
 Handles a message buffer which has a full message in it. The buffer may contain more than a full message but will not contain less. It will have a valid message length in the first two bytes describing how much of the message is to be processed. This method must extract the message that it needs from the buffer but must not change the positioning or limit of the supplied buffer in any way. More...
 
- Public Member Functions inherited from PushTechnology.DiffusionCore.Connection.Interfaces.ISyncMessageHandler
void HandleConnect (SocketAsyncEventArgs args)
 Perform the connection handling. More...
 
void ServerConnectionAttemptFailed (ServerClosedEventArgs args)
 Called when a connection attempt to the server fails. More...
 
void ServerRejectedCredentials (V4Credentials credentials)
 This is called when credentials have been sent to the server and the server has rejected the credentials. More...
 
void ServerDisconnected (ServerClosedEventArgs args)
 Called when the server is disconnected. More...
 
- Public Member Functions inherited from PushTechnology.DiffusionCore.Connection.Interfaces.IDiffusionClientEventMethods
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...
 
- Properties inherited from PushTechnology.DiffusionCore.Connection.Interfaces.IDiffusionClientConnector
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]
 
- Properties inherited from PushTechnology.DiffusionCore.Connection.Connectors.IClientConnectionHandler
IServerDetails ServerDetails [get]
 Returns the server details. More...
 
V4Credentials Credentials [get, set]
 Get/set the credentials. More...
 
List< IServerConnectionListenerServerConnectionListeners [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< TopicListenerImplActionListeners [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]
 
- Properties inherited from PushTechnology.DiffusionCore.Messaging.IMessageSource
MessageSourceType SourceType [get]
 Get/set the message source type. More...
 
- Events inherited from PushTechnology.DiffusionCore.Connection.Interfaces.IDiffusionClientEvents
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...
 

Detailed Description

Represents a diffusion client TCP connection.