|
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...
|
|