lib/client/client_publish_engine.js
/**
 * A client side implementation to deal with publish service.
 *
 * @class ClientSidePublishEngine
 *
 * @param session {ClientSession} - the client session
 * @constructor
 *
 * The ClientSidePublishEngine encapsulates the mechanism to
 * deal with a OPCUA Server and constantly sending PublishRequest
 * The ClientSidePublishEngine also performs  notification acknowledgements.
 * Finally, ClientSidePublishEngine dispatch PublishResponse to the correct
 * Subscription id callback
 */
A client side implementation to deal with publish service.

@param session {ClientSession} - the client session
@constructor

The ClientSidePublishEngine encapsulates the mechanism to
deal with a OPCUA Server and constantly sending PublishRequest
The ClientSidePublishEngine also performs  notification acknowledgements.
Finally, ClientSidePublishEngine dispatch PublishResponse to the correct
Subscription id callback
A client side implementation to deal with publish service . @param session { ClientSession } - the client session @constructor The ClientSidePublishEngine encapsulates the mechanism to deal with a OPCUA Server and constantly sending PublishRequest The ClientSidePublishEngine also performs notification acknowledgements . Finally ClientSidePublishEngine dispatch PublishResponse to the correct Subscription id callback
function ClientSidePublishEngine(session) {
    assert(session instanceof Object);
    this.session = session;
    this.subscriptionAcknowledgements = [];
    this.subscriptionMap = {};
    this.timeoutHint = 10000; 
    this.activeSubscriptionCount = 0;
    this.nbPendingPublishRequests = 0;
    this.nbMaxPublishRequestsAcceptedByServer = 1000;
}
function ClientSidePublishEngine ( session ) { assert ( session instanceof Object ) ; this . session = session ; this . subscriptionAcknowledgements = [ ] ; this . subscriptionMap = { } ; this . timeoutHint = 10000 ; this . activeSubscriptionCount = 0 ; this . nbPendingPublishRequests = 0 ; this . nbMaxPublishRequestsAcceptedByServer = 1000 ; }
A client side implementation to deal with publish service.
A client side implementation to deal with publish service .
// 10 s by default // number of pending Publish request sent to the server and awaited for being processed by the server // the maximum number of publish requests we think that the server can queue. // we will adjust this value .