X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=rwlaunchpad%2Fplugins%2Frwnsm%2Frift%2Ftasklets%2Frwnsmtasklet%2Fpublisher.py;fp=rwlaunchpad%2Fplugins%2Frwnsm%2Frift%2Ftasklets%2Frwnsmtasklet%2Fpublisher.py;h=bff6d49c0f1122d651233e2528f69b58166cdb9e;hb=8c00490fb3a93a707daf86be0c198d86c77d92a0;hp=6c4b1237c2d43b2a8bf35aef077de323446a5ef2;hpb=0ab796706cbf507667fc2f1be4c75979985a1fdf;p=osm%2FSO.git

diff --git a/rwlaunchpad/plugins/rwnsm/rift/tasklets/rwnsmtasklet/publisher.py b/rwlaunchpad/plugins/rwnsm/rift/tasklets/rwnsmtasklet/publisher.py
index 6c4b1237..bff6d49c 100644
--- a/rwlaunchpad/plugins/rwnsm/rift/tasklets/rwnsmtasklet/publisher.py
+++ b/rwlaunchpad/plugins/rwnsm/rift/tasklets/rwnsmtasklet/publisher.py
@@ -1,4 +1,4 @@
-# 
+#
 #   Copyright 2016 RIFT.IO Inc
 #
 #   Licensed under the Apache License, Version 2.0 (the "License");
@@ -62,7 +62,7 @@ class NsrOpDataDtsHandler(object):
         Create an NS record in DTS with the path and message
         """
         self._log.debug("Creating NSR xact = %s, %s:%s", xact, path, msg)
-        self.regh.create_element(path, msg)
+        self.regh.create_element(path, msg, xact=xact)
         self._log.debug("Created NSR xact = %s, %s:%s", xact, path, msg)
 
     @asyncio.coroutine
@@ -71,7 +71,7 @@ class NsrOpDataDtsHandler(object):
         Update an NS record in DTS with the path and message
         """
         self._log.debug("Updating NSR xact = %s, %s:%s regh = %s", xact, path, msg, self.regh)
-        self.regh.update_element(path, msg, flags)
+        self.regh.update_element(path, msg, flags, xact=xact)
         self._log.debug("Updated NSR xact = %s, %s:%s", xact, path, msg)
 
     @asyncio.coroutine
@@ -80,11 +80,10 @@ class NsrOpDataDtsHandler(object):
         Update an NS record in DTS with the path and message
         """
         self._log.debug("Deleting NSR xact:%s, path:%s", xact, path)
-        self.regh.delete_element(path)
+        self.regh.delete_element(path, xact=xact)
         self._log.debug("Deleted NSR xact:%s, path:%s", xact, path)
 
 
-
 class VnfrPublisherDtsHandler(object):
     """ Registers 'D,/vnfr:vnfr-catalog/vnfr:vnfr' DTS"""
     XPATH = "D,/vnfr:vnfr-catalog/vnfr:vnfr"
@@ -134,7 +133,7 @@ class VnfrPublisherDtsHandler(object):
         """
         self._log.debug("Creating VNFR xact = %s, %s:%s",
                         xact, path, msg)
-        self.regh.create_element(path, msg)
+        self.regh.create_element(path, msg, xact=xact)
         self._log.debug("Created VNFR xact = %s, %s:%s",
                         xact, path, msg)
 
@@ -145,7 +144,7 @@ class VnfrPublisherDtsHandler(object):
         """
         self._log.debug("Updating VNFR xact = %s, %s:%s",
                         xact, path, msg)
-        self.regh.update_element(path, msg)
+        self.regh.update_element(path, msg, xact=xact)
         self._log.debug("Updated VNFR xact = %s, %s:%s",
                         xact, path, msg)
 
@@ -155,7 +154,7 @@ class VnfrPublisherDtsHandler(object):
         Delete a VNFR record in DTS with path and message
         """
         self._log.debug("Deleting VNFR xact = %s, %s", xact, path)
-        self.regh.delete_element(path)
+        self.regh.delete_element(path, xact=xact)
         self._log.debug("Deleted VNFR xact = %s, %s", xact, path)
 
 
@@ -208,7 +207,7 @@ class VlrPublisherDtsHandler(object):
         """
         self._log.debug("Creating VLR xact = %s, %s:%s",
                         xact, path, msg)
-        self.regh.create_element(path, msg)
+        self.regh.create_element(path, msg, xact=xact)
         self._log.debug("Created VLR xact = %s, %s:%s",
                         xact, path, msg)
 
@@ -219,7 +218,7 @@ class VlrPublisherDtsHandler(object):
         """
         self._log.debug("Updating VLR xact = %s, %s:%s",
                         xact, path, msg)
-        self.regh.update_element(path, msg)
+        self.regh.update_element(path, msg, xact=xact)
         self._log.debug("Updated VLR xact = %s, %s:%s",
                         xact, path, msg)
 
@@ -229,7 +228,7 @@ class VlrPublisherDtsHandler(object):
         Delete a VLR record in DTS with path and message
         """
         self._log.debug("Deleting VLR xact = %s, %s", xact, path)
-        self.regh.delete_element(path)
+        self.regh.delete_element(path, xact=xact)
         self._log.debug("Deleted VLR xact = %s, %s", xact, path)
 
 
@@ -286,4 +285,3 @@ class VnfdPublisher(object):
             update,
             vnfd
             )
-