Merge pull request #258 from sipcapture/resend

added resend
sipcapture · Aug 15, 2023 · 0499d48 · 0499d48
2 parents 32d2ad7 + b5c1814
commit 0499d48
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/main.go b/main.go
@@ -12,7 +12,7 @@ import (
 	"github.com/sipcapture/heplify/sniffer"
 )
 
-const version = "heplify 1.65.6"
+const version = "heplify 1.65.7"
 
 func createFlags() {
 

diff --git a/publish/hep.go b/publish/hep.go
@@ -123,6 +123,12 @@ func (h *HEPOutputer) Send(msg []byte) {
 				if err = h.ReConnect(n); err != nil {
 					logp.Err("reconnect error: %v", err)
 					return
+				} else {
+					h.client[n].writer.Write(msg)
+					err = h.client[n].writer.Flush()
+					if err != nil {
+						logp.Err("Bad resend: %v", err)
+					}
 				}
 			}
 		}