Rudimentary implementation with stomp.py.

etc.skeleton/application.yml

@@ -87,6 +87,8 @@ messaging:
           port: 61613
           username:
           password:
+          protocol: 12
+          destination: '/topic/fcrepo'
 
           # Message format: at the moment only `ActivityStreamsFormatter` is
           # supported.

lakesuperior/messaging/handlers.py

@@ -16,17 +16,18 @@ class StompHandler(logging.Handler):
     informational purpose, this module has a functional one.
     '''
     def __init__(self, conf):
-        super().__init__()
-
-        #import pdb; pdb.set_trace()
+        self.conf = conf
         self.conn = stomp.Connection([(conf['host'], conf['port'])])
         self.conn.start()
         self.conn.connect(conf['username'], conf['password'], wait=True)
 
+        return super().__init__()
+
 
     def emit(self, record):
         '''
         Send the message to the destination endpoint.
         '''
-        self.conn.send('/topic/fcrepo', self.format(record))
+        self.conn.send(destination=self.conf['destination'],
+                body=self.format(record))