Function to send data to xbus

model/xbus_emitter.py

+import logging
 from openerp import api
 from openerp import fields
 from openerp import models
@@ -1,6 +2,10 @@
 from openerp import api
 from openerp import fields
 from openerp import models
+from zmq_rpc import ZmqRpcClient
+
+
+log = logging.getLogger(__name__)
 
 
 class xbus_emitter(models.Model):
@@ -45,3 +50,45 @@
     @api.one
     def name_get(self):
         return self.id, '%s@%s' % (self.login, self.front_url)
+
+    @api.one
+    def send_items(self, event_type, items):
+        """Send the data to Xbus, inside one event with the specified event
+        type.
+        :param event_type: Name of an Xbus event type.
+        :type event_type: String.
+        :type items: Iterable.
+        :return: The result of an "end_event" Xbus API call.
+        """
+
+        # TODO Better handle failures (exceptions / timeouts).
+
+        log.debug('Establishing RPC connection...')
+        conn = ZmqRpcClient(self.front_url)
+        log.debug('RPC connection OK')
+        token = conn.login(self.login, self.password)
+        log.debug('Got connection token: %s', token)
+
+        envelope_id = conn.start_envelope(token)
+        log.debug('Envelope created: %s', envelope_id)
+
+        event_id = conn.start_event(token, envelope_id, event_type, 0)
+        log.debug('Event created: %s', event_id)
+
+        for item in items:
+            conn.send_item(token, envelope_id, event_id, item)
+        log.debug('Data sent (event ID: %s)', event_id)
+
+        ret = conn.end_event(token, envelope_id, event_id)
+        log.debug('Event %s done: return value: %s', event_id, ret)
+
+        conn.end_envelope(token, envelope_id)
+        log.debug('Envelope %s closed', envelope_id)
+
+        conn.logout(token)
+        log.debug('Logged out; terminating')
+
+        conn.close()
+        log.debug('Done.')
+
+        return ret