TestAgent

Full code of agent detailed in AgentDevelopment:

import sys

from volttron.platform.vip.agent import Agent, PubSub
from volttron.platform.agent import utils

class TestAgent(Agent):


    def __init__(self, config_path, **kwargs):
        super(TestAgent, self).__init__(**kwargs)

    @PubSub.subscribe('pubsub', 'heartbeat/listeneragent')
    def on_heartbeat_topic(self, peer, sender, bus, topic, headers, message):
           print "TestAgent got\nTopic: {topic}, {headers}, Message: {message}".format(topic=topic, headers=headers, message=message)
           
    
def main(argv=sys.argv):
    '''Main method called by the platform.'''
    utils.vip_main(TestAgent)


if __name__ == '__main__':
    # Entry point for script
    try:
        sys.exit(main())
    except KeyboardInterrupt:
        pass

Contents of setup.py for TestAgent:

packages = find_packages('.')
package = packages[0]

setup(
    name = package + 'agent',
    version = "0.1",
    install_requires = ['volttron'],
    packages = packages,
    entry_points = {
        'setuptools.installation': [
            'eggsecutable = ' + package + '.agent:main',
        ]
    }
)

Contents of testagent.config

{
    "agentid": "Test1",
    "message": "hello"    
}