Diffusion .NET Classic API - Core and Common  5.9.4
 All Classes Namespaces Functions Variables Enumerations Enumerator Properties Events
PushTechnology.DiffusionCore.Messaging.Ack.ServerAckManager Class Reference

More...

Static Public Member Functions

static string NextMessageId ()
 Get the next unique ack id. This should be called to obtain an id when an acknowledgeable message is created. It is possible an Ack with this id never gets created. More...
 
static void CreateAck (ITopicMessage message, IServerAckListener listener, long timeout)
 Creates a new ack entry with the given id (will fail if already present). This should be called at the point of sending a message. More...
 
static void CreateAck (IDiffusionClientConnector connector, ITopicMessage message, EventHandler< MessageEventArgs< TopicMessageImpl >> received, EventHandler< MessageEventArgs< TopicMessageImpl >> notReceived, long timeout)
 Creates a new ack entry with the given id (will fail if already present). This should be called at the point of sending a message. More...
 
static void ReceiveAck (string id)
 Mark ack as received from client. More...
 
static ThreadingHandleContainer ScheduleAck (WaitOrTimerCallback ack, long timeout)
 Schedules an ack for termination. More...
 
static void CloseDown ()
 Cancel all outstanding acks. More...
 

Detailed Description

Member Function Documentation

static void PushTechnology.DiffusionCore.Messaging.Ack.ServerAckManager.CloseDown ( )
static

Cancel all outstanding acks.

static void PushTechnology.DiffusionCore.Messaging.Ack.ServerAckManager.CreateAck ( ITopicMessage  message,
IServerAckListener  listener,
long  timeout 
)
static

Creates a new ack entry with the given id (will fail if already present). This should be called at the point of sending a message.

Parameters
messageThe message.
listenerThe publisher.
timeoutThe timeout for the ack.
static void PushTechnology.DiffusionCore.Messaging.Ack.ServerAckManager.CreateAck ( IDiffusionClientConnector  connector,
ITopicMessage  message,
EventHandler< MessageEventArgs< TopicMessageImpl >>  received,
EventHandler< MessageEventArgs< TopicMessageImpl >>  notReceived,
long  timeout 
)
static

Creates a new ack entry with the given id (will fail if already present). This should be called at the point of sending a message.

Parameters
connectorThe client connector.
messageThe message.
receivedThe 'received' event.
notReceivedThe 'not received' event.
timeoutThe timeout for the ack.
static string PushTechnology.DiffusionCore.Messaging.Ack.ServerAckManager.NextMessageId ( )
static

Get the next unique ack id. This should be called to obtain an id when an acknowledgeable message is created. It is possible an Ack with this id never gets created.

Returns
static void PushTechnology.DiffusionCore.Messaging.Ack.ServerAckManager.ReceiveAck ( string  id)
static

Mark ack as received from client.

Parameters
id
static ThreadingHandleContainer PushTechnology.DiffusionCore.Messaging.Ack.ServerAckManager.ScheduleAck ( WaitOrTimerCallback  ack,
long  timeout 
)
static

Schedules an ack for termination.

Parameters
ack
timeout