Preserve the message order

[ric-plt/xapp-frame.git] / pkg / xapp / types.go

diff --git a/pkg/xapp/types.go b/pkg/xapp/types.go
old mode 100644 (file)
new mode 100755 (executable)
index 2e1eb09..251dae5
--- a/pkg/xapp/types.go
+++ b/pkg/xapp/types.go
@@ -32,6 +32,7 @@ type RMRClient struct {
        context       unsafe.Pointer
        ready         int
        wg            sync.WaitGroup
+       msgWg         sync.WaitGroup
        mux           sync.Mutex
        stat          map[string]Counter
        consumers     []MessageConsumer