X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fsbi%2Fnngpub.go;fp=pkg%2Fsbi%2Fnngpub.go;h=c48a40f96ccb52fbc0845d5c991061c56541f9b3;hb=16d84d6f7d3489e65e0a83ba9c0d5d62c3914c7f;hp=02e4ebfd2fda352cc364b9978dfad7644a7a8ad4;hpb=871fa393844ce1b61b8d5218d27687d9fc05803a;p=ric-plt%2Frtmgr.git

diff --git a/pkg/sbi/nngpub.go b/pkg/sbi/nngpub.go
index 02e4ebf..c48a40f 100644
--- a/pkg/sbi/nngpub.go
+++ b/pkg/sbi/nngpub.go
@@ -33,25 +33,34 @@ import (
 	"strconv"
 )
 
-var sock mangos.Socket
+var socket mangos.Socket
+
+func createNngPubEndpointSocket(ep *rtmgr.Endpoint) error {
+	return nil
+}
+
+func destroyNngPubEndpointSocket(ep *rtmgr.Endpoint) error {
+	return nil
+}
 
 /*
 Creates the NNG publication channel
 */
-func openNngPub(url string) error {
+func openNngPub(ip string) error {
 	var err error
-	if sock, err = pub.NewSocket(); err != nil {
+	if socket, err = pub.NewSocket(); err != nil {
 		return errors.New("can't get new pub socket due to:" + err.Error())
 	}
-	rtmgr.Logger.Info("publishing on: " + url)
-	if err = sock.Listen(url); err != nil {
-		return errors.New("can't publish on socket " + url + " due to:" + err.Error())
+	uri := DEFAULT_NNG_PUBSUB_SOCKET_PREFIX + ip + ":" + strconv.Itoa(DEFAULT_NNG_PUBSUB_SOCKET_NUMBER)
+	rtmgr.Logger.Info("publishing on: " + uri)
+	if err = socket.Listen(uri); err != nil {
+		return errors.New("can't publish on socket " + uri + " due to:" + err.Error())
 	}
 	return nil
 }
 
 func closeNngPub() error {
-	if err := sock.Close(); err != nil {
+	if err := socket.Close(); err != nil {
 		return errors.New("can't close socket due to:" + err.Error())
 	}
 	return nil
@@ -59,7 +68,7 @@ func closeNngPub() error {
 
 func publishAll(policies *[]string) error {
 	for _, pe := range *policies {
-		if err := sock.Send([]byte(pe)); err != nil {
+		if err := socket.Send([]byte(pe)); err != nil {
 			return errors.New("Unable to send policy entry due to: " + err.Error())
 		}
 	}