src/wiotp/sdk/client.py
def _onPublish(self, mqttc, obj, mid):
        """
        Called when a message from the client has been successfully sent to IBM Watson IoT Platform.
        
        See [paho.mqtt.python#on_publish](https://github.com/eclipse/paho.mqtt.python#on_publish) for more information
        
        # Parameters
        mqttc (paho.mqtt.client.Client): The client instance for this callback
        obj (object): The private user data as set in Client() or user_data_set()
        mid (int): Gives the message id of the successfully published message.
        """
        with self._messagesLock:
            if mid in self._onPublishCallbacks:
                midOnPublish = self._onPublishCallbacks.get(mid)
                del self._onPublishCallbacks[mid]
                if midOnPublish != None:
                    midOnPublish()
            else:
                # record the fact that paho callback has already come through so it can be called inline
                # with the publish.
                self._onPublishCallbacks[mid] = None
def _onPublish(self, mqttc, obj, mid):
        """
        Called when a message from the client has been successfully sent to IBM Watson IoT Platform.
        
        See [paho.mqtt.python#on_publish](https://github.com/eclipse/paho.mqtt.python#on_publish) for more information
        
        # Parameters
        mqttc (paho.mqtt.client.Client): The client instance for this callback
        obj (object): The private user data as set in Client() or user_data_set()
        mid (int): Gives the message id of the successfully published message.
        """
        with self._messagesLock:
            if mid in self._onPublishCallbacks:
                midOnPublish = self._onPublishCallbacks.get(mid)
                del self._onPublishCallbacks[mid]
                if midOnPublish != None:
                    midOnPublish()
            else:
                # record the fact that paho callback has already come through so it can be called inline
                # with the publish.
                self._onPublishCallbacks[mid] = None
def _onPublish ( self , mqttc , obj , mid ) : with self . _messagesLock : if mid in self . _onPublishCallbacks : midOnPublish = self . _onPublishCallbacks . get ( mid ) del self . _onPublishCallbacks [ mid ] if midOnPublish != None : midOnPublish ( ) else : # record the fact that paho callback has already come through so it can be called inline # with the publish. self . _onPublishCallbacks [ mid ] = None
Called when a message from the client has been successfully sent to IBM Watson IoT Platform.
        
        See [paho.mqtt.python#on_publish](https://github.com/eclipse/paho.mqtt.python#on_publish) for more information
        
        # Parameters
        mqttc (paho.mqtt.client.Client): The client instance for this callback
        obj (object): The private user data as set in Client() or user_data_set()
        mid (int): Gives the message id of the successfully published message.
Called when a message from the client has been successfully sent to IBM Watson IoT Platform . See [ paho . mqtt . python#on_publish ] ( https : // github . com / eclipse / paho . mqtt . python#on_publish ) for more information # Parameters mqttc ( paho . mqtt . client . Client ) : The client instance for this callback obj ( object ) : The private user data as set in Client () or user_data_set () mid ( int ) : Gives the message id of the successfully published message .