Updated parameters to show SetSubscriptionDurable Functionality

OPCFoundation · Oct 14, 2024 · 9fedb96 · 9fedb96
1 parent 4a76a03
commit 9fedb96
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 12 deletions.
diff --git a/Applications/ConsoleReferenceClient/ClientSamples.cs b/Applications/ConsoleReferenceClient/ClientSamples.cs
@@ -358,11 +358,12 @@ public bool SubscribeToDataChanges(ISession session, uint minLifeTime, bool enab
                 int subscriptionPublishingInterval = 1000;
                 int itemSamplingInterval = 1000;
                 uint queueSize = 10;
+                uint lifetime = minLifeTime;
 
                 if (enableDurableSubscriptions)
                 {
-                    subscriptionPublishingInterval = 30000;
-                    queueSize = 600;
+                    queueSize = 100;
+                    lifetime = 20;
                 }
 
                 // Define Subscription parameters
@@ -371,7 +372,8 @@ public bool SubscribeToDataChanges(ISession session, uint minLifeTime, bool enab
                     PublishingEnabled = true,
                     PublishingInterval = subscriptionPublishingInterval,
                     LifetimeCount = 0,
-                    MinLifetimeInterval = minLifeTime,
+                    MinLifetimeInterval = lifetime,
+                    KeepAliveCount = 5,
                 };
 
                 session.AddSubscription(subscription);

diff --git a/Applications/ConsoleReferenceClient/Program.cs b/Applications/ConsoleReferenceClient/Program.cs
@@ -247,6 +247,11 @@ await FindUserCertificateIdentifierAsync(userCertificateThumbprint,
                             }
                         }
 
+                        if ( enableDurableSubscriptions )
+                        {
+                            uaClient.ReconnectPeriodExponentialBackoff = 60000;
+                        }
+
                         bool connected = await uaClient.ConnectAsync(serverUrl.ToString(), !noSecurity, quitCTS.Token).ConfigureAwait(false);
                         if (connected)
                         {
@@ -385,6 +390,7 @@ await samples.SubscribeAllValuesAsync(uaClient,
                                 if (enableDurableSubscriptions)
                                 {
                                     quitTimeout = 150_000;
+                                    uaClient.ReconnectPeriod = 500_000;
                                 }
 
                                 NodeId sessionNodeId = uaClient.Session.SessionId;
@@ -394,27 +400,23 @@ await samples.SubscribeAllValuesAsync(uaClient,
                                 samples.Browse(uaClient.Session);
                                 samples.CallMethod(uaClient.Session);
                                 samples.EnableEvents(uaClient.Session, (uint)quitTimeout);
-                                bool isDurable = samples.SubscribeToDataChanges(
+                                samples.SubscribeToDataChanges(
                                     uaClient.Session, 60_000, enableDurableSubscriptions);
-                                if ( isDurable )
-                                {
-                                    // Need to control the reconnect
-                                    uaClient.ReconnectPeriod = 200_000;
-                                }
 
                                 output.WriteLine("Waiting...");
 
                                 // Wait for some DataChange notifications from MonitoredItems
                                 int waitCounters = 0;
                                 int checkForWaitTime = 1000;
-                                int closeSessionTime = checkForWaitTime * 35;
-                                int restartSessionTime = checkForWaitTime * 65;
+                                int closeSessionTime = checkForWaitTime * 15;
+                                int restartSessionTime = checkForWaitTime * 45;
                                 bool stopNotQuit = false;
+                                int stopCount = 0;
                                 while (!quit && !stopNotQuit && waitCounters < quitTimeout)
                                 {
                                     quit = quitEvent.WaitOne(checkForWaitTime);
                                     waitCounters += checkForWaitTime;
-                                    if (isDurable)
+                                    if (enableDurableSubscriptions)
                                     {
                                         if (waitCounters == closeSessionTime)
                                         {
@@ -433,6 +435,12 @@ await uaClient.DurableSubscriptionTransfer(
                                                 useSecurity: !noSecurity,
                                                 quitCTS.Token);
                                         }
+
+                                        if ( waitCounters > closeSessionTime && waitCounters < restartSessionTime )
+                                        {
+                                            Console.WriteLine("No Communication Interval " + stopCount.ToString());
+                                            stopCount++;
+                                        }
                                     }
                                 }
                             }