.NET Based OPC UA Client/Server SDK
3.1.3.516
|
Manages the publish queues for a session. More...
Inherits IDisposable.
Public Member Functions | |
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... | |
Protected Member Functions | |
virtual void | Dispose (bool disposing) |
An overrideable version of the Dispose. More... | |
Manages the publish queues for a session.
UnifiedAutomation.UaServer.SessionPublishQueue.SessionPublishQueue | ( | ServerManager | server, |
Session | session, | ||
uint | maxPublishRequests | ||
) |
Creates a new queue.
void UnifiedAutomation.UaServer.SessionPublishQueue.Acknowledge | ( | RequestContext | context, |
SubscriptionAcknowledgementCollection | subscriptionAcknowledgements, | ||
out StatusCodeCollection | acknowledgeResults | ||
) |
Processes acknowledgements for previously published messages.
void UnifiedAutomation.UaServer.SessionPublishQueue.Add | ( | Subscription | subscription | ) |
Adds a subscription from the publish queue.
IList<Subscription> UnifiedAutomation.UaServer.SessionPublishQueue.Close | ( | ) |
Clears the queues because the session is closing.
Subscription UnifiedAutomation.UaServer.SessionPublishQueue.CompletePublish | ( | bool | requeue, |
StatusCode | error, | ||
object | callbackData | ||
) |
Completes the publish.
requeue | if set to true the request must be requeued. |
error | The error. |
callbackData | The callback data. |
void UnifiedAutomation.UaServer.SessionPublishQueue.Dispose | ( | ) |
Frees any unmanaged resources.
|
protectedvirtual |
An overrideable version of the Dispose.
NotificationMessage UnifiedAutomation.UaServer.SessionPublishQueue.NextStatusChange | ( | out uint | subscriptionId | ) |
Nexts the status change on the queue.
subscriptionId | The subscription id. |
Subscription UnifiedAutomation.UaServer.SessionPublishQueue.Publish | ( | RequestContext | context, |
bool | requeue, | ||
IEndpointIncomingRequest | incoming | ||
) |
Returns a subscription that is ready to publish.
void UnifiedAutomation.UaServer.SessionPublishQueue.PublishCompleted | ( | Subscription | subscription, |
bool | moreNotifications | ||
) |
Adds a subscription back into the queue because it has more notifications to publish.
void UnifiedAutomation.UaServer.SessionPublishQueue.PublishTimerExpired | ( | ) |
Checks the state of the subscriptions.
void UnifiedAutomation.UaServer.SessionPublishQueue.Remove | ( | Subscription | subscription | ) |
Removes a subscription from the publish queue.
void UnifiedAutomation.UaServer.SessionPublishQueue.SubscriptionStatusChange | ( | Subscription | subscription, |
StatusCode | status | ||
) |
Subscriptions the status change.
subscription | The subscription. |
status | The status. |