FreeOpcUa / python-opcua

                return res

            return self.subscriptions[params.SubscriptionId].monitored_item_srv.create_monitored_items(params)

    def modify_monitored_items(self, params):

        self.logger.info("modify monitored items")

        with self._lock:

            if not params.SubscriptionId in self.subscriptions:

                res = []

                for _ in params.ItemsToModify:

                    result = ua.MonitoredItemModifyResult()

                    result.StatusCode = ua.StatusCode(ua.StatusCodes.BadSubscriptionIdInvalid)

                    res.append(result)

                return res

            return self.subscriptions[params.SubscriptionId].monitored_item_srv.modify_monitored_items(params)

    def delete_monitored_items(self, params):

        self.logger.info("delete monitored items")

            for subid, sub in self.subscriptions.items():

                sub.publish([ack.SequenceNumber for ack in acks if ack.SubscriptionId == subid])

    def create_monitored_items(self, params):

        self.logger.info("create monitored items")

        with self._lock:

            if not params.SubscriptionId in self.subscriptions:

                res = []

                for _ in params.ItemsToCreate:

                    response = ua.MonitoredItemCreateResult()

                    response.StatusCode = ua.StatusCode(ua.StatusCodes.BadSubscriptionIdInvalid)

                    res.append(response)

                return res

            return self.subscriptions[params.SubscriptionId].monitored_item_srv.create_monitored_items(params)

    def modify_monitored_items(self, params):

        self.logger.info("modify monitored items")