CMFActivity: Add a function to create hashes

product/CMFActivity/Activity/SQLJoblib.py

@@ -43,6 +43,11 @@ _DequeueMessageException = Exception()
 
 from SQLDict import SQLDict
 
+def sqljoblib_hash(args):
+  signature = joblib_hash(args)
+  sigint = int(signature, 16) % (10 ** 16)
+  return sigint
+
 class SQLJoblib(SQLDict):
   """
     A simple OOBT based queue, It is non transatactional and follow always-excute paradigm.
@@ -79,11 +84,7 @@ class SQLJoblib(SQLDict):
     """
     assert not message.is_registered, message
     message.is_registered = True
-
-    signature = joblib_hash(message.args)
-    sigint = int(signature, 16) % (10 ** 16)
-    message.activity_kw['signature'] = sigint
-
+    message.activity_kw['signature'] = sqljoblib_hash(message.args)
     if activity_buffer.activity_tool is None:
       self.activity_tool = activity_tool
     self.prepareMessage(activity_tool, message)