Commit 6ca22402 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Device component - IETF Slice / NCE FAN Driver: 

- Bug fix in rpc() method call for (un)subscriptions
parent b2ae2f7f

src/device/service/drivers/ietf_slice/handlers/SubscriptionHandler.py

+2 −2
Original line number Diff line number Diff line
@@ -59,7 +59,7 @@ class SubscriptionHandler: 
        try:

            url = '/subscriptions:establish-subscription'

            LOGGER.debug('Subscribing to telemetry: {:s}'.format(str(subscription_data)))

            reply = self._rest_conf_client.rpc(url, json=subscription_data)

            reply = self._rest_conf_client.rpc(url, body=subscription_data)

            LOGGER.debug('Subscription reply: {:s}'.format(str(reply)))

            return reply

        except requests.exceptions.ConnectionError as e:
@@ -74,7 +74,7 @@ class SubscriptionHandler: 
        try:

            url = '/subscriptions:delete-subscription'

            LOGGER.debug('Unsubscribing from telemetry: {:s}'.format(str(unsubscription_data)))

            reply = self._rest_conf_client.rpc(url, json=unsubscription_data)

            reply = self._rest_conf_client.rpc(url, body=unsubscription_data)

            LOGGER.debug('Unsubscription reply: {:s}'.format(str(reply)))

            return reply

        except requests.exceptions.ConnectionError as e:

src/device/service/drivers/nce/handlers/SubscriptionHandler.py

+2 −2
Original line number Diff line number Diff line
@@ -59,7 +59,7 @@ class SubscriptionHandler: 
        try:

            url = '/subscriptions:establish-subscription'

            LOGGER.debug('Subscribing to telemetry: {:s}'.format(str(subscription_data)))

            reply = self._rest_conf_client.rpc(url, json=subscription_data)

            reply = self._rest_conf_client.rpc(url, body=subscription_data)

            LOGGER.debug('Subscription reply: {:s}'.format(str(reply)))

            return reply

        except requests.exceptions.ConnectionError as e:
@@ -74,7 +74,7 @@ class SubscriptionHandler: 
        try:

            url = '/subscriptions:delete-subscription'

            LOGGER.debug('Unsubscribing from telemetry: {:s}'.format(str(unsubscription_data)))

            reply = self._rest_conf_client.rpc(url, json=unsubscription_data)

            reply = self._rest_conf_client.rpc(url, body=unsubscription_data)

            LOGGER.debug('Unsubscription reply: {:s}'.format(str(reply)))

            return reply

        except requests.exceptions.ConnectionError as e: