Inherits IDisposable.
|
| SessionPublishQueue (ServerManager server, Session session, uint maxPublishRequests) |
| Creates a new queue. More...
|
|
void | Dispose () |
| Frees any unmanaged resources. More...
|
|
IList< Subscription > | Close () |
| Clears the queues because the session is closing. More...
|
|
void | Add (Subscription subscription) |
| Adds a subscription from the publish queue. More...
|
|
void | Remove (Subscription subscription) |
| Removes a subscription from the publish queue. More...
|
|
void | SubscriptionStatusChange (Subscription subscription, StatusCode status) |
| Subscriptions the status change. More...
|
|
NotificationMessage | NextStatusChange (out uint subscriptionId) |
| Nexts the status change on the queue. More...
|
|
void | Acknowledge (RequestContext context, SubscriptionAcknowledgementCollection subscriptionAcknowledgements, out StatusCodeCollection acknowledgeResults) |
| Processes acknowledgements for previously published messages. More...
|
|
Subscription | Publish (RequestContext context, bool requeue, IEndpointIncomingRequest incoming) |
| Returns a subscription that is ready to publish. More...
|
|
Subscription | CompletePublish (bool requeue, StatusCode error, object callbackData) |
| Completes the publish. More...
|
|
void | PublishCompleted (Subscription subscription, bool moreNotifications) |
| Adds a subscription back into the queue because it has more notifications to publish. More...
|
|
void | PublishTimerExpired () |
| Checks the state of the subscriptions. More...
|
|
Manages the publish queues for a session.