Fix send_header_body

NEWS.rst

 Changelog
 =========
 
+7.0.1.1.1 (UNRELEASED)
+----------------------
+
+When a header and a body are requested to be injected in a Xbus emitter job,
+these data must not be inserted in the sent items, but in the job creation
+values.
+
 7.0.1.1.0 (2023-03-22)
 ----------------------
 
 Add the possibility to send a header and a body in Xbus emitter jobs.
 
@@ -4,9 +11,8 @@
 7.0.1.1.0 (2023-03-22)
 ----------------------
 
 Add the possibility to send a header and a body in Xbus emitter jobs.
 
-
 7.0.1.0.0 (2016-12-15)
 ----------------------
 

__openerp__.py

@@ -38,7 +38,7 @@
 
     $ pip install zmq_rpc
 """,
-    "version": "7.0.1.1.0",
+    "version": "7.0.1.1.1",
     "category": "Technical",
     "author": "XCG Consulting",
     "website": "https://orbeet.io/",

model/xbus_emitter.py

@@ -197,7 +197,8 @@
 
         if delayed:
             # Just add to the job queue.
+            job_values = context.get("job_values", {})
 
             emitter_job_id = self.pool["xbus.emitter.job"].create(
                 cr,
                 uid,
@@ -200,12 +201,15 @@
 
             emitter_job_id = self.pool["xbus.emitter.job"].create(
                 cr,
                 uid,
-                {
-                    "emitter_id": emitter.id,
-                    "event_type": event_type,
-                    "items": json.dumps(items),
-                },
+                dict(
+                    {
+                        "emitter_id": emitter.id,
+                        "event_type": event_type,
+                        "items": json.dumps(items),
+                    },
+                    **job_values
+                ),
                 context=context,
             )
 
@@ -330,8 +334,11 @@
             "body": body,
             "chunking": SELECTION_CHUNKING_AUTO,
         }
+
+        context["job_values"] = job_values
+
         return self.send_items(
             cr,
             uid,
             ids,
             event_type,
@@ -333,9 +340,9 @@
         return self.send_items(
             cr,
             uid,
             ids,
             event_type,
-            job_values,
+            {},
             delayed=delayed,
             context=context,
         )