Infinity receiving mode (#15)

* Upgrade installed to new version

* Infinity receiving mode

Author: kornys

installer/CliNetliteInstaller/CliNetliteInstaller.wixproj

@@ -6,7 +6,7 @@
     <ProductVersion>3.10</ProductVersion>
     <ProjectGuid>f13fb7ef-d892-4229-a1eb-8b595d71d64e</ProjectGuid>
     <SchemaVersion>2.0</SchemaVersion>
-    <OutputName>cli-netlite-2.1.4</OutputName>
+    <OutputName>cli-netlite-2.1.5</OutputName>
     <OutputType>Package</OutputType>
   </PropertyGroup>
   <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|x86' ">

installer/CliNetliteInstaller/Product.wxs

@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<?define version="2.1.4"?>
+<?define version="2.1.5"?>
 <?define UpgradeCode="a580c04f-caec-4e18-9134-c4b8f1c8f1be"?>
 <Wix xmlns="http://schemas.microsoft.com/wix/2006/wi">
 	<Product Id="*"
@@ -54,6 +54,9 @@
       <Component Id="Amqp.Net.dll">
         <File Id="Amqp.Net.dll" Source="..\..\src\dotNet\ClientLib\bin\Debug\Amqp.Net.dll" KeyPath="yes" Checksum="yes"/>
       </Component>
+      <Component Id="System.ValueTuple.dll">
+        <File Id="System.ValueTuple.dll" Source="..\..\src\dotNet\ClientLib\bin\Debug\System.ValueTuple.dll" KeyPath="yes" Checksum="yes"/>
+      </Component>
       <Component Id="SetEnvPath"
                      Guid="{016cb18d-0357-425b-90a8-caf1826ddee6}">
         <CreateFolder />
@@ -69,6 +72,7 @@
       <ComponentRef Id="SenderExe" />
       <ComponentRef Id="ReceiverExe" />
       <ComponentRef Id="ConnectorExe"/>
+      <ComponentRef Id="System.ValueTuple.dll"/>
     </Feature>
   </Fragment>
 

src/dotNet/ClientLib/OptionsParser.cs

@@ -141,6 +141,7 @@ public abstract class BasicOptions : LinkOptions
         public int CloseSleep { get; protected set; }
         public string SyncMode { get; protected set; }
         public TimeSpan Timeout { get; protected set; }
+        public bool isInfinityReceiving { get; protected set; }
         public string LogMsgs { get; protected set; }
         public string LogStats { get; protected set; }
         public string LogLib { get; protected set; }
@@ -157,6 +158,7 @@ public BasicOptions() : base()
             this.CloseSleep = 0;
             this.SyncMode = "none";
             this.Timeout = TimeSpan.FromSeconds(1);
+            this.isInfinityReceiving = false;
             this.LogMsgs = "upstream";
             this.LogStats = String.Empty;
             this.LogLib = String.Empty;
@@ -169,7 +171,15 @@ public BasicOptions() : base()
             this.Add("sync-mode=", "sync action",
                 (string syncMode) => { this.SyncMode = syncMode; });
             this.Add("t|timeout=", "timeout",
-                (int timeout) => { this.Timeout = TimeSpan.FromSeconds(timeout); });
+                (int timeout) => {
+                    if (timeout == -1)
+                    {
+                        this.Timeout = TimeSpan.FromDays(100);
+                        this.isInfinityReceiving = true;
+                    }
+                    else
+                        this.Timeout = TimeSpan.FromSeconds(timeout);
+                });
             this.Add("log-msgs=", "log messages output [dict|body|upstream|interop]",
                 (string logMsgs) => { this.LogMsgs = logMsgs; });
             this.Add("log-stats=", "report various statistic/debug information [endpoint]",

src/dotNet/ClientLib/ReceiverClient.cs

@@ -188,14 +188,17 @@ private void ReceiveAll(ReceiverLink receiver, ReceiverOptions options)
         {
             Message message = null;
 
-            while ((message = receiver.Receive(options.Timeout)) != null)
+            while ((message = receiver.Receive(options.Timeout)) != null || options.isInfinityReceiving)
             {
-                Formatter.LogMessage(message, options);
-                Utils.TsSnapStore(this.ptsdata, 'F', options.LogStats);
-
-                if (!String.IsNullOrEmpty(options.MsgSelector))
+                if (message != null)
                 {
-                    receiver.Accept(message);
+                    Formatter.LogMessage(message, options);
+                    Utils.TsSnapStore(this.ptsdata, 'F', options.LogStats);
+
+                    if (!String.IsNullOrEmpty(options.MsgSelector))
+                    {
+                        receiver.Accept(message);
+                    }
                 }
             }
         }
@@ -338,7 +341,7 @@ public void Run(string[] args)
                     bool tx_batch_flag = String.IsNullOrEmpty(options.TxLoopendAction) ? (options.TxSize > 0) : true;
 
                     //receiving of messages
-                    if (options.RecvBrowse || !String.IsNullOrEmpty(options.MsgSelector))
+                    if (options.RecvBrowse || !String.IsNullOrEmpty(options.MsgSelector) || options.isInfinityReceiving)
                         this.ReceiveAll(receiver, options);
                     else
                     {