django/smartcity/vagent/backups/django_agent.py
def start(self, sender, **kwargs):
        '''Handle the starting of the agent.
        
        Subscribe to all points in the topics_prefix_to_watch tuple
        defined in settings.py.
        '''
        writer = '~~~~~~~~~~THIS IS SOME TEXT~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~'

        sys.stdout.write(writer)

        now = datetime.utcnow().isoformat(' ') + 'Z'
        headers = {
            # 'AgentID': self._agent_id,
            headers_mod.CONTENT_TYPE: headers_mod.CONTENT_TYPE.PLAIN_TEXT,
            headers_mod.DATE: now,
        }

        self.vip.pubsub.publish(
            peer='pubsub',
            topic='/django/test',
            headers=headers,
            message=writer)

        exit(0)
Handle the starting of the agent.
        
        Subscribe to all points in the topics_prefix_to_watch tuple
        defined in settings.py.
        
Handle the starting of the agent.
Subscribe to all points in the topics_prefix_to_watch tuple
defined in settings.py.
Handle the starting of the agent . Subscribe to all points in the topics_prefix_to_watch tuple defined in settings . py .
def start(self, sender, **kwargs):
        writer = '~~~~~~~~~~THIS IS SOME TEXT~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~'
        sys.stdout.write(writer)
        now = datetime.utcnow().isoformat(' ') + 'Z'
        headers = {
            headers_mod.CONTENT_TYPE: headers_mod.CONTENT_TYPE.PLAIN_TEXT,
            headers_mod.DATE: now,
        }
        self.vip.pubsub.publish(
            peer='pubsub',
            topic='/django/test',
            headers=headers,
            message=writer)
        exit(0)
def start ( self , sender , ** kwargs ) : writer = '~~~~~~~~~~THIS IS SOME TEXT~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~' sys . stdout . write ( writer ) now = datetime . utcnow ( ) . isoformat ( ' ' ) + 'Z' headers = { headers_mod . CONTENT_TYPE : headers_mod . CONTENT_TYPE . PLAIN_TEXT , headers_mod . DATE : now , } self . vip . pubsub . publish ( peer = 'pubsub' , topic = '/django/test' , headers = headers , message = writer ) exit ( 0 )
Handle the starting of the agent.
Handle the starting of the agent .
'''Handle the starting of the agent.
        
        Subscribe to all points in the topics_prefix_to_watch tuple
        defined in settings.py.
        ''' # 'AgentID': self._agent_id,
self
sender