Pubsub working now!

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "volttron-listener"
-version = "1.0.1"
+version = "1.0.3"
 description = "The volttron-listener agent allows publishing of message bus traffic to standard out."
 authors = ["VOLTTRON Team <[email protected]>"]
 license = "Apache License 2.0"

src/listener/agent.py

@@ -21,19 +21,20 @@
 #
 # ===----------------------------------------------------------------------===
 # }}}
-
+import logging
 import sys
 from pprint import pformat
 import datetime
 
 from volttron.utils.commands import vip_main
 from volttron.client.messaging.health import STATUS_GOOD
 from volttron.client.vip.agent import Agent, Core, PubSub
-from volttron.client.logs import get_logger, setup_logging
+from volttron.client.logs import setup_logging
 import volttron.utils as utils
 
-setup_logging()
-_log = get_logger()
+setup_logging(level=logging.DEBUG)
+_log = utils.get_logger()
+#_log.setLevel(logging.DEBUG)
 __version__ = '4.0'
 DEFAULT_MESSAGE = 'Listener Message'
 DEFAULT_HEARTBEAT_PERIOD = 30
@@ -80,13 +81,16 @@ def onsetup(self, sender, **kwargs):
     @Core.receiver('onstart')
     def onstart(self, sender, **kwargs):
         # TODO: Bring back version?
+        pass
         #_log.debug("VERSION IS: {}".format(self.core.version()))
         if self._heartbeat_period != 0:
             _log.debug(f"Heartbeat starting for {self.core.identity} published every {self._heartbeat_period}")
             self.vip.heartbeat.start_with_period(self._heartbeat_period)
             self.vip.health.set_status(STATUS_GOOD, self._message)
 
-    @PubSub.subscribe('pubsub', '', all_platforms=True)
+        self.vip.pubsub.subscribe(peer='pubsub', prefix='', callback=self.on_match)
+
+    #@PubSub.subscribe('pubsub', '', all_platforms=True)
     def on_match(self, peer, sender, bus, topic, headers, message):
         """Use match_all to receive all messages and print them out."""
         self._logfn(
@@ -103,6 +107,9 @@ def main():
         vip_main(ListenerAgent, version=__version__)
     except Exception as e:
         _log.exception('unhandled exception')
+        _log.exception(e)
+    finally:
+        _log.debug("Exiting")
 
 
 if __name__ == '__main__':